分布式架构 如何使用消息队列解决分布式事务？
如何使用消息队列解决分布式事务？
有两种选择。
Scheme 1 Local message transaction table
生产者需要添加一个事务消息表。具体步骤如下：[1。生产者执行业务逻辑并将事务记录插入到消息表中。这两个操作在一个本地事务中
2。启动后台线程定期轮询消息表并将消息发送到消息队列
3。删除消息表中的消息，直到发送成功。
方案2需要消息队列支持，业务端提供回溯接口
1。生产端将准备好的消息发送到消息队列
2。在本地事务中，业务逻辑
3。根据执行结果确认或取消准备好的消息
4。消息队列将确保准备好的消息被确认或取消，并且消息队列将不断地向生产端请求执行结果，这要求生产端提供类似的回调函数。
在方案2中，消息队列取代了方案1中的消息表和后台线程轮询功能，但并非所有消息队列都支持此功能。支持Rocketmq。
方案1的开发工作量大，外部依赖性小
方案2的开发工作量小，但依赖于特定的消息队列。
何时使用分布式消息队列？
据我所知，消息队列目前有几种用途。
1. 消除峰值并控制流量
例如，在这种情况下，今天标题中的百万个答案需要在完成后写入数据库。虽然你的MySQL只允许你以每秒300的速度写，但是消息队列是一个很好的方法。离线计算
日志分析，图像处理，这些都属于这类应用。
例如，您希望能够根据网站的日志进行监视。此时，在不影响web服务的情况下，可以通过消息队列定期发送日志流
3。解耦
想象一个用户上传图片的服务。用户只想上传到空间，但需要添加水印。如果同时添加水印和用户记录，速度会非常慢。因此，通常的方法是web服务接受图像并通过消息队列将其转发给水印服务。web服务本身不会阻止。
您所说的分布式队列只是为了适应高吞吐量消息队列的优化实现。
golang有什么比较好得分布式任务队列，类似Python的celery？
机械是基于分布式消息传递的异步任务队列/作业队列。
版权声明：本文内容由互联网用户自发贡献，本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。
