面试官:RocketMQ是什么,它有什么特性与使用场景?

2022年05月11日 阅读数:1
这篇文章主要向大家介绍面试官:RocketMQ是什么,它有什么特性与使用场景?,主要内容包括基础应用、实用技巧、原理机制等方面,希望对大家有所帮助。

哈喽!你们好,我是小奇,一位热爱分享的程序员
小奇打算以轻松幽默的对话方式来分享一些技术,若是你以为经过小奇的文章学到了东西,那就给小奇一个赞吧
文章持续更新程序员

1、前言

做为一名Java程序员,RocketMQ底层的一些原理是咱们没必要学会就能够搬砖工做的一种技能点,可是小奇为何还要讲一下呢?难道就是为了浪费你们1分钟的宝贵时间,一我的1分钟,50万人就是1年,5000万人就是100年,赚了,小奇以一己之力成功搞挂一我的(血赚)。面试

固然不是,而且小奇的文章也没有那么多人看,最多也就浪费个吧。数据库

学习RocketMQ底层原理是由于面试官要问啊!,因此咱们就要学,什么?不实用的你不学?那邻居小奇可要使劲学啦,到时候面试官只要小奇不要你。编程

在这里插入图片描述

至于你问为何面试官要问RocketMQ底层原理呢,这个。。。我把此次机会留给你,下次你面试的时候面试官问:“讲一下RocketMQ底层原理”。你:“面试官你好,请问为何你要问RocketMQ底层原理呢,你给我台电脑,我五分钟给你搭建好图书管理系统他不香吗,我们键盘上见真章”。这时面试官就会告诉你答案,你就能够把答案打在评论区,让小奇以及众多小伙伴一块儿知道一下到底为何要问?

微信

在这里插入图片描述

2、面试

在一个晴朗的周日,我来到了一个陌生的园区(别问为何是周日,问就是997,不过为了填饱肚子的打工人,只能明知山有虎、偏向虎山行),坐在陌生的会议室,等待HR小姐姐去叫面试官,此时个人心情和各位小伙伴同样五味杂陈,担忧面试官问的会不会很难?问到个人知识盲区我该怎么办?一会自我介绍的时候要不要吹一下我和小奇的关系?异步

一位英俊潇洒,眼神犀利的面试官走了进来,看到他那犀利、仿佛能看穿一切的眼神 ,我在想要否则一会就不要20k了,要8k得了,这个面试官一看就很差糊弄啊,可是我想起来我来以前刚看了小奇的趣学编程系列,我已经彻底学会了小奇的精髓,我顿时就来了底气,决定一会要30k,不给就学小奇赖着不走(哈哈)分布式

面试官:小奇是吧,带简历了吗?学习

我:没带,如今彩印两块一张,我简历五张,每次面试都要花费十块,我朋友说了还没工做就先让你掏钱的工做不要去。3d

面试官:。。。那你靠什么来征服我,让我录用你中间件

我:气质?

请添加图片描述

(此时面试官并无叫保安,而是从门后拿出了恭候我多时的棍子,我瞬间怂了)

在这里插入图片描述

我只好从个人双肩包中拿出了我上午从其余公司面试官手中要回的简历,上午的情形是这样的。


上午的面试官:今天的面试就到这吧,回去等通知吧!


我:面试官你好,若是贵公司不打算录取个人话,能不能把个人纸质简历还给我,我下午还有一家面试。


上午的面试官:我说你的简历怎么皱皱巴巴,原来你一直在循环利用啊!这个症状出现多久了?


我:半拉月了。。。


(当我把皱皱巴巴的简历交给面试官后,这场面试才得以继续进行。。。)

3、RocketMQ是什么

面试官:我看你简历上写的精通RocketMQ?(哼,面试官轻蔑的一笑)

我:原本不想写精通的,可是同行们抬爱,非逼着写,可是也无可厚非,虽然说没有到达炉火纯青,可是也差很少登峰造极了吧。

面试官:呵呵、那你先说一说RocketMQ是什么吧

我:RocketMQ是一个消息队列中间件,经过将消息放入队列中来实现解耦,削峰填谷等效果。

面试官:嗯,RocketMQ消息模型是什么样子的?

我:RocketMQ中主要有三部分组成,分别是消息生产端Producer、消息存储端Broker、和消息消费端Consumer。

在这里插入图片描述

面试官:嗯,RocketMQ有哪些消息发送模式呢?

一、基本模式
基本模式中咱们生产者能够经过三种不一样的方式发送消息,分别是同步发送、异步发送、单向发送,其中同步发送就是须要接收端响应接收到当前消息后才能再次发送消息,而单向发送是不须要等接收端响应接收到消息就能够再次发送的。
另外消费者消费消息也有两种模式,一种是消费者主动去Broker上拉取消息的拉模式,另外一种是消费者等待Broker把消息推过来的推模式。

二、顺序消息发送模式
顺序模式就是保证消息发送到Broker的顺序和消费者从Broker中消费的时候顺序是有序的,那么若是只有一个Broker的话确定是有序的,若是多个Broker就没法保证有序性,因此RocketMQ保证的是消息的局部有序,并不能保证全局有序。

