消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?

大家好,又见面了,我是全栈君。

消息队列(MQ)

在百度百科中,消息队列(MQ)是这么解释的:“消息队列”是在消息的传输过程中保存消息的容器(可存可取)。

它是分布式系统中重要的组件,使用消息队列主要是为了通过异步处理提高系统性能和削峰和降低系统耦合性。

异步处理:多应用对消息队列中同一消息进行处理,应用间并发处理消息,相比较串行处理,减少处理时间;

应用耦合:多应用通过消息队列对同一消息进行处理,避免调用接口失败导致整个过程失败;

限流消峰:广泛应用于秒查或抢购活动中,避免某一刻流量过导致应用系统挂掉的情况;

目前使用较多的消息队列有 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 等。

消息队列的两种模式
消息队列包括两种模式:点对点模式 和 发布/订阅模式。
1)点对点模式
点对点模式下包括三个角色:640?wx_fmt=png

消息队列

发送者 (生产者)

接收者(消费者)

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]

消息发送者生产消息发送到queue中,然后消息接收者从queue中取出并且消费消息。消息被消费以后,queue中不再有存储,所以消息接收者不可能消费到已经被消费的消息。

点对点模式特点:

每个消息只有一个接收者(Consumer)(即一旦被消费,消息就不再在消息队列中);

发送者和接收者间没有依赖性,发送者发送消息之后,不管有没有接收者在运行,都不会影响到发送者下次发送消息;

接收者在成功接收消息之后需向队列应答成功,以便消息队列删除当前接收的消息;

2)发布/订阅模式
发布/订阅模式下包括三个角色:

角色主题(Topic)

发布者(Publisher)

订阅者(Subscriber)

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]

发布者将消息发送到Topic,系统将这些消息传递给多个订阅者。

发布/订阅模式特点:

每个消息可以有多个订阅者;

发布者和订阅者之间有时间上的依赖性。针对某个主题(Topic)的订阅者,它必须创建一个订阅者之后,才能消费发布者的消息。

为了消费消息,订阅者需要提前订阅该角色主题,并保持在线运行;

异步处理

具体场景:用户为了使用某个应用,进行注册,系统需要发送注册邮件和注册短信。

对于该流程有两种处理方式:并行和串行。

1)串行处理:写入注册信息后,先发送注册邮件,再发送注册短信。

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]

这种方式下,需要等发送短信处理完成后才完成注册。

2)并行处理:写入注册信息后,同时处理发邮件和发短信。

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]

这种方式下,需要等发送短信和发送邮件处理完成后才完成注册。

假设上面三个子系统处理耗时均为:50ms,且不考虑网络延迟,系统卡顿等因素,则总的处理时间为:
串行:50ms + 50ms + 50 ms = 150ms
并行:50ms + 50ms = 100ms
使用消息队列结果将如何呢?

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]

若使用消息队列,写入完注册信息后,再将信息写入消息队列就能直接返回成功给客户端了,然后注册完成。
现在总的响应时间依赖于写入消息队列的时间,而写入消息队列的时间是很快的,基本可以忽略不计。因此总的处理时间相比串行提高了 2 倍,相比并行提高了 1 倍。
应用解耦
具体场景:A 系统每次产生数据时,都要将数据发给 BC 两个系统(通过接口调用)。这个时候新增了一个 D 系统,如下图:

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]
在这个场景中,A 系统和其他几个系统乱七八糟的耦合在一起,当 A 系统中产生一条数据时,需要将数据发给各个系统。
每次项目中新增了系统,A 系统都需要修改代码,还要时刻担心那个系统挂掉了,信息没发送过去要不要重发,那个系统又不要该数据了,这时求 A 系统负责人的心理阴影…
如果使用 MQ,A 系统产生一条数据后,只需要插入到 MQ 里面去,那个系统需要就去 MQ 里消费。如果新增了一个系统,那么订阅 MQ 的消息即可;同理那个系统不再需要该数据,那么只要取消订阅就行了。

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]
通过一个 MQ, Pub/Sub 发布订阅消息模型,A 系统就跟其他系统实现解耦了。
限流削峰
具体场景:某电商网站开展秒杀活动,一般由于瞬间访问暴增,服务器收到请求过大,可能出现无法处理请求或崩溃的情况。

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]
加入消息队列后,系统就可以从消息队列中读取数据,相当于做了一次缓冲,超出系统处理之外的请求会积压在消息队列中,等高峰期已过,就会快速将积压在队列中的数据处理完。
消息队列有什么优缺点
优点上面已经说了,就是在特殊场景下有其对应的好处,解耦、异步、削峰。
缺点有以下几个:
系统可用性降低
系统引入的外部依赖越多,越容易挂掉。本来你就是 A 系统调用 BCD 三个系统的接口就好了,人 ABCD 四个系统好好的,没啥问题,你偏加个 MQ 进来,万一 MQ 挂了咋整,MQ 一挂,整套系统崩溃的,你不就完了?如何保证消息队列的高可用,可以点击这里查看。
系统复杂度提高
硬生生加个 MQ 进来,你怎么保证消息没有重复消费?怎么处理消息丢失的情况?怎么保证消息传递的顺序性?头大头大,问题一大堆,痛苦不已。
一致性问题
A 系统处理完了直接返回成功了,人都以为你这个请求就成功了;但是问题是,要是 BCD 三个系统那里,BD 两个系统写库成功了,结果 C 系统写库失败了,咋整?你这数据就不一致了。
所以消息队列实际是一种非常复杂的架构,你引入它有很多好处,但是也得针对它带来的坏处做各种额外的技术方案和架构来规避掉,做好之后,系统复杂度提升了一个数量级,也许是复杂了 10 倍。但是关键时刻,用,还是得用的。
RabbitMQ/ActiveMQ/RocketMQ/Kafka对比
这里列举了上述四种消息队列的差异对比(图片来源:https://www.cnblogs.com/javalyy/p/8856731.html):

消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]

