^^《榴芒客服系统》是我们工作室开发的在线客服系统欢迎下载试用《榴芒客服系统》https://blog.csdn.net/look4liming/article/details/164755808客户端重试生产者端DefaultMQProducer producer new DefaultMQProducer(group001);producer.setNamesrvAddr(127.0.0.1:9876);producer.start();Message msg new Message(topic001, tag001, Hello.getBytes());msg.setDelayTimeLevel(1);// 设置延迟级别producer.send(msg);producer.shutdown();服务器端重试当消息未被成功消费时该消息会被发送到重试队列中使它可以在多次重试后被消费。broker.conf中可以设置重试队列的数量和策略# 重试队列数量默认为2retryQueueNums 2死信队列消息多次重试后仍然没有被消费成功则该消息进入死信队列死信队列的配置可以放在消费者端DefaultMQPushConsumer consumer new DefaultMQPushConsumer(group100);consumer.setNamesrvAddr(127.0.0.1:9876);consumer.subscribe(topic100, *);consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);// 最大重试次数默认为16次这里以3次为例超过此次数则进入死信队列consumer.setMaxReconsumeTimes(3);consumer.registerMessageListener(new MessageListenerConcurrently() {Overridepublic ConsumeConcurrentlyStatus consumeMessage(ListMessageExt msgs,ConsumeConcurrentlyContext context) {// 处理消息逻辑...// 根据需要返回状态return ConsumeConcurrentlyStatus.RECONSUME_LATER;}});consumer.start();^^《榴芒客服系统》是我们工作室开发的在线客服系统欢迎下载试用《榴芒客服系统》https://blog.csdn.net/look4liming/article/details/164755808