首页 > 新闻资讯

rabbitmq消息队列5种模式 如何设计一个MQ消息队列?

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

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

2。首先定义消息协议,如activemq、stomp、xmpp等

3。定义消息协议,定义消息队列需要满足的场景

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

rabbitmq消息队列5种模式 如何设计一个MQ消息队列?

是否要支持同步和异步消息

是否要保证消息队列例如rocketmq是高可靠性,卡夫卡是高吞吐量,但不高可靠性。

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

有两种选择。

scheme1localmessagetransactiontable

生产者需要添加一个事务消息表。具体步骤如下:[1。生产者执行业务逻辑并将事务记录插入到消息表中。这两个操作在一个本地事务中

2。启动后台线程定期轮询消息表并将消息发送到消息队列

3。删除消息表中的消息,直到发送成功。

方案2需要消息队列支持,业务端提供回溯接口

1。生产端将准备好的消息发送到消息队列

2。在本地事务中,业务逻辑

3。根据执行结果确认或取消准备好的消息

4。消息队列将确保准备好的消息被确认或取消,并且消息队列将不断地向生产端请求执行结果,这要求生产端提供类似的回调函数。

在方案2中,消息队列取代了方案1中的消息表和后台线程轮询功能,但并非所有消息队列都支持此功能。支持rocketmq。

方案1的开发工作量大,外部依赖性小

方案2的开发工作量小,但依赖于特定的消息队列。

rabbitmq消息队列5种模式javamq消息队列详解进程消息队列

原文标题:rabbitmq消息队列5种模式 如何设计一个MQ消息队列?,如若转载,请注明出处:https://www.saibowen.com/news/22681.html
免责声明:此资讯系转载自合作媒体或互联网其它网站,「赛伯温」登载此文出于传递更多信息之目的,并不意味着赞同其观点或证实其描述,文章内容仅供参考。