使用RetryOperationsInterceptor如何让消费异常消息重回队列尾部而非头部

默认使用RetryOperationsInterceptor时，消费异常触发的消息重入队列走的是RabbitMQ原生basic.nack/reject的requeue=true逻辑，RabbitMQ的原生机制会直接将消息放回原队列头部，因此会优先重试同一条消息。要实现将消息放到队列尾部重试，可通过以下两种方案实现：

方案1：自定义重试恢复逻辑，手动投递到队尾 #

• 替换RetryOperationsInterceptor默认的重试恢复器，自定义RecoveryCallback逻辑
• 重试次数耗尽后，先调用basic.nack设置requeue=false丢弃原队列头部的待重试消息
• 保留原消息的全部内容和属性，追加重试次数字段到消息头后，手动调用RabbitTemplate将消息发送到原业务队列，新发送的消息会自动进入队列尾部
• 注意事项：必须做好消费接口的幂等校验，避免消息重复投递导致的业务异常；同时需要设置最大重试次数阈值，避免消息无限循环投递占用队列资源。

代码示例 #

@Bean
public RetryOperationsInterceptor customRetryInterceptor(RabbitTemplate rabbitTemplate) {
    return RetryInterceptorBuilder.stateless()
            // 单次消费时的内部最大重试次数
            .maxAttempts(3)
            // 重试退避策略：初始间隔1s，倍率2，最大间隔5s
            .backOffOptions(1000, 2, 5000)
            .recoverer((data, cause) -> {
                Message message = (Message) data;
                // 从消息头读取已重试次数，无则默认0
                Integer retryCount = message.getMessageProperties().getHeader("x-custom-retry-count");
                retryCount = retryCount == null ? 0 : retryCount;
                // 总重试次数不超过阈值则转队尾重试
                if (retryCount < 5) {
                    message.getMessageProperties().setHeader("x-custom-retry-count", retryCount + 1);
                    // 发送消息到原队列，自动进入队尾
                    rabbitTemplate.send(
                            message.getMessageProperties().getReceivedExchange(),
                            message.getMessageProperties().getReceivedRoutingKey(),
                            message
                    );
                    // 拒绝原消息，不重入队列
                    throw new AmqpRejectAndDontRequeueException("转队尾重试", cause);
                }
                // 超过最大重试次数可自定义落库/告警/进死信队列逻辑
                throw new AmqpRejectAndDontRequeueException("超过最大重试次数，终止投递", cause);
            })
            .build();
}

方案2：基于死信队列流转实现 #

• 为原业务队列配置死信交换机和死信路由键，消费异常时直接设置requeue=false，消息会自动进入死信交换机
• 绑定死信队列到上述死信交换机，编写死信队列消费者，消费到死信消息后校验重试次数，符合条件则转发到原业务队列尾部
• 该方案优势是可以统一管控所有重试消息，便于实现重试统计、异常告警等附加运维能力。

内容的提问来源于stack exchange，提问作者abullor