RocketMQ事务性消息是一定能保证消息发送成功的
事务消息发送步骤:
(1)发送方将半事务消息发送至RocketMQ服务端。
(2)RocketMQ服务端将消息持久化之后,向发送方返回ack确认消息已经发送成功。由于消息为半事务消息,在未收到生产者对该消息的二次确认前,此消息被标记成“暂不能投递”状态。
(3)发送方开始执行本地事务逻辑。
(4)发送方根据本地事务执行结果向服务端提交二次确认(Commit 或是 Rollback),服务端收到Commit 状态则将半事务消息标记为可投递,订阅方最终将收到该消息;服务端收到 Rollback 状态则删除半事务消息,订阅方将不会接受该消息。
事务消息回查步骤:
(1)在断网或者是应用重启的特殊情况下,上述步骤4提交的二次确认最终未到达服务端,经过固定时间后服务端将对该消息发起消息回查。
(2)发送方收到消息回查后,需要检查对应消息的本地事务执行的最终结果。
(3) 发送方根据检查得到的本地事务的最终状态再次提交二次确认,服务端仍按照步骤4对半事务消息进行操作。