网站域名注册费用优化网站收费标准

前言

基于消息补偿的最终一致性方案是一种分布式事务的实现方式，又包括本地消息表、消息队列两种方式。

一、本地消息表

核心思想是将分布式事务拆分成本地事务进行处理，本地消息表实现最终一致性。

• 步骤1和2，系统收到用户下单请求，将订单业务数据写入订单表中，同时把该订单对应的消息数据写入本地消息表中，订单表与本地消息表为同一个数据库，更新订单和存储消息为同一个本地事务，数据库事务处理，要么都成功，要么都失败。
• 步骤345，订单服务发送消息到消息队列，库存服务收到消息，进行库存业务操作，更新库存数据
• 步骤6和7，返回业务处理结果，订单服务收到结果后，将本地消息表中的数据设置完成状态或者删除数据。
• 步骤8，另起定时任务，定时扫描本地消息表，看是否有未完成的任务，有则重试。

优缺点

• 实现简单，开发成本低
• 订单表与本地消息表为同一个数据库

二、支持事务的消息队列

RMQ支持事务消息，与常见的数据库事务流程类似，生产者生产一条事务消息，等生产者本地操作ok了，会向MQ Server发送提交确认。

在这种情况下，事务消息初始被扔到消息队列中是没办法消费的，只有当该事务消息被提交了，这个消息才能被消费者所消费。

同理，如果rollback了，RMQ会从消息队列中把该消息删掉。

1. 生产者生产消息给MQ，此时未提交，称该消息为HalfMsg，即半消息
2. MQ受到该消息，会给生产者一个OK确认
3. 生产者执行本地事务
4. 根据本地事务执行的结果向MQ提交commit或者rollback，MQ根据commit或者rollback对消息进行相应操作，即消费或者丢弃
5. 如果生产者提交commit或者rollback提交超时，即第四步没有收到来自生产者的请求，MQ回调检查该消息
6. MQ回调检查本地事务的状态

参考

https://www.jianshu.com/p/e31d9ebed201