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

 

 

 

1. RocketMq 消息重发的次数

上一篇:ak和sk的意思及用法


下一篇:接雨水