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