rocketmq 事务消息
时间: 2023-08-22 18:10:42 浏览: 101
spingboot-rocketmq事务消息
RocketMQ事务消息是一种支持分布式事务的消息模式。在传统的消息队列中,消息发送方发送消息到消息队列,而消息接收方从消息队列中接收消息。而在事务消息中,消息发送方除了发送消息外,还需要执行本地事务。发送方首先将消息发送到消息队列,在本地事务执行成功后,再通知消息队列提交该消息,否则通知消息队列回滚该消息。
RocketMQ事务消息的实现关键在于两个阶段的确认:预备确认和提交确认。在预备确认阶段,发送方将消息发送到消息队列,并执行本地事务。如果本地事务执行成功,则向消息队列发送确认信息,否则发送回滚信息。在提交确认阶段,消息队列根据收到的确认信息进行提交或回滚操作。
事务消息的使用场景包括分布式事务、订单支付等需要保证事务一致性的业务场景。通过使用事务消息,可以确保消息的可靠传输和事务的一致性。
需要注意的是,事务消息需要在RocketMQ服务端配置开启事务消息功能,并在业务代码中编写本地事务执行逻辑和确认逻辑。
阅读全文