mq解决分布式事务 如何使用消息队列解决分布式事务?
如何使用消息队列解决分布式事务?
有两种选择。
Scheme 1 Local message transaction table
生产者需要添加一个事务消息表。具体步骤如下:[1。生产者执行业务逻辑并将事务记录插入到消息表中。这两个操作在一个本地事务中
2。启动后台线程定期轮询消息表并将消息发送到消息队列
3。删除消息表中的消息,直到发送成功。
方案2需要消息队列支持,业务端提供回溯接口
1。生产端将准备好的消息发送到消息队列
2。在本地事务中,业务逻辑
3。根据执行结果确认或取消准备好的消息
4。消息队列将确保准备好的消息被确认或取消,并且消息队列将不断地向生产端请求执行结果,这要求生产端提供类似的回调函数。
在方案2中,消息队列取代了方案1中的消息表和后台线程轮询功能,但并非所有消息队列都支持此功能。支持Rocketmq。
方案1的开发工作量大,外部依赖性小
方案2的开发工作量小,但依赖于特定的消息队列。
传统事务为什么解决不了分布式事务?
其根本原因是传统事务只能解决单个事务资源的问题,而分布式事务则考虑了多个事务资源的问题。这两种场景是不同的,传统的事务无法解决分布式事务的问题。
1. 传统的事务通常指数据库事务,事务资源的强一致性保证了事务的一致性。在传统的单一应用中,由于事务资源在同一个应用中,无法跨多个事务资源调用,因此可以高效工作;
,只需要保证数据的“最终一致性”,但最终时间需要在用户可接受的范围内;但在金融关联交易领域,仍然需要采用强一致性的方法来保证交易的准确性和可靠性。
3. 目前,分布式事务常用的解决方案有:两阶段提交、三阶段提交、sagas长事务、补偿模式、可靠事件模式(本地事件表、外部事件表)、可靠事件模式(非事务消息、事务消息),TCC等
不同实现的优缺点如下图所示:
科普知识@大象聊天技术
版权声明:本文内容由互联网用户自发贡献,本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。