rabbitmq生产者消息确认

Love The Way You Lie 2024-02-19 18:45 9阅读 0赞

在使用 RabbitMQ 的时候，有时候当我们生产者发送一条消息到 RabbitMQ 服务器后，我们 **生产者想知道消息是否到达了 RabbitMQ 服务器上。这个时候我们应该如何处理**？

**针对上述问题，RabbitMQ 提供了2中解决方案。**

*  通过事务机制实现（**不推荐**）
 *  通过发送方确认（publisher confirm）机制实现（**推荐**）
 *  **注意：**
 *  1、上方2中方式不可共存，只能选取一种，如果一个channel上开启事务又开启confirm则会报错。
 *  2、如果发送消息的交换器没有匹配的队列，那么消息也会丢失。

### 通过事务机制实现 ###

RabbitMQ 客户端中与事务机制相关的方法共有三个。

**channel.txSelect()：** 用于将当前 channel 设置成事务模式

**channel.txCommit()：**  用于提交事务 （**事务提交成功，说明消息一定到达了RabbitMQ服务器中**）

**channel.txRollback()：**用于回滚事务

**java 生产者 事务 实现的代码如下：**  
**![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEzMC84NjAwLzIxNGM5MzA5LTU4YjgtMzE3Ni05M2RhLWMwZTY5NTViMjgwMi5wbmc][]  
注意：事务机制到发送一条消息之后会使发送端阻塞，在RabbitMQ服务端回应之后，才能继续发送下一条消息，在高并发的情况下可能性能不怎么好，因此不建议使用。**

### 发送方确认机制（Comfirm Listener） ###

消息的确认机制有好几种，此处介绍效率最高的异步确认机制。

**异步确认机制：**

1、使用 channel.confirmSelect() 将channel设置成 confirm 模式

2、使用 channel.addConfirmListener 监控消息是否到达RabbitmqMQ

**监听器中的 deliverTag 和multiple 参数见下方图中解释。**

生产者将channel设置成confirm 模式后，在此channel上发布的消息都会被分派一个唯一的ID(从1开始)，当消息不exchange路由到所匹配的队列后，如果消息是持久化的，那么在消息持久化后，RabbitMQ 就会发送一个确认（Basic.Ack）给生产者（包含消息的唯一ID）,这样生产者就知道消息正确到达RabbitMQ了。

**java 生产者 异步确认 实现的代码如下：**  
![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEzMC84NjAyL2M1MjZhYzkyLTljYjgtM2NjOS1iNWM0LTM2YjI2M2ZkYWE4OC5wbmc][]

### 完整代码： ###

**事务确认：**[https://gitee.com/huan1993/rabbitmq/tree/master/rabbitmq-advance/src/main/java/com/huan/rabbitmq/advance/produceconfirm/tx][https_gitee.com_huan1993_rabbitmq_tree_master_rabbitmq-advance_src_main_java_com_huan_rabbitmq_advance_produceconfirm_tx]

**confrirm异步确认：**[https://gitee.com/huan1993/rabbitmq/tree/master/rabbitmq-advance/src/main/java/com/huan/rabbitmq/advance/produceconfirm/confirmlistener][https_gitee.com_huan1993_rabbitmq_tree_master_rabbitmq-advance_src_main_java_com_huan_rabbitmq_advance_produceconfirm_confirmlistener]

[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEzMC84NjAwLzIxNGM5MzA5LTU4YjgtMzE3Ni05M2RhLWMwZTY5NTViMjgwMi5wbmc]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/bd76bf9fe6fc4a3d95aab5017ae1e4c1.png
[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEzMC84NjAyL2M1MjZhYzkyLTljYjgtM2NjOS1iNWM0LTM2YjI2M2ZkYWE4OC5wbmc]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/80d1aa1be24643e38e6888e12eaf0560.png
[https_gitee.com_huan1993_rabbitmq_tree_master_rabbitmq-advance_src_main_java_com_huan_rabbitmq_advance_produceconfirm_tx]: https://gitee.com/huan1993/rabbitmq/tree/master/rabbitmq-advance/src/main/java/com/huan/rabbitmq/advance/produceconfirm/tx
[https_gitee.com_huan1993_rabbitmq_tree_master_rabbitmq-advance_src_main_java_com_huan_rabbitmq_advance_produceconfirm_confirmlistener]: https://gitee.com/huan1993/rabbitmq/tree/master/rabbitmq-advance/src/main/java/com/huan/rabbitmq/advance/produceconfirm/confirmlistener