图片来源(https://doocs.gitee.io/advanced-java/#/docs/high-concurrency/why-mq)消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择?[通俗易懂]640?wx_fmt=png

总结
一般业务系统要引入 MQ,最早大家都是用 ActiveMQ,但是现在大家用的不多了,没经过大规模吞吐量场景的验证,社区也不是很活跃,不推荐使用。
中小型公司,技术实力较为一般,技术挑战不是特别高,用 RabbitMQ 是不错的选择,大型公司,基础架构研发实力较强,用 RocketMQ 是很好的选择。
如果是高性能分布式、大数据领域的实时计算、日志采集等场景,用 Kafka 是业内标准。
广泛来说,电商、金融等对事务性要求很高的,可以考虑RabbitMQ和RocketMQ,对性能要求高的可考虑Kafka
 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/111953.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • ldd 命令介绍_ldr指令是什么意思

    ldd 命令介绍_ldr指令是什么意思1.在制作自己的发行版时经常需要判断某条命令需要哪些共享库文件的支持,以确保指定的命令在独立的系统内可以可靠的运行;在Linux环境下通过ldd命令即可实现,在终端下执行:ldd/bin/ls//ldd命令通常使用”-v”或”–verbose”选项来显示所依赖的动态连接库的尽可能的详细信息。即可得到/bin/ls命令的相关共享库文件列表:libtermcap.so.2=>/lib/lib

  • l1正则化为什么稀疏(特征值重根与秩的关系)

    L1正则化与稀疏性L1正则化使得模型参数具有稀疏性的原理是什么?机器学习经典之作《patternrecognitionandmachinelearning》中的第三章作出的一个解释无疑是权威且直观的,我们也经常都是从这个角度出发,来解释L1正则化使得模型参数具有稀疏性的原理。再回顾一下,以二维为例,红色和黄色的部分是L1、L2正则项约束后的解空间,蓝色的等高线是凸优化问题中的目标函数(…

  • js中跳转_js跳转页面传递参数

    js中跳转_js跳转页面传递参数JS页面跳转大全所谓的js页面跳转就是利用javesrcipt对打开的页面ULR进行跳转,如我们打开的是A页面,通过javsrcipt脚本就会跳转到B页面。一、常规的JS页面跳转代码1、在原来的窗体中直接跳转用  window.location.href=”你所要跳转的页面”;  2、在新窗体中打开页面用:  window.open(‘你所要跳转的页面’);

  • adb命令 利用jks文件给apk签名[通俗易懂]

    adb命令 利用jks文件给apk签名[通俗易懂]程序猿日常实践是检验真理的唯一标准。jarsigner-verbose-keystorexxx.jks-signedjarxxx.apk(签名后的apk名字)xxx.apk(需要签名的apk)xxx(keystore别名)

  • 电脑蓝屏报错0x00000006怎么办?蓝屏报错0x00000006解决方法

    电脑蓝屏报错0x00000006怎么办?蓝屏报错0x00000006解决方法1.首先进入系统,按键盘上的win+r组合键打开“运行”窗口,在运行框中输入msconfig并回车。2.在“系统配置”窗口中,将“加载启动项”选项前的勾去除。3.切换到服务栏界面,勾选“隐藏所有Microsoft服务”,然后点击“全部禁用”。4.接着切换到“启动”栏界面中,点击“全部禁用”,然后点击确定即可。…

  • C#桌面文案小工具 ,详细带解说图(带源码)

    C#桌面文案小工具 ,详细带解说图(带源码)新手!新手!新手!有什么不对的地方可以交流交流最近无聊,写了一个小工具,每隔一段时间随机刷新一下文案,并且还可以连接数据库思路:1窗体的隐藏:在属性上面把BackCoor和TransprencyKey设置成一样的就可以隐藏窗口了2日期时间的刷新:在窗体上创建一个label标签,这个没什么好说,直接获取时间然后创建一个计时器一直刷新他,频率设置成1—900都可以,代码记得写在计时器label2.Text=DateTime.Now.ToString();//20

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号