分步式事务

分布式事务场景: 不同系统,不同数据库

例如,外卖点单后提交,就有订单系统 和 配送系统。

分步式事务问题:

配送调度接口调用成功,但订单系统数据库事务提交失败

配送调度接口调用超时,但订单系统数据库事务回滚

分布式事情Base

Bese 模型反ACID,完全不同于ACID模型

核心思想: 无法做到强一致性,但是可以根据业务场景,保证最终一致性

例如: 可以先把订单数据存下来,然后再利用MQ 配置调度系统 实现分步式事务

Rabbit MQ 5个重要概念

生产者: 发步消息到MQ中

消费者: 消费队列中的消息

Exchange: 消息交换机制???可以把数据存储在一个Queue里,也可以配置在2个Queue里

Bind : 配置

问题:

1. 发送MQ失败怎么办?

建立一张MQ信息表存储MQ中发送的信息,MQ信息表和Order 表的存储放到一个事务中,

MQ发送成功之后,要更新MQ信息表中的状态。 如果发送失败?手工处理

2. 发送重复怎么办?

幂等性,依赖主键,例如在配送表,以订单表为主键,如果一个订单发送多次,自然是失败的

3. 接收者处理失败怎么办

接收者处理成功: 删除Queue中的信息

接收者处理失败: 不删除Queue中的信息,报警信息

相关推荐