一、重试机制

首先说一下RabbitMQ的消息重试机制，顾名思义，就是消息消费失败后进行重试，重试机制的触发条件是消费者显式的抛出异常，这个很类似@Transactional，如果没有显式地抛出异常或者try catch起来没有手动回滚，事务是不会回滚的。

以下代码可以触发重试机制

还有一种情况就是消息被拒绝后重新加入队列,比如basic.reject和basic.nack，并且requeue = true，但是个人认为这个不算是触发了重试机制，这个是重新进入到了消息队列然后重新被消费，并且也不会触发我们重试机制的配置(如重试间隔、最大重试次数等等)。

重试机制是默认开启的，但是如果没有重试机制相关的配置会导致消息一直无间隔的重试，直到消费成功，所以要使用重试机制一定要有相关配置。

spring:rabbitmq:host: 127.0.0.1port: 5672virtual-host: mq-testusername: ********password: ********listener:simple:# ACK模式(none,auto,manual,默认为auto)acknowledge-mode: auto# 开启重试retry:# 是否开启重试机制enabled: true# 最大重试次数max-attempts: 5# 重试间隔(ms)initial-interval: 5000

二、死信队列

说到死信队列，首先需要知道什么是死信

死信就是消息在特定场景下的一种表现形式，这些场景包括：

消息被拒绝(basic.reject / basic.nack)，并且requeue = false
消息的 TTL 过期时
消息队列达到最大长度
达到最大重试限制

消息在这些场景中时，被称为死信。

死信队列就是用于储存死信的消息队列，在死信队列中，有且只有死信构成，不会存在其余类型的消息。死信队列也是一个普通队列，也可以被消费者消费，区别在于业务队列需要绑定在死信队列上，才能正常地把死信发送到死信队列上。

业务队列绑定死信队列

三、重试+死信的实现

文章开头的场景有两种方案可以实现

方案一：使用自动ACK + RabbitMQ重试机制

方案二：使用手动ACK + 手动重试机制

3.1 自动ACK + RabbitMQ重试机制

配置

spring:rabbitmq:host: 127.0.0.1port: 5672virtual-host: mq-testusername: ********password: ********listener:simple:# ACK模式(默认为auto)acknowledge-mode: auto# 开启重试retry:enabled: truemax-attempts: 5initial-interval: 5000

消费者

   @RabbitListener(queues = RabbitMqConfig.USER_ADD_QUEUE, concurrency = "10")public void userAddReceiver(String data, Message message, Channel channel) throws Exception {UserVo vo = OBJECT_MAPPER.readValue(data, UserVo.class);boolean success = messageHandle(vo);// 通过业务控制是否消费成功，消费失败则抛出异常触发重试if (!success) {log.error("消费失败");throw new Exception("消息消费失败");}}

需要说明的是，上述的方法一定要开启自动ACK，才会在到达最大重试上限后发送到死信队列，而且在重试过程中会独占当前线程，如果是单线程的消费者会导致其他消息阻塞，直至重试完成，所以可以使用@RabbitListener上的concurrency属性来控制并发数量。

3.2 手动ACK + 手动重试

配置

spring:rabbitmq:host: 127.0.0.1port: 5672virtual-host: mq-testusername: ********password: ********listener:simple:# ACK模式(默认为auto)acknowledge-mode: manual

需要说明的是，如果是手动ACK配置了重试机制，在抛出异常的时候仍会触发重试，但是达到重试上限之后，会永远处于Unacked状态，不会进入到死信队列，必须要手动拒绝才可以进入死信队列，所以说这里不用配置重试机制而是采用手动重试的方式

消费者

/*** 消息最大重试次数*/
private static final int MAX_RETRIES = 3;/*** 重试间隔(秒)*/
private static final long RETRY_INTERVAL = 5;private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();@RabbitListener(queues = RabbitMqConfig.USER_ADD_QUEUE, concurrency = "10")
public void userAddReceiver(String data, Message message, Channel channel) throws IOException, InterruptedException {UserVo vo = OBJECT_MAPPER.readValue(data, UserVo.class);// 重试次数int retryCount = 0;boolean success = false;// 消费失败并且重试次数<=重试上限次数while (!success && retryCount < MAX_RETRIES) {retryCount++;// 具体业务逻辑success = messageHandle(vo);// 如果失败则重试if (!success) {String errorTip = "第" + retryCount + "次消费失败" +((retryCount < 3) ? "," + RETRY_INTERVAL + "s后重试" : ",进入死信队列");log.error(errorTip);Thread.sleep(RETRY_INTERVAL * 1000);}}if (success) {// 消费成功，确认channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);log.info("创建订单数据消费成功");} else {// 重试多次之后仍失败，进入死信队列channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);log.info("创建订单数据消费失败");}
}

总结：两种方案都可以达到我们的预期效果，相比起来方案一会更加的方便简洁，方案二的可控性更高

RabbitMQ重试机制+死信队列相关推荐

Apache Kafka-消费端消费重试和死信队列
文章目录概述 Code POM依赖配置文件配置类 SeekToCurrentErrorHandler 自定义逻辑处理消费异常生产者消费者单元测试测速结果源码地址概述 Spring-K ...
6.RokcketMQ消息重试与死信队列
消息发送重试机制 Producer对发送失败的消息进行重新发送的机制,称为消息发送重试机制,也称为消息重投机制. 对于消息重投,需要注意以下几点: 生产者在发送消息时,若采用同步或异步发送方式,发送失 ...
RabbitMQ重试机制
1.RabbitMQ重试机制的简介 RabbitMQ 不会为未确认的消息设置过期时间,它判断此消息是否需要重新投递给消费者的唯一依据是消费该消息连接是否已经断开,这个设置的原因是 RabbitMQ 允 ...
RabbitMQ高级特性——死信队列DLX以及代码测试
大伙可以到我的RabbitMQ专栏获取更多信息 demo示例这里拿概述死信队列,缩写DLX(dead letter exchange 死信交换机),当消息称为dead message之后,会被重新 ...
spring boot + rabbitMq整合之死信队列（DL）
rabbit mq 死信队列什么是死信队列? DL-Dead Letter 死信队列死信,在官网中对应的单词为"Dead Letter",可以看出翻译确实非常的简单粗暴.那么死 ...
RabbitMQ的TTL+死信队列看完这篇包会！！！
这里写目录标题一:TTL队列过期时间设置二:TTL消息过期时间设置三:死信队列 - 第一种是声明队列的时候,在队列的属性中设置,这样该队列中的消息都会有相同的有效期: -第二种是发送消息时给消息 ...
RabbitMQ TTL、死信队列在订单支付场景的应用
基于RabbitMQ的TTL以及死信队列,使用SpringBoot实现延迟付款,手动补偿操作. 1.用户下单后展示等待付款页面 2.在页面上点击付款的按钮,如果不超时,则跳转到付款成功页面 3.如果超 ...
Rabbitmq消费失败死信队列
为什么80%的码农都做不了架构师?>>> Rabbitmq 重消费处理一处理流程图: 业务交换机:正常接收发送者,发送过来的消息,交换机类型topic AE交换机: ...
Rabbitmq死信队列
目录 1.什么是死信队列 2.产生死信队列的原因 3.代码实现---直连交换机 3.1.导入依赖 3.2.配置rabbitmq连接信息 3.3.编写配置类 3.4.编写生产者 3.5.编写消费者 3. ...

RabbitMQ重试机制+死信队列