基于RabbitMQ消息队列的分布式事务解决方案(上)

1 RabbitMQ

一款分布式消息中间件，基于erlang开发， 具备语言级别的高并发处理能力。和Spring框架是同一家公司。支持持久化、高可用。

核心概念

1. Queue: 真正存储数据的地方
2. Exchange: 接收请求，转存数据
3. Bind: 收到请求后存储到哪里
4. 消息生产者:发送数据的应用
5. 消息消费者: 取出数据处理的应用

2 分布式事务问题

分布式事务是一个业务问题，不能脱离具体场景。

• 美团点评系统架构

多系统间的分布式事务问题

用户下单生成订单

需要传递订单数据，由此产生两个事务一致性问题

错误案例

当接口调用失败时

订单系统事务回滚，提示用户操作失败。

自以为这样的接口调用写法，就不会有分布式事务问题。

接口调用成功或失败

都会产生分布式事务问题：

• 接口调用成功

  订单系统数据库事务提交失败，运单系统没有回滚，产生数据

• 接口调用超时

  订单系统数据库事务回滚，运单系统接口继续执行，产生数据

所以都会导致数据不一致问题。

3 正确实现分布式事务（五步法）

• 之前都是订单系统直接HTTP请求运单系统的接口，出问题了!

• 

• 因此考虑发消息给MQ，异步暂存

3.1 整体设计思路

外卖下订单后，慢慢等待运单中心数据生成，并非强制要求同时。但要保证：

• 可靠生产

  保证消息一定要发送到Rabitmq服务

• 可靠消费

  保证消息取出来一定正确消费掉

• 最终使多方数据达到一致。