rocketmq 事务消息实现
时间: 2023-09-14 21:10:41 浏览: 57
RocketMQ的事务消息实现主要分为两个阶段:正常事务的发送及提交和事务信息的补偿流程。在正常事务的发送及提交阶段,事务消息的发送是在本地事务提交之前进行的。如果在发送事务消息之后发生异常,导致本地事务未能成功提交,那么事务消息也会被回滚。在事务信息的补偿流程中,RocketMQ会定期扫描未收到确认消息的Prepared消息,并执行事务回查的逻辑,主动去消息生产方确认事务状态。\[1\]
为了实现RocketMQ的事务消息,需要使用RocketMQ事务专属的TransactionMQProducer,并设置一个事务监听器(TransactionListener)。在事务监听器中,需要实现接口方法,以等待本地事务的执行情况。此外,由于监听器需要等待本地事务的执行情况,所以在生产者发送完消息后不能立即关闭。\[3\]
综上所述,RocketMQ的事务消息实现包括正常事务的发送及提交阶段和事务信息的补偿流程,需要使用TransactionMQProducer和设置事务监听器,以保证本地事务和事务消息的一致性。\[1\]\[3\]
#### 引用[.reference_title]
- *1* *2* *3* [RocketMQ事务消息](https://blog.csdn.net/qq_42877546/article/details/125404307)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^control_2,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]
相关推荐
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![-](https://csdnimg.cn/download_wenku/file_type_column_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)