RabbitMQ宕机后消息卡在Unacked状态，因TCP连接未正常断开导致Broker无法触发重入队；需配置心跳、手动ACK、RepublishMessageRecoverer及惰性队列等保障消息可靠性。
微服务宕机后，RabbitMQ 不会自动删消息，也不会自动重发给其他存活消费者——除非你明确配置了连接断开后的重入队行为，且消费者没用 autoAck。
为什么宕机后消息还卡在 Unacked 状态？
RabbitMQ 的未确认消息（Unacked）是否重新入队，只取决于一个条件：消费者 TCP 连接是否真正断开。而 Spring Cloud 默认的 SimpleMessageListenerContainer 在 JVM 崩溃或 Kill -9 时，往往来不及发送 AMQP 的 connection.close 帧，Broker 就收不到断连通知，于是认为消费者“还在”，消息一直维持 Unacked 状态。
常见表现：
- 服务进程已消失，但 RabbitMQ Management UI 里队列的
Unacked数不降反升（因心跳超时前又投了几条） - 其他同组消费者没收到新消息，因为
prefetch被占满，且 Broker 不敢把 Unacked 消息再分发 - 重启原服务后，这些消息立刻被重新投递，造成重复消费
如何让宕机消息安全回到 Ready 队列？
核心是让 RabbitMQ 尽快感知连接死亡，并触发自动 requeue。关键配置点如下：
- 在消费者端设置
spring.rabbitmq.listener.simple.missing-queues-fatal=false（避免启动失败掩盖问题） - 显式配置
spring.rabbitmq.listener.simple.shutdown-timeout=5s，让容器关闭时尽量发 close 帧 - 调低心跳：在
application.yml中设spring.rabbitmq.listener.simple.heartbeat=10s（默认 60s 太长，Broker 要等 2×heartbeat 才判定断连） - 确保没开启
noack=true或acknowledge-mode: auto；必须是acknowledge-mode: manual - 禁用
default-requeue-rejected: true（它只影响basicNack，和宕机无关）
注意：prefetch 值不宜过大（如设为 1），否则一条 Unacked 消息就卡死整个并发吞吐。
Spring Cloud 下更稳妥的兜底方案：RepublishMessageRecoverer
靠心跳检测不可靠，尤其在 K8s Pod 突然终止、网络分区等场景下。推荐用 RepublishMessageRecoverer 主动接管失败消息，而不是依赖 Broker 自动重入队。
RabbitMQ 4.2.3 是 2026 年初发布的重要稳定更新版本，重点修复了 Khepri 元数据存储相关问题，并改进了监控性能。对于使用 Docker、Kubernetes 或微服务架构的开发团队来说，该版本兼容性和稳定性表现较好。
它会在消费者抛出未捕获异常、或线程池拒绝任务时，把原始消息 + 异常堆栈封装成新消息，转发到指定的 error.exchange。这样：
- 消息脱离原队列，不再受 Unacked 状态影响
- 你可以独立消费 error 队列，做人工干预、延迟重试或归档
- 避免因单条消息反复失败导致整条通道阻塞
配置示例（Java Config）：
@Bean
public MessageRecoverer messageRecoverer(RabbitTemplate rabbitTemplate) {
return new RepublishMessageRecoverer(rabbitTemplate, "error.exchange", "error.routing.key");
}
这个 recoverer 不处理宕机本身，但它让“宕机后遗留的消息”在下次成功启动的消费者里被 try/catch 到时，有明确出口——这才是生产环境真正可控的回收路径。
别忽略：队列声明时的 x-expires 和惰性队列
如果消息确实长期无人消费（比如消费者代码有 bug 卡住 ACK），仅靠重入队不够。这时需要两层防御：
- 给队列加
x-expires（如 7200000 = 2h）：空队列自动销毁，释放内存 - 启用惰性队列（
x-queue-mode: lazy）：消息直接落盘，避免宕机时内存中 Unacked 消息丢失 - 配合
x-message-ttl：单条消息最长存活时间，超时进死信队列，不堆积
这些参数必须在队列首次声明时设定，后续修改无效。Spring Boot 中通过 @Bean Queue 显式声明最稳妥，别依赖自动声明。
