2023年rabbitMq面试题汇总1（5道）

男娘i 2024-03-27 14:39 60阅读 0赞

一、上千万条消息在mq中积压了⼏个⼩时还没解决：

1）先修复consumer的问题，确保其恢复消费速度，然后将现有consumer都停掉；

2）新建⼀个topic，partition是原来的10倍，临时建⽴好原先10倍或者20倍的queue数量；

3）然后写⼀个临时的分发数据的consumer程序，这个程序部署上去消费积压的数据；消费之后不做耗时的处理，直接均匀轮询写⼊临时建⽴好的10倍数量的queue；

4）接着临时征⽤10倍的机器来部署consumer，每⼀批consumer消费⼀个临时queue的数据；

5）这种做法相当于是临时将queue资源和consumer资源扩⼤10倍，以正常的10倍速度来消费数据；

6）等快速消费完积压数据之后，得恢复原先部署架构，重新⽤原先的consumer机器来消费消息。

总结：

1. 修复并停掉consumer；

2. 新建⼀个topic，partition是原来的10倍，建⽴临时queue，数量是原来的10倍或20倍；

3. 写临时consumer程序，临时征⽤10倍的机器去消费数据；

4. 消费完成之后，恢复原先consumer；

**二、rabbitmq设置过期时间，部分消息丢失：**

采取批量重导⽅法：将丢失的那批数据查询导⼊到mq⾥⾯。

**三、RabbitMQ 上的⼀个 queue 中存放的 message 是否有数量限制？**

可以认为是⽆限制，因为限制取决于机器的内存，但是消息过多会导致处理效率的下降。

**四、分布式部署：**

RabbitMQ⽆法容忍不同数据中⼼之间⽹络延迟，但是可以通过3种⽅式实现分布式部署：Federatio和Shovel。

**5、如何确保消息正确地发送⾄RabbitMQ？**

RabbitMQ使⽤发送⽅确认模式，确保消息正确地发送到RabbitMQ。

发送⽅确认模式：将信道设置成confirm模式（发送⽅确认模式），则所有在信道上发布的消息都会被派⼀个唯⼀的ID。⼀旦消息被投递到⽬的队列后，或者消息被写⼊磁盘后（可持久化的消息），信道会发送⼀个确认给⽣产者（包含消息唯⼀ID）。如果RabbitMQ发⽣内部错误从⽽导致消息丢失，会发送⼀条nack（not acknowledged，未确认）消息。发送⽅确认模式是异步的，⽣产者应⽤程序在等待确认的同时，可以继续发送消息。当确认消息到达⽣产者应⽤程序，⽣产者应⽤程序的回调⽅法就会被触发来处理确认消息

发表评论取消回复

表情：

评论列表（有 0 条评论，60人围观）

还没有评论，来说两句吧...

相关阅读

相关关于RabbitMQ面试题汇总

RabbitMQ常见面试题汇总，看这一篇就够了！！！

逃离我推掉我的手/ 2024年05月06日 09:51/ 0 赞/ 64 阅读

相关 2023年MQ面试题5道

1. 什么是MQ MQ就是消息队列。是软件和软件进行通信的中间件产品。 2. MQ的优点简答异步处理 - 相比于传统的串行、并行方式，提高了系统吞吐量。应用解耦

港控/mmm°/ 2024年03月30日 17:57/ 0 赞/ 67 阅读

相关 2023年java面试题之kafka（5道）

一. kafka介绍： 1.消息分类按不同类别,分成不同的Topic,Topic⼜拆分成多个partition,每个partition均衡分散到不同的服务器(提⾼并发访问的能

喜欢ヅ旅行/ 2024年03月27日 15:34/ 0 赞/ 68 阅读

相关 2023年rabbitMq面试题汇总4（7道）

一、如何保证消息的顺序性？ 1. 通过某种算法，将需要保持先后顺序的消息放到同⼀个消息队列中(kafka中就是partition,rabbitMq中就是queue)。然后只⽤

Dear 丶/ 2024年03月27日 15:06/ 0 赞/ 85 阅读

相关 2023年rabbitMq面试题汇总3（5道）

一、如何确保消息不丢失？消息持久化的前提是：将交换器/队列的durable属性设置为true，表示交换器/队列是持久交换器/队列，在服务器崩溃或重启之后不需要重新创建交换器

女爷i/ 2024年03月27日 15:04/ 0 赞/ 80 阅读

相关 2023年rabbitMq面试题汇总2（5道）

一、如何确保消息接收⽅消费了消息？接收⽅消息确认机制：消费者接收每⼀条消息后都必须进⾏确认（消息接收和消息确认是两个不同操作）。只有消费者确认了消息，RabbitMQ才能安

╰半夏微凉°/ 2024年03月27日 14:39/ 0 赞/ 269 阅读

相关 2023年rabbitMq面试题汇总1（5道）

一、上千万条消息在mq中积压了⼏个⼩时还没解决： 1）先修复consumer的问题，确保其恢复消费速度，然后将现有consumer都停掉； 2）新建⼀个topic，part

男娘i/ 2024年03月27日 14:39/ 0 赞/ 61 阅读

相关 2023年redis面试题开胃菜3（7道）

一、Redis 集群如何选择数据库？ Redis 集群目前无法做数据库选择，默认在 0 数据库。二、Redis 中的管道有什么用？一次请求/响应服务器能实现处理新的请

我就是我/ 2024年03月27日 11:57/ 0 赞/ 91 阅读

相关 2023年springboot面试题

1. 什么是SpringBoot? 通过Spring Boot，可以轻松地创建独立的，基于生产级别的Spring的应用程序，您可以“运行”们。大多数Spring Boot应用

迷南。/ 2024年03月27日 08:55/ 0 赞/ 81 阅读

相关 2023年java初级面试题10道基础试水题

1、面向对象的特征有哪些方面? 答：面向对象的特征主要有以下几个方面： 1)抽象：抽象是将一类对象的共同特征总结出来构造类的过程，包括数据抽象和行为抽象两方面。抽象只关注对

叁歲伎倆/ 2024年03月26日 14:12/ 0 赞/ 122 阅读