Convertmessage IfNecessary

1.1 定义 持久化： 是为了提高 RabbitMQ 消息的可靠性，防止在异常情况（重启、宕机）下数据的丢失。 RabbitMQ 持久化分为三部分：交换机的持久化、队列的持久化、消息的持久化。 1.2 消息丢失的场景 出现消息丢失的场景有： 生产者发送消息丢失：发送消息到 RabbitMQ Server 异常。 可能因为网络问题造成 RabbitMQ 服务端无法收到消息。——解决方案：ConfirmCallback 生产者发送消息丢失：消息无法路由到指定队列。 可能由于代码层面或配置层面错误导致消息路由到指定队列失败。——解决方案：ReturnCallback RabbitMQ Server 存储消息丢失：消息未完全持久化到磁盘。 可能因为 RabbitMQ 宕机导致消息未完全持久化，或队列丢失从而导致消息丢失等持久化问题。——解决方案：集群部署，实现高可用 消费者消费消息丢失：消费者消费消息异常。 可能在消费者接收消息后，还没来得及消费消息，消费者就发生宕机、故障等问题。——解决方案：消费端手动确认消息 方式一：直接 new 直接实例化对应的 Exchange...