spring boot集成rabbitmq实现可靠消息投递需四层设防：1. 生产者启用confirm+return机制；2. broker端消息与队列、交换机均持久化；3. 消费者手动ack+幂等处理；4. 本地消息表+定时补偿兜底。
Spring Boot 集成 RabbitMQ 实现可靠消息投递，关键不是堆配置，而是分层设防：生产者不丢、Broker 不丢、消费者不错、失败有兜底。四层机制缺一不可，下面直接说清楚怎么做。
开启生产者确认与返回机制
默认情况下，rabbitTemplate.convertAndSend() 发完即走，网络抖动或路由失败根本无感知。必须启用 Confirm + Return 双机制：
- 在
application.yml中明确配置：spring.rabbitmq.publisher-confirm-type: correlatedspring.rabbitmq.publisher-returns: truespring.rabbitmq.template.mandatory: true - 启动时注册异步回调，捕获投递结果：
@PostConstruct
public void init(RabbitTemplate template) {
template.setConfirmCallback((correlationData, ack, cause) -> {
if (ack) {
// 消息已成功落盘，可更新 DB 状态为“已发送”
} else {
// NACK，需触发重试逻辑
}
});
template.setReturnsCallback(returned -> {
// routing key 错、exchange 不存在等场景会进这里
log.warn("消息退回：{} → {}，原因：{}", returned.getExchange(), returned.getRoutingKey(), returned.getReplyText());
});
}
确保消息在 Broker 端持久化
仅靠 Confirm 不能防止 RabbitMQ 崩溃丢数据。必须让消息真正写入磁盘：
Java开发手册规约集合，基于阿里巴巴Java开发手册（嵩山版）。 涵盖7大维度：编程规约、异常日志、单元测试、安全规约、MySQL数据库、工程结构、设计规约。 当用户需要：(1) 编写或审查Java代码 (2) 检查命名/代码规范 (3) 处理异常和日志 (4) 编写单元测试 (5) 安全编码 (6) 数据库设...
- 声明队列时设置
durable = true（Spring AMQP 默认已开启） - 发送消息时设置
MessageProperties.DELIVERY_MODE_PERSISTENT（Spring Boot 3.x 中convertAndSend()默认就是持久化模式） - 交换机也需声明为 durable（
DirectExchange(..., true, false)），否则重启后绑定丢失
消费者手动 ACK + 幂等处理
自动 ACK 一旦消费线程崩溃，消息就永久丢失；而手动 ACK 要求你明确控制提交时机：
- 配置
spring.rabbitmq.listener.simple.acknowledge-mode: manual - 在监听方法中，业务逻辑成功后再调用
channel.basicAck(deliveryTag, false) - 若抛异常或主动拒绝，用
channel.basicNack(..., true, false)触发重入队（注意避免死循环） - 务必对消息做幂等判断——推荐用业务唯一 ID（如订单号）+ Redis 或数据库记录已处理状态
补漏：本地消息表 + 定时补偿
Confirm 回调可能因网络闪断未送达，这是最终防线：
- 发送前，将消息 ID、内容、状态（“发送中”）、重试次数存入本地数据库
- Confirm 成功后，更新状态为“已发送”
- 起一个定时任务（如每 30 秒），扫描状态为“发送中”且创建时间 > 60 秒的记录，重新投递
- 重试达上限（建议 3 次）后，转存至失败表，人工介入或接入告警
