在创建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;
}
网友评论