面试是每个程序员都要面对的一道门槛，这次小编整理了一些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面试宝典中查看详情。
推荐阅读：