订阅专栏
RocketMQ使用教程相关系列 目录
#所属集群名字 brokerClusterName=xuzhu_cluster ##broker名称,主从要一样,根据BrokerRole来确定谁是主谁是从 brokerName=broker-a #0 表示 Master,>0 表示 Slave brokerId=0 #nameServer 地址,分号分割 namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876 #在发送消息时,自动创建服务器不存在的 topic,默认创建的队列数 defaultTopicQueueNums=4 #是否允许 Broker 自动创建 Topic,建议线下开启,线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 #brokerIP1 当前broker监听的IP brokerIP1=192.168.88.131 #存在broker主从时,在broker主节点上配置了brokerIP2的话,broker从节点会连接主节点配置的#brokerIP2来同步。 brokerIP2=192.168.88.131 listenPort=10911 #删除文件时间点,默认凌晨 4 点 deleteWhen=04 #文件保留时间,默认 48 小时 fileReservedTime=120 #commitLog 每个文件的大小默认 1G mapedFileSizeCommitLog=1073741824 #ConsumeQueue 每个文件默认存 30W 条,根据业务情况调整 mapedFileSizeConsumeQueue=300000 #destroyMapedFileIntervalForcibly=120000 #redeleteHangedFileInterval=120000 #检测物理文件磁盘空间 checkTransactionMessageEnable diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/usr/local/server/mq/rocketmq/store #commitLog 存储路径 storePathCommitLog=/usr/local/server/mq/rocketmq/store/commitlog #消费队列存储路径存储路径 storePathConsumeQueue=/usr/local/server/mq/rocketmq/store/consumequeue #消息索引存储路径 storePathIndex=/usr/local/server/mq/rocketmq/store/index #checkpoint 文件存储路径 storeCheckpoint=/usr/local/server/mq/rocketmq/store/checkpoint #abort 文件存储路径 abortFile=/usr/local/server/mq/rocketmq/store/abort #限制的消息大小 maxMessageSize=65536 #flushCommitLogLeastPages=4 #flushConsumeQueueLeastPages=2 #flushCommitLogThoroughInterval=10000 #flushConsumeQueueThoroughInterval=60000 #Broker 的角色 #- ASYNC_MASTER 异步复制 Master #- SYNC_MASTER 同步双写 Master #- SLAVE brokerRole=ASYNC_MASTER #刷盘方式 #- ASYNC_FLUSH 异步刷盘 #- SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH #checkTransactionMessageEnable=false #发消息线程池数量 #sendMessageThreadPoolNums=128 #拉消息线程池数量 #pullMessageThreadPoolNums=128 #默认该值为false,表示该Broker不承载系统自定义用于存储消息轨迹的topic traceTopicEnable=false #默认回查次数是15次,15次后还没成功就回滚 transactionCheckMax=15 #transactionCheckInterval参数:默认定时回查间隔时间是1分钟 transactionCheckInterval=60000
参考:
RocketMQ中broker配置brokcerIP1和brokerIP2的作用:https://blog.csdn.net/jiajiren11/article/details/80528406