1. RocketMq 消息重发的次数


DefaultMQProducer 

看这个使用过程 , 第一次是没有设置任何的参数  listener就直接重复接收我故意设置为  consume_later的消息, 发现回收的时间越来越慢 , 现在看下有12条记录, 他的 messageID是不相同的, 而 我后来又把 consumer的设置进行了改动, 

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("SK_Consumer_Group");
consumer.setNamesrvAddr("127.0.0.1:9876");
consumer.setInstanceName("SK_Consumber");
System.out.println("max resonsume Times = " + consumer.getMaxReconsumeTimes());  //这个没有设置之前, 值打印出来是 -1 , 实际后面重复发送了12次
consumer.setMaxReconsumeTimes(3);  // 这边是设置了3次, 后面的消息就是 看到重复是3 条 C6D26E47794C18B4AAC25079D5BF0000

 

 

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM