应系统排查生产、broker、消费三端的持久化与确认机制：一、验证生产者publisher confirm/return是否启用并生效；二、检查broker端队列与消息是否均设为持久化；三、确认消费者是否手动ack且无异常吞没；四、通过消息id与时间戳交叉比对定位丢失环节。
☞☞☞AI 智能聊天, 问答助手, AI 智能搜索, 多模态理解力帮你轻松跨越从0到1的创作门槛☜☜☜
如果您尝试排查RabbitMQ消息丢失问题，但无法定位具体环节，则可能是由于未系统覆盖生产、Broker、消费三端的持久化与确认机制配置。以下是针对性的排查步骤：
一、验证生产者端消息是否成功抵达Broker
该步骤用于确认消息是否在发送途中丢失，核心在于启用并校验Publisher Confirm与Return机制的实际生效状态。
1、检查RabbitMQ客户端连接配置中是否启用confirm模式，例如Spring Boot中需设置spring.rabbitmq.publisher-confirm-type=correlated。
2、确认生产者代码中已注册RabbitTemplate.ConfirmCallback实现类，并在confirm()方法内正确处理ack=false分支。
3、启用publisher-returns并设置mandatory=true，同时注册RabbitTemplate.ReturnsCallback，捕获未路由消息的returnedMessage日志。
4、向交换器发送一条带明确routingKey的消息，观察回调日志中是否收到ack=true或returnedMessage非空输出。
5、若无任何回调触发，说明confirm/return机制未实际启用或信道未进入confirm模式，需检查客户端版本兼容性及配置加载顺序。
二、检查Broker端队列与消息是否持久化
该步骤用于排除Broker重启或崩溃导致消息从内存清空的问题，重点验证队列声明与消息投递两个层面的持久化设置。
1、使用rabbitmqctl list_queues name durable auto_delete命令，确认目标队列的durable字段值为true。
2、检查队列声明代码（如Spring AMQP中@Bean Queue queue()）是否显式传入new Queue("name", true)参数。
3、查看消息发布代码中是否调用MessageProperties.setDeliveryMode(MessageDeliveryMode.PERSISTENT)或等效设置deliveryMode=2。
4、在管理界面（http://localhost:15672）中进入目标队列详情页，核对Features列是否显示D（Durable）标识。
5、若队列或消息任一未持久化，Broker宕机后该队列中所有未消费消息将不可恢复。
通过 Perplexity API 进行深度搜索。提供三种模式：搜索（快速事实）、推理（复杂分析）、研究（深度报告）。返回基于 AI 且有据可依的答案。
三、审查消费者端ACK行为是否合规
该步骤用于识别因自动确认或异常提前确认导致的消息逻辑丢失，聚焦于消费逻辑与通道配置的一致性。
1、检查消费者容器工厂配置（如SimpleRabbitListenerContainerFactory）中setAcknowledgeMode(AcknowledgeMode.MANUAL)是否已启用。
2、确认消费方法签名包含Channel参数，并在业务处理成功后显式调用channel.basicAck(deliveryTag, false)。
3、验证消费方法内是否存在未捕获的异常导致basicAck未执行，或在try-catch中错误调用了basicNack且requeue=false。
4、通过管理界面查看目标队列的Ready与Unacked数值：若Unacked持续为0且无消费日志，极可能处于autoAck模式或ACK被静默吞掉。
5、临时在消费方法开头添加log.info("Received msg, deliveryTag={}", deliveryTag)，确认消息是否真正到达消费者线程。
四、交叉比对消息ID与日志时间戳
该步骤用于定位消息在哪个环节“消失”，通过唯一标识串联全链路日志，识别断点位置。
1、生产者发送消息前生成全局唯一ID（如UUID），并作为CorrelationData传入RabbitTemplate.convertAndSend()。
2、在ConfirmCallback中记录correlationData.getId()与ack结果，以及当前系统时间戳。
3、在消费者接收到消息后，解析消息头中的correlationId属性并记录时间戳。
4、在RabbitMQ管理界面的Messages标签页中，使用Get Message功能提取任意一条队列中现存消息的correlation_id字段。
5、若某ID在生产者日志中存在ack=true记录，但在消费者日志和队列中均未出现，说明消息在Broker内部路由阶段丢失，需检查交换器绑定与策略插件。
