摘要:的作用就是订阅发布模式,从而让上下游系统的调用链解耦,即上游系统可以按自己的节奏生产,下游系统可以按自己的节奏消费,即削峰填谷,其他的都是扯淡。防重发由消息幂等性保证。
MQ的作用
就是订阅-发布模式,从而让上、下游系统的调用链解耦,即上游系统可以按自己的节奏生产,下游系统可以按自己的节奏消费,即削峰填谷,其他的都是扯淡。
即 producer - push - mq broker - pull - consumer
防丢失、防重发防丢失由MQ 的ack机制保证。
防重发由消息幂等性保证。
注意:
producer与mq broker之间的幂等性由mq broker内部 inner-msg-id 保证;mq broker 与consumer之间的幂等性要由用户自己实现,一般直接加个冗余消息字段,即业务消息id,consumer端判重。
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/70959.html
摘要:数量对吞吐量的影响可以达到几百几千个的级别,吞吐量会有小幅度的下降。这是的一大优势,可在同等数量机器下支撑大量的从几十个到几百个的时候,吞吐量会大幅下降。下一篇如何保证消息队列的高可用 1.为什么使用消息队列? (1)解耦:可以在多个系统之间进行解耦,将原本通过网络之间的调用的方式改为使用MQ进行消息的异步通讯,只要该操作不是需要同步的,就可以改为使用MQ进行不同系统之间的联系,这样项目之间...
摘要:在对事实性要求没有那么高的情况下,可以用基于最大努力交付消息队列以及消息存储来解决最终一致性。可靠消息服务和消息组件,协调上下游消息的传递,并确保上下游数据的一致性。下游应用通知可靠消息服务该消息已经成功消费。 本文对比 二阶段事务、最大努力交付以及消息最终一致性,并给出部分解决方案,最终一致性方案参考阿里RockMQ事务消息:http://blog.csdn.net/chunlong...
摘要:能不能支持数据丢失啊可以的,参考我们之前说的那个数据零丢失方案其实一个肯定是很复杂的,其实这是个开放题,就是看看你有没有从架构角度整体构思和设计的思维以及能力。其实回答这类问题,说白了,起码不求你看过那技术的源码,起码你大概知道那个技术的基本原理,核心组成部分,基本架构构成,然后参照一些开源的技术把一个系统设计出来的思路说一下就好 比如说这个消息队列系统,我们来从以下几个角度来考虑一下 (1...
阅读 4086·2023-04-26 01:48
阅读 3260·2021-10-13 09:40
阅读 1742·2021-09-26 09:55
阅读 3619·2021-08-12 13:23
阅读 1783·2021-07-25 21:37
阅读 3433·2019-08-30 15:53
阅读 1394·2019-08-29 14:16
阅读 1398·2019-08-29 12:59