一款分布式消息中间件,基于erlang开发, 具备语言级别的高并发处理能力。和Spring框架是同一家公司。支持持久化、高可用。
分布式事务是一个业务问题,不能脱离具体场景。
订单系统事务回滚,提示用户操作失败。 自以为这样的接口调用写法,就不会有分布式事务问题。
都会产生分布式事务问题:
所以都会导致数据不一致问题。
外卖下订单后,慢慢等待运单中心数据生成,并非强制要求同时。但要保证:
最终使多方数据达到一致。
为确保数据一定成功发送到MQ。在同一事务中,增加一个记录表的操作, 记录每一条发往MQ的数据以及它的发送状态
。
不再通过HTTP请求直接调用运单系统接口,而是使用MQ: 生成订单时,也保存本地信息表
于是还需要如下处理: ➢ 幂等性 防止重复消息数据的处理,一次用户操作,只对应一次数据处理
➢ 开启手动ACK模式
由消费者控制消息的重发/清除/丢弃
消费者处理失败,需要MQ重发给消费者。出现异常一般会重试几次,由消费者自身记录重试次数,并进行次数控制。
消费者处理失败,直接丢弃或者转移到死信队列(DLQ)。重试次数过多、消息内容格式错误等情况,通过线上预警机制通知运维
。
尽量避免分布式事务,尽量将非核心事务做成异步。
参考