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