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