2016 - 2024

感恩一路有你

分布式服务器架构 如何使用消息队列解决分布式事务?

浏览量:2403 时间:2021-03-12 05:35:16 作者:admin

如何使用消息队列解决分布式事务?

有两种选择。

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服务本身不会阻止。

您所说的分布式队列只是为了适应高吞吐量消息队列的优化实现。

如何设计一个MQ消息队列?

1. 在上图中定义消息发送和消耗的过程

2。为消息定义消息协议,如ActiveMQ、stomp、XMPP等。定义消息协议,定义消息队列需要满足的场景

是否要保证消息的可靠性,必要时要保证存储的高可用性

是否支持同步和异步消息

是否要保证消息的顺序

是否需要延迟消息要支持

很多开源的实现功能可以参考详细信息。例如,rocketmq是高度可靠的,Kafka是高吞吐量的,但不是高度可靠的。

本人本科大二,随手可以写java网课上的仓储系统(无法联网,图形化界面,sql),在业内算什么水平呢?

我做软件已经20多年了。编程不仅是关于使用什么语言,而且是关于思考。编程语言只是一种工具。如果你熟悉一个工具,那就没什么值得骄傲的了,除非你想把编程和诗人比较一下。一个软件要实现哪些功能,这些功能用户如何使用才能酷、易用、稳定如新是最重要的。否则,就是半衰期,在这个领域没有太大前途

分布式服务器架构 分布式架构 什么是分布式

版权声明:本文内容由互联网用户自发贡献,本站不承担相关法律责任.如有侵权/违法内容,本站将立刻删除。