美文网首页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