美文网首页RocketMQ
RocketMQ Topic配置

RocketMQ Topic配置

作者: 王广帅 | 来源:发表于2020-02-24 14:25 被阅读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;
}

相关文章

网友评论

    本文标题:RocketMQ Topic配置

    本文链接:https://www.haomeiwen.com/subject/dhqvqhtx.html