rocketmq原理面试题通常有哪些?

TheDisguiser 2020-07-05 15:39:16 java常见问答 6013

面试是每个程序员都要面对的一道门槛,这次小编整理了一些rocketmq原理的相关面试题,快来一起看看都有什么内容吧。

一、什么是RabbitMQ?

RabbitMQ是一款开源的,Erlang编写的,基于AMQP协议的,消息中间件;

二、RabbitMQ有什么优缺点?

优点:解耦、异步、削峰;

缺点:降低了系统的稳定性:本来系统运行好好的,现在你非要加入个消息队列进去,那消息队列挂了,你的系统不是呵呵了。因此,系统可用性会降低;

增加了系统的复杂性:加入了消息队列,要多考虑很多方面的问题,比如:一致性问题、如何保证消息不被重复消费、如何保证消息可靠性传输等。因此,需要考虑的东西更多,复杂性增大。

三、如何保证RabbitMQ的高可用?

没有哪个项目会只用一搭建一台RabbitMQ服务器提供服务,风险太大;

四、如何保证RabbitMQ不被重复消费?

先说为什么会重复消费:正常情况下,消费者在消费消息的时候,消费完毕后,会发送一个确认消息给消息队列,消息队列就知道该消息被消费了,就会将该消息从消息队列中删除;

但是因为网络传输等等故障,确认信息没有传送到消息队列,导致消息队列不知道自己已经消费过该消息了,再次将消息分发给其他的消费者。

针对以上问题,一个解决思路是:保证消息的唯一性,就算是多次传输,不要让消息的多次消费带来影响;保证消息等幂性;

比如:在写入消息队列的数据做唯一标示,消费消息时,根据唯一标识判断是否消费过;

五、如何保证RabbitMQ消息的可靠传输?

消息不可靠的情况可能是消息丢失,劫持等原因;

丢失又分为:生产者丢失消息、消息列表丢失消息、消费者丢失消息;

生产者丢失消息:从生产者弄丢数据这个角度来看,RabbitMQ提供transaction和confirm模式来确保生产者不丢消息;

transaction机制就是说:发送消息前,开启事务(channel.txSelect()),然后发送消息,如果发送过程中出现什么异常,事务就会回滚(channel.txRollback()),如果发送成功则提交事务(channel.txCommit())。然而,这种方式有个缺点:吞吐量下降;

confirm模式用的居多:一旦channel进入confirm模式,所有在该信道上发布的消息都将会被指派一个唯一的ID(从1开始),一旦消息被投递到所有匹配的队列之后;

rabbitMQ就会发送一个ACK给生产者(包含消息的唯一ID),这就使得生产者知道消息已经正确到达目的队列了;

如果rabbitMQ没能处理该消息,则会发送一个Nack消息给你,你可以进行重试操作。

消息队列丢数据:消息持久化。

处理消息队列丢数据的情况,一般是开启持久化磁盘的配置。

这个持久化配置可以和confirm机制配合使用,你可以在消息持久化磁盘后,再给生产者发送一个Ack信号。

这样,如果消息持久化磁盘之前,rabbitMQ阵亡了,那么生产者收不到Ack信号,生产者会自动重发。

那么如何持久化呢?

这里顺便说一下吧,其实也很容易,就下面两步

1. 将queue的持久化标识durable设置为true,则代表是一个持久的队列

2. 发送消息的时候将deliveryMode=2

这样设置以后,即使rabbitMQ挂了,重启后也能恢复数据

消费者丢失消息:消费者丢数据一般是因为采用了自动确认消息模式,改为手动确认消息即可!

消费者在收到消息之后,处理消息之前,会自动回复RabbitMQ已收到消息;

如果这时处理消息失败,就会丢失该消息;

解决方案:处理消息成功后,手动回复确认消息。

六、如何保证RabbitMQ消息的顺序性?

单线程消费保证消息的顺序性;对消息进行编号,消费者处理消息是根据编号处理消息;

七、MQ是用来干嘛的?有什么作用?

答:

MQ其实就是一种系统,独立部署,让系统之间通过发消息和收消息来进行异步的调用

作用:提升性能、系统解耦、流量消峰

提升性能:

一个请求调用了A、B两个系统,执行业务逻辑各需要20 、200毫秒,那么处理这个请求一共需要220毫秒

引入MQ后:发送消息给MQ的速度是很快的(没有业务逻辑、没有数据库操作),所以引入MQ后,20多毫秒就可以返回结果给用户了。

系统解耦:

系统A和系统B通过同步调用的模式耦合在了一起,一旦系统B出现故障,很可能会影响系统A也有故障

而且系统A还得去关心系统B的故障,去处理对应的异常,这是很麻烦的。

引入MQ后:B如果出现了故障,对系统A根本没影响,系统A也感觉不到,B自己处理自己的问题!

流量消峰:

如果高并发访问系统A(A没有数据库操作),A调用B(B有数据库操作),那么瓶颈在B,因为数据库操作是比较耗时的。

同样的机器配置下,如果数据库可以抗每秒6000请求,MQ至少可以抗每秒几万请求。因为数据库复杂,需要支持事务、复杂的SQL查询等

引入MQ后:A系统依赖支持高并发的MQ,B也依赖MQ,此时B可以用自己的合适的速度访问MQ,即B系统流量被消峰了。整个系统的性能由A决定,而不速度慢的B决定

八、说说MQ解决了系统中的哪些问题?

答:

1、支付订单流程中步骤过多,订单系统完成核心的步骤,发送消息到MQ,其他的服务从MQ获取消息,执行比较耗时的操作。

2、退款失败问题,订单支付系统完成公司系统内部业务的核心流程,发送消息到MQ,使用一个专门的系统区处理和第三方支付系统的交互。

3、大促时,大量下单请求放到MQ,订单系统以合适的速度消费消息,处理相关业务

九、你们MQ系统选型、技术调研怎么做的?

答:

初步考虑的因素:

业内常用的MQ有哪些?

每一种MQ各自的表现如何?

这些MQ在同等机器条件下,能抗多少QPS(每秒抗几千QPS还是几万QPS)?

性能有多高(发送一条消息给他要2ms还是20ms)?

可用性能不能得到保证(要是MQ部署的机器挂了怎么办)?

以上就是关于rocketmq原理的所有面试题,你了解了吗?如果还想了解更多面试题相关内容,可以来我们网站java面试宝典中查看详情。

推荐阅读:

rocketmq和kadka区别是什么?区别详细介绍

rocketmq使用场景一般会有哪些?rocketmq使用场景示例

rocketmq事务消息原理有哪些?rocketmq是什么?