在这里插入图片描述

三、广播消息发送模式
广播消息发送模式针对多个消费者来讲并非有一个消费者消费了消息,这个消息就没有了,而是每一个消费者都会消费到这一条消息。就像我用大喇叭在村里广播说张寡妇王光棍的事情,我只说了一遍,可是村里的人都听到了,这就是广播模式。
若是不用广播模式,那么我找到刘婶跟她说了张寡妇和王光棍的事情,那么也只有刘婶她一我的知道(固然,刘婶知道了后面全村最晚一晚上之间就全知道了)

在这里插入图片描述

四、延迟消息发送模式
延迟消息就是生产者发送消息后,消息并无被及时的发送出去,而是等过了一段时间才发出去。

好比我上面跟刘婶说了一个八卦,我让她不外传,那她确定作不到啊,我那只能要求她一个小时以内不容许外传,怎么也得给我预留一个小时让我逃跑啊

结果刘婶说一个小时她忍不住,最后协商她只能忍五分钟以内不说,那我也没什么好说的了,五分钟我能跑二里地了,总比没有时间强。

我还没来得及跑呢,就看到刘婶拦住了骑大梁自行车准备回家作饭的老林,老林从自行车上下来尽是期待的表情问:“刘婶呀,什么事啊,这么神秘”。只见刘婶看了一眼本身手上镀金的小腕表来了一句:“再等我四分半钟,我给你说一个秘密”

我完全服了,咱们村不愧是人才村,个个都是人才。。。

在这里插入图片描述

五、批量消息发送模式
批量消息发送的意思就是将多条消息合并成一个消息,一次发送出去。这样的好处就能够减小网路IO的次数,提高了效率。

好比以前我在村里说八卦的时候,我见了刘婶
我说:“哎呀刘婶呀,你可不知道”。
刘婶:“我确实不知道呀,你啥都没说呀”。
我说:“就我们村的张寡妇啊,可真行”。
刘婶:“张寡妇怎么了,哪里行,难道比我还。。。”。
我说:“还有咱村的王光棍,单身四十多年了,没想到还有这本事呢”。
刘婶:“啥本事啊,不是小奇你能一下说出来不,我快憋死了,快说到底啥事呀”。
我说:“就他俩在村东头苞米地里那啥”。
刘婶:“那啥呀”。
我说:“我先回去吃饭了啊,吃完饭我再回来跟你说剩下的”。
刘婶:“你这个兔崽子,你看我能让你吃饭吃安省不,吊个人胃口,你找死”。

明明能够一下说明白的事,我非要演上一部60集的电视连续剧,冯导听了都连连叫好啊。

六、过滤消息发送模式
在RocketMQ中咱们可使用Message的Tag属性来过滤信息,就是咱们指定这个信息哪一个消费者能够收到,那么它就能够收到,其余人收不到。

好比我发现村里的八卦了,我忍不住想让全村里的人知道,那我就在村里的微信群里发一下不就好了,可是张寡妇和王光棍也在微信群里呢,我这么一发他们不就知道是我说的嘛。

那我只好先将他们两个屏蔽了,而后把消息发出去,而后瞬间群里炸了锅,只有他两我的不知道发生了什么。

七、事务消息发送模式
事务消息是在分布式系统中保证最终一致性的两阶段提交的消息实现,他能够保证本地事务执行与消息发送两个操做的原子性。

这里保证的是生产者发送出去的消息与生产者本地存储的消息要一致,好比咱们购买商品下单,咱们来简单描述一下流程。

一、客户下单。
二、程序生成一条订单信息(这个时候尚未落库)
三、这个时候向快递服务发送了一条消息,让快递服务准备一下这条订单的货。
四、这个时候将生成的订单信息落到订单服务的数据库中

上面是一个正常的流程,可是若是订单信息落库的时候失败了呢。这个时候已经向快递服务发送了发快递的消息了,可是订单服务落库失败,没有这笔订单,那就是白白发了一个快递。回头对帐对不上,领导宰了你的心都有了。

这个时候咱们就须要进行一个事务的处理了,咱们能够进行一个两阶段提交来保证事务。

在这里插入图片描述

面试官:小伙子真厉害啊,我这边没有什么要问的了,你还有什么问题要问(面试官两眼放光)

我:额。。。面试官我如今能够走了吗,我一会还有一个面试呢。

面试官:还面啥别的公司啊,就来我这吧,条件随便开

我:那就100k吧(此时面试官又拿起了他准备好的棍子)

面试官:你要是不来就给我推荐一下,让别人来我这面试一下

我:你先好好学习一下RocketMQ吧,今天幸好只是我来了,若是是小奇的忠实读者来了,你将会被虐的很惨的。(我将个人博客地址留给了面试官,转身留下了帅气的背影,而面试官落寞无神的呆呆的坐在那里,仿佛一个亿离他而去。。。)

4、总结

这里关于RocketMQ尚未整理完毕,文章后面持续更新,建议收藏。

文章中涉及到的命令你们必定要像我同样每一个都敲几遍,只有在敲的过程当中才能发现本身对命令是否真正的掌握了。

若是以为个人文章还不错的话就点个赞吧