标签：slave 192.168 9876 集群 rocketMQ var rocketmq store 搭建

准备四台机器

 

 

 

 

 先实现2主2从同步

 

 

 修改主 配置文件

 

 

 brokerName //主从要一致

brokerId=0 // master 是0  slave>0

brokerRole=SYNC_MASTER   ASYNC_MASTER   //同步规则 

flushDiskType=ASYNC_FLUSH  //异步刷盘 存储到磁盘异步

nameservAddr=192.168.150.11:9876;192.168.150.12:9876;192.168.150.13:9876;

storePathRootDir=/var/rocketmq/store

storePathCommitLog=/var/rocketmq/store/commitlog

storePathIndex=/var/rocket/store/index

storePathConsumeQueue=/var/rocketmq/store/consumequeue

----

 slave配置

 

 

 

 -----

broker-b  m

 

broker-b slave

 

 

 ---

 

 修改堆大小

 

 

 

 

 

 

 

 

 

 

 MessageListenerConcurrently  是无序消费消息 线程安全  返回两个状态  一个是消费成功  一个是过一会再试

 

 这个出现异常 会进行消息重新投递给consumer  重复投递时间如下

设置最大重新消费次数 为2次

 

 

 当设置了

 

rocketMQ 就会维护一个延时队列  和一个死信队列  当消息达到最大重试次数  消息就会到达死信队列中

 

标签：slave,192.168,9876,集群,rocketMQ,var,rocketmq,store,搭建
来源： https://www.cnblogs.com/Lcch/p/16631826.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。