首先要找到原因，是producer太多了，还是说consumer太少了。定位问题，然后看下消息的消费速度是否正常，正常的话，可以通过临时上线更多consumer解决问题。 如果consumer和queue不对等，上线了多台consumer也无法解决的话，可以 准备一个临时 ...

RocketMQ消息堆积的问题 1.发生的原因： 　　由于Consumer故障导致消费着节点全部宕机，生产者还在不停的投递消息到Broker，消息被挤压在Broker没有被消费； 2.消息堆积导致的问题: 　　过多的数据不仅占用磁盘空间，还会影响MQ性能； 3.解决方案： 　　分三种 ...

RocketMQ消息堆积问题 RocketMQ消息堆积主要分为三个层次的问题： 其一是Producer生产速率过快，什么场景呢，比如Producer故障，比如DOS攻击，比如业务高峰（超过企业预估的，例如12306订票，双十一下单，这些一开始的时候都有超过预期的情况）。 其二是Broker消息 ...

1.大量消息在mq里积压 场景：几千万条数据在MQ里积压了七八个小时，从下午4点多，积压到了晚上很晚，10点多，11点多。线上故障了，这个时候要不然就是修复consumer的问题，让他恢复消费速度，然后傻傻的等待几个小时消费完毕。这个肯定不行。一个消费者一秒是1000条，一秒3个消费者是3000 ...

1.大量消息在mq里积压 场景：几千万条数据在MQ里积压了七八个小时，从下午4点多，积压到了晚上很晚，10点多，11点多。线上故障了，这个时候要不然就是修复consumer的问题，让他恢复消费速度，然后傻傻的等待几个小时消费完毕。这个肯定不行。一个消费者一秒是1000条，一秒3个消费者是3000 ...

首先，造成这个问题的 BUG RocketMQ 官方已经在 3月16号 的这个提交中修复了，这里只是探讨一下在修复之前造成问题的具体细节，更多的上下文可以参考我之前写的 《RocketMQ Consumer 启动时都干了些啥？》 ，这篇文章讲解了 RocketMQ 的 Consumer 启动 ...

MQ消息堆积是指生产者发送的消息短时间内在Broker端大量堆积，无法被消费者及时消费，从而导致业务功能无法正常使用。 消息堆积常见于以下几种情况： （1）新上线的消费者功能有BUG，消息无法被消费。 （2）消费者实例宕机或因网络问题暂时无法同Broker建立连接。 （3）生产者短时间 ...

消息堆积 　为什么会产生消息堆积？ 　　　　大多数是因为Consumer 出问题了，没有及时发现，或者故障恢复需要较长时间，导致大量消息积压在消息队列中。 消息队列堆积会造成什么后果？ 消息被丢弃 磁盘满了 海量消息需要处理 　解决方案： 增加消费者 ...