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