RocketMQ的事务消息实现方法如下:
1、首先
生产者
订单系统先发送⼀条
half消息到Broker
,half消息对消费者而⾔是不可⻅的
2、再创建订单,根据创建订单成功与否,向Broker发送commit或rollback
3、并且⽣产者订单系统还可以提供Broker回调接口,当Broker发现⼀段时间half消息没有收到任
何操作命令,则会主动调此接口来查询订单是否创建成功
4、⼀旦half消息commit了,消费者库存系统就会来消费,如果消费成功,则消息销毁,分布式事
务成功结束
5、最后如果消费失败,则根据重试策略进⾏重试,最后还失败则进⼊死信队列,等待进⼀步处理


![[附源码]Nodejs计算机毕业设计基于web的家教管理系统Express(程序+LW)](https://img-blog.csdnimg.cn/7297cc7ca48a406d9bd19b5fcfc6d185.png)

![[附源码]Node.js计算机毕业设计电影票网上订票系统Express](https://img-blog.csdnimg.cn/6241bce620574d6e9a91f0a6a9887d74.png)









![[附源码]Nodejs计算机毕业设计基于web的火车订票管理系统Express(程序+LW)](https://img-blog.csdnimg.cn/0a0f283ce4734e99aa72064e46a5b86a.png)




