分布式事务 | RocketMQ事务消息方案

分布式事务 | RocketMQ事务消息方案

        当一个请求进来，先到事务发起方，同时有另一个服务，即事务消费方，现在需要在这两个服务之间要保证数据的一致性，比如说他想发送一个half message，发送到RocketMQ给他一个回应，表示发送half message成功。Half message当前这个状态的消息，在事务消费方是消费不到这个消息的，因为它是一个half message，这是RocketMQ事务消息的一个概念，只要是half message，事务消费方消费不到。

        而事务发起方知道他们已经发过去了，发送成功之后，执行本地事务，待执行完之后，如果本地事务执行不出错，那么进行消息提交，当消息提交之后，消费方就可以进行消息消费了，这样就保证了本地业务执行和消息发送是原子性的。当任务执行完了，消息发出去了，事务消费方把消息消费之后，执行其业务逻辑。这样其实就是保通过，整体的原子性通过割裂的原子性来保证。

        需要注意的是发送完half message之后，执行完本地事务，但是发送提交和回滚时，发送指令在路上丢了，RocketMQ中的halfmessage是不是就不知道该怎么办了，总不能一直等着吧？ 所以这里有一个回查机制，未收到第四步的命令时进行回查事务。

        本地事务如果执行完，则把消息确认一下，如果没执行完，则把它回滚，这样就不让他一直在这里卡着。这里有一个小技巧，怎么能通过查询事务发起方，确定事务执行完了呢？比如，可能事务发起方执行10个SQL，怎么能通过查询，难道把10个SQL都检查一遍？

        执行业务有10个SQL业务，其中在事件表中有一个SQL执行，我只查事件表不就好了吗？因为这10个SQL和这1个SQL都是在同一个服务里，他们之间可以通过原子性来保证，所以只需查他。如果他有，则说明执行成功了；如果没有，或者说正在执行未变更，就知道他出错了。这样就把整体的事务原子性切割成小的原子性。