RocketMQ

RocketMQ Topic配置

2020-02-24  本文已影响0人  王广帅

在创建Topic时,需要输入一些参数,这些参数和项目中Topic的配置类一一对应,这个类是TopicConfig,它在rocketmq-common。如下所示:

/**
 * 
 * @ClassName: TopicConfig 
 * @Description: RocketMQ的Topic配置数据,在创建Topic时会更新这里面的配置。
 * @author: wang guang shuai
 * @date: 2020年2月24日 下午1:56:43
 */
public class TopicConfig {
    private static final String SEPARATOR = " ";
    //默认的topic读队列数量
    public static int defaultReadQueueNums = 16;
    //默认的topic写队列数量
    public static int defaultWriteQueueNums = 16;
    //topic的名字
    private String topicName;
    private int readQueueNums = defaultReadQueueNums;
    private int writeQueueNums = defaultWriteQueueNums;
    /**
     * topic的权限控制:默认是既可以读取,又可以写入值为6,具体的权限规则见{@link PermName },| 算法:两个操作数对应的二进制位,有1则为1,否则为0。如:1|1=1; 1|0=1; 0|1=1; 0|0=0
     */
    private int perm = PermName.PERM_READ | PermName.PERM_WRITE;
    /** topic 过滤类型 */
    private TopicFilterType topicFilterType = TopicFilterType.SINGLE_TAG;
    
    private int topicSysFlag = 0;
    private boolean order = false;
}
上一篇 下一篇

猜你喜欢

热点阅读