利用事务消息实现分布式事务的消息队列方案

简介：
本方案探讨了通过采用事务消息机制来构建有效的分布式系统事务解决方案，重点介绍了如何应用消息队列技术保障数据的一致性和可靠性。 在“发消息”的过程中，通常是为了通知另一个系统更新数据。MQ的事务主要解决的是消息生产者与消费者之间的数据一致性问题。 例如，在电商APP中购物时，用户首先将商品添加到购物车，然后一起下单，并最终完成支付流程以等待收货。在这个过程中需要用到MQ的一个环节是：订单系统创建订单后会发送一条消息给购物车模块，通知其删除已下单的商品。 从技术角度来看，从购物车中移除已经成功下单的商品并不是用户主要的购物流程中的必要步骤；因此使用MQ进行异步清理更为合理和高效。具体来说，在订单模块创建新订单时实际上执行了两个操作：在订单数据库（DB）里插入一条新的订单记录，并发送一个包含该新订单详情的消息到消息队列（MQ）。接下来，购物车模块会订阅相应的主题并接收到来自MQ的关于新创建订单的通知信息。收到通知后，它将从用户的购物车内移除已下单的商品。 通过这种方式可以保证系统的高可用性和灵活性，同时确保数据的一致性与完整性。