RocketMQ（三）——————javaAPI(8.重试机制)

//添加重试机制
    public static void main(String[] args) throws Exception {

        DefaultMQProducer producer = new DefaultMQProducer("MQ2Group");

        producer.setNamesrvAddr("127.0.0.1:9876");

        producer.start();

        //异步发送 重试次数 系统默认是2
        producer.setRetryTimesWhenSendAsyncFailed(1);
        //同步发送 重试次数 系统默认是2
//        producer.setRetryTimesWhenSendFailed(1);
        producer.send(new Message("MQ2Topic","回调消息!".getBytes()));
        producer.setRetryAnotherBrokerWhenNotStoreOK(true);
//        producer.shutdown();
        System.out.println("生产者下线！");

    }

    //接收消息
    public static void main(String[] args) throws Exception {

        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("MQ2Group");

        consumer.setNamesrvAddr("127.0.0.1:9876");

        consumer.subscribe("MQ2Topic","*");
        consumer.registerMessageListener(new MessageListenerConcurrently() {

            public ConsumeConcurrentlyStatus consumeMessage(List list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {

                for (MessageExt mes: list) {

                    System.out.println("mes : "+new String(mes.getBody()));
                }

                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
            }
        });



        consumer.start();
        System.out.println("Consumer  start...");
    }