关键词：
一、面试题
如何解决消息队列的延时以及过期失效问题？消息队列满了以后该怎么处理？有几百万消息持续积压几小时，说说怎么解决？
二、面试官心里分析
你看这问法，其实本质针对的场景，都是说，可能你的消费端出了问题，不消费了，或者消费的极其极其慢。接着就坑爹了，可能你的消息队列集群的磁盘都快写满了，都没人消费，这个时候怎么办？或者是整个这就积压了几个小时，你这个时候怎么办？或者是你积压的时间太长了，导致比如rabbitmq设置了消息过期时间后就没了怎么办？
所以就这事儿，其实线上挺常见的，一般不出，一出就是大case，一般常见于，举个例子，消费端每次消费之后要写mysql，结果mysql挂了，消费端hang那儿了，不动了。或者是消费端出了个什么叉子，导致消费速度极其慢。
三、面试题分析
关于这个事儿，我们一个一个来梳理吧，先假设一个场景，我们现在消费端出故障了，然后大量消息在mq里积压，现在事故了，慌了
1、大量消息在mq里积压了几个小时了还没解决
几千万条数据在MQ里积压了七八个小时，从下午4点多，积压到了晚上很晚，10点多，11点多。
这个是我们真实遇到过的一个场景，确实是线上故障了，这个时候要不然就是修复consumer的问题，让他恢复消费速度，然后傻傻的等待几个小时消费完毕。这个肯定不能在面试的时候说吧。
一个消费者一秒是1000条，一秒3个消费者是3000条，一分钟是18万条，1000多万条。
所以如果你积压了几百万到上千万的数据，即使消费者恢复了，也需要大概1小时的时间才能恢复过来。
一般这个时候，只能操作临时紧急扩容了，具体操作步骤和思路如下：
（1）先修复consumer的问题，确保其恢复消费速度，然后将现有cnosumer都停掉；
（2）新建一个topic，partition是原来的10倍，临时建立好原先10倍或者20倍的queue数量；
（3）然后写一个临时的分发数据的consumer程序，这个程序部署上去消费积压的数据，消费之后不做耗时的处理，直接均匀轮询写入临时建立好的10倍数量的queue；
（4）接着临时征用10倍的机器来部署consumer，每一批consumer消费一个临时queue的数据；
（5）这种做法相当于是临时将queue资源和consumer资源扩大10倍，以正常的10倍速度来消费数据；
（6）等快速消费完积压数据之后，得恢复原先部署架构，重新用原先的consumer机器来消费消息；
2、这里我们假设再来第二个坑
假设你用的是rabbitmq，rabbitmq是可以设置过期时间的，就是TTL，如果消息在queue中积压超过一定的时间就会被rabbitmq给清理掉，这个数据就没了。那这就是第二个坑了。这就不是说数据会大量积压在mq里，而是大量的数据会直接搞丢。
这个情况下，就不是说要增加consumer消费积压的消息，因为实际上没啥积压，而是丢了大量的消息。我们可以采取一个方案，就是批量重导，这个我们之前线上也有类似的场景干过。就是大量积压的时候，我们当时就直接丢弃数据了，然后等过了高峰期以后，比如大家一起喝咖啡熬夜到晚上12点以后，用户都睡觉了。
这个时候我们就开始写程序，将丢失的那批数据，写个临时程序，一点一点的查出来，然后重新灌入mq里面去，把白天丢的数据给他补回来。也只能是这样了。
假设1万个订单积压在mq里面，没有处理，其中1000个订单都丢了，你只能手动写程序把那1000个订单给查出来，手动发到mq里去再补一次。
3、然后我们再来假设第三个坑
如果走的方式是消息积压在mq里，那么如果你很长时间都没处理掉，此时导致mq都快写满了，咋办？这个还有别的办法吗？没有，谁让你第一个方案执行的太慢了，你临时写程序，接入数据来消费，消费一个丢弃一个，都不要了，快速消费掉所有的消息。然后走第二个方案，到了晚上再补数据吧。
另外，大家有什么好的想法，欢迎留言补充哦！
热门内容：
1、为什么阿里巴巴不建议在for循环中使用"+"进行字符串拼接?
8、困扰多年的Java泛型解惑之 extends T>和 super T>
消息队列的面试题6
...时以及过期失效问题？消息队列满了以后该怎么处理？有几百万消息持续积压几小时，说说怎么解决？ 2、面试官心里分析 你看这问法，其实本质针对的场景，都是说，可能你的消费端出了问题，不消费了，或者消费的... 查看详情
43rocketmq对百万消息积压问题的处理方案
业务场景：在一个系统中，由生产者系统和消费者系统两个环节组成，生产者系统不停的把消息写入RocketMQ里去，然后消费者系统就负责从RocketMQ里消费消息。该系统在生产环境的高峰期内，大概有100多万条消... 查看详情
生产环境消息队列activemq的数据积压优化过程(代码片段)
1概述最近生产环境的消息通知队列发生了大量的数据积压问题，从而影响到整个平台商户的交易无法正常进行，最后只能通过临时关闭交易量较大的商户来缓解消息队列积压的问题，经线上数据分析，我们的消息队列在面对交... 查看详情
17如何解决消息队列的延时以及过期失效问题？消息队列满了以后该怎么处理？有几百万消息持续积压几小时，说说怎么解决
消息积压处理办法：临时紧急扩容：先修复 consumer 的问题，确保其恢复消费速度，然后将现有 cnosumer 都停掉。新建一个 topic，partition 是原来的 10 倍，临时建立好原先 10 倍的 queue 数... 查看详情
消息积压的处理
...在使用消息队列的系统中，对于性能的优化，主要体现在生产者和消费者两部分的业务逻辑中。对于消息队列本身的性能，作为使用者不需要太关注。主要原因是对于绝大多数使用消息队列的业务来说，消息队列本身的处理能力... 查看详情
mq——消息积压如何处理
一、消息积压的原因1、producer生产消息突然增多比如大促期间，抢购，秒杀业务。2、consumer消费性能突然下降比如消费失败时重试，程序死锁，io阻塞。3、消费系统本身出现瓶颈这种情况很少，对于绝大多数使用消息队列的业务... 查看详情
消息队列消息积压了该如何处理
...避免消息积压在性能优化的层面，我们主要关注的是生产者和消费者一收和一发业务逻辑中，因为单节点的消息队列处理能力远远大于业务系统的处理能力，并且可以通过拓展Broker来进行提升整体的处理能力。而业务... 查看详情
rocketmq使用之消息保证，重复读，积压，顺序，过滤，延时，事务，死信
...可能在哪些阶段丢失呢？可能会在这三个阶段发生丢失：生产阶段、存储阶段、消费阶段所以要从这三个阶段考虑：在生产阶段，主要通过请求确认机制，来保证消息的可靠传递。存储阶段，可以通过配置可靠性优先的Broker参数... 查看详情
rabbitmq消息积压，恶性循环解决思路
设置消息的过期时间，让有问题的消息自己过期，不过会误杀正常的消息设置队列的死性队列以及最大重试次数，消息一达到最大重试次数，就会自己到死性队列，不会影响后续消息，而且在死性队列里还... 查看详情
消息队列：消息可靠性重复消息消息积压利用消息实现分布式事务
...星标”学最好的别人，做最好的我们 - 如何确保消息不丢失 - 1、检测消息丢失的方法可以利用消息队列的有序性来验证是否有消息丢失。在Producer端给每个发出的消息附加一个连续递增的序号，然后在Consumer端来... 查看详情
消息队列面试题
...上，总结如下：【activeMQ】【rabitMQ】【rocketMQ】【kafka】生产者投递消息到MQ，MQ存储消息，消费者从MQ消费消息：要分别确保上述三个过程都是成功的，有如下做法：解决方法如下：【rabbitmq解决积压范例】【kafka解决范例】 查看详情
消息队列rabbitmq原理消息队列保证幂等性，消息丢失，消息顺序性，以及处理消息队列消息积压问题
消息队列消息队列（MessageQueue，简称MQ），从字面意思上看，本质是个队列，FIFO先入先出，只不过队列中存放的内容是message而已常见的消息队列RabbitMqActiveMqZeroMqkafka等；为什么使用RabbitMq?RabbitMQ是... 查看详情
redis消息队列(messagequeues)
参考技术A+发布者订阅者模式：发布者生产消息放到队列里，多个监听队列的消费者都会收到同一份消息；即正常情况下每个消费者收到的消息应该都是一样的。+生产者消费者模式(Producer/ConsumerMode)：生产者生产消息放到队列里... 查看详情
面试官心理分析+面试题剖析：消息队列+redis缓存+分布式系统等
...时以及过期失效问题？消息队列满了以后该怎么处理？有几百万消息持续积压几小时，说说怎么解决？7、如果让你写一个消息队列，该如何进行架构设计？说一下你的思路。搜索引擎1、es的分布式架构原理能说一下么（es是如何... 查看详情
rabbitmq业务难点(代码片段)
Rabbitmq业务难点1.消息生产者发送的消息无法路由到任何一个队列怎么处理?2.聊聊Rabbitmq的七种工作模式3.Rabbitmq的消息确认机制4.Rabbitmq的消息持久化5.发布确认模式如何确保生产者能够成功将消息投递到消息队列6.Rabbitmq基于队列... 查看详情
第七篇：分布式组件（dubbonettynigixzookeepermqjob）
...队列延时及过期问题？消息队列满了怎么处理？几百万消息队列积压了几小时怎么处理？一.Dubbo：高性能RPC框架五.MQ：分布式消息中间件1、MQ有哪些使用场景(优点)？(高频)异步处理:相对于同步提高了吞吐... 查看详情
消息积压了怎么办？
...求必须尽快处理。消息积压，一般分为两大类：生产者生产消息过快消费者消 查看详情
redis实现简单消息队列
...还是处理通知消息，针对通知消息通常采取是队列结构。生产和消费消息进行通信和业务实现。上述异步任务的实现，可以抽象为生产者消费模型。如同一个餐馆，厨师在做饭，吃货在吃饭。如果厨师做了很多，暂时卖不完，厨... 查看详情