RabbitMQ 死信队列监听器最佳实践：重试和异常处理

使用 @Component 监听 RabbitMQ 死信队列时，需要谨慎处理消息消费失败的情况，避免死循环或资源浪费。以下代码示例中存在两个潜在问题：

没有进行消息重试： 当消息消费失败时，代码使用了 channel.basicNack 将消息重新发送到原队列，但没有进行重试。如果消息消费失败的原因是暂时的，例如网络抖动等，那么消息会被不断地重新发送到原队列，导致死循环。
没有对消费异常进行处理： 如果消息消费失败的原因是不可恢复的，例如消息格式错误等，那么将消息重新发送到原队列也无济于事，会一直占用资源，影响队列的正常消费。

为了解决这些问题，需要将消息重试和消费异常处理加入到代码中。可以使用 RabbitMQ 提供的 DLX 和 TTL 机制，将原队列设置为死信交换机，将消息发送到死信队列后，再将死信队列绑定到一个新的消费队列上，对新的消费队列进行消息消费。

具体实现步骤如下：

设置死信交换机（DLX）： 在创建原队列时，设置 x-dead-letter-exchange 属性为死信交换机的名称。
设置消息存活时间（TTL）： 在创建原队列时，设置 x-message-ttl 属性为消息的存活时间，例如 30000 毫秒（30 秒）。
创建新的消费队列： 创建一个新的消费队列，用于消费死信队列中的消息。
绑定死信队列到新的消费队列： 将死信队列绑定到新的消费队列，并将路由键设置为死信交换机的名称。

通过以上步骤，可以实现以下功能：

当消息在原队列中消费失败时，会根据 TTL 设置自动进入死信队列。
死信队列中的消息会自动被转发到新的消费队列，并进行重新消费。
可以通过设置重试次数和 TTL 来控制消息重试的次数和时间。
如果消息消费失败的原因是不可恢复的，可以记录日志等方式进行异常处理。

代码示例：

@Component
public class MQDeadLetterListener {

    private final Logger logger = LoggerFactory.getLogger(getClass());

    @RabbitListener(queuesToDeclare = @Queue(name = "movie.type.list.dead", arguments = {
            @Argument(name = "x-dead-letter-exchange", value = "movie.type.list.dlx"),
            @Argument(name = "x-message-ttl", value = 30000)
    }))
    public void consumer(Message message, Channel channel) throws Exception {
        String msgId = message.getMessageProperties().getCorrelationId();
        try {
            // 消费消息逻辑
            logger.info('消息发送到死信队列. msgId={}, body={}', msgId, new String(message.getBody()));
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        } catch (Exception e) {
            logger.error('消息消费失败，将重新发送. msgId={}, body={}', msgId, new String(message.getBody()));
            channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
        }
    }
}

注意：

以上示例代码仅供参考，实际实现中可能需要根据具体情况进行调整。
建议在开发过程中充分测试消息重试和异常处理机制，确保消息能够被正确消费。