1. rocketmq源码安装参考官方文档：http://rocketmq.apache.org/docs/quick-start/安装好jdk和maven rocketmq安装包：https://pan.baidu.com/s/1I3CqWaxFnxtUX1kJpIJkcQ 密码: vu5m ...

转载：消息队列消息积压了怎么办？ 作者： 以梦为码 　　Q:刚开始是对这个疑问抱有质疑态度的，因为使用消息队列的其中目的就是削峰填谷，来避免高流量时，对下游服务的冲击，所以使用消息队列进行缓冲，下游根据自己的消费能力去消费， 我感觉这就是消息积压本就是使用消息队列的功能，怎么会是问题 ...

在日常工作中使用RabbitMQ偶尔会遇不可预料的情况导致的消息积压，一般出现消息积压基本上分为几种情况： 消费者消费消息的速度赶不上生产速度，这总问题主要是业务逻辑没设计好消费者和生产者之间的平衡，需要改业务流程或逻辑已保证消费度跟上生产消息的速，譬如增加消费者的数量 ...

大量消息在 mq 里积压了几个小时了还没解决 几千万条数据在 MQ 里积压了七八个小时，从下午 4 点多，积压到了晚上 11 点多。这个是我们真实遇到过的一个场景，确实是线上故障了，这个时候要不然就是修复 consumer 的问题，让它恢复消费速度，然后傻傻的等待几个小时消费完毕。这个肯定不能在 ...

...

消息丢失 1、只要订单完成我们就会发送一条消息给MQ，这个途中突然MQ服务器网络中断，导致消息无法抵达 做好容错方法需要在消息发送前加上异常处理 还可以将消息存入数据库，把失败的消息定期重新再发一遍 2、当消息发送给MQ，通过Brock通过交换机抵达队列，MQ关机了，只有抵达队列 ...

除了消息的丢失，另一个消息队列常见的问题就是消息积压了。我们都知道，消息之所以会挤压是由于消费端的性能除了问题，导致消息的消费速度较低来不及处理上游发送的消息。这一章我们就来看一下，如果优化代码的性能，避免出现消息积压。 在使用消息队列的系统中，对于性能的优化，主要体现在 ...

消费端出了问题，导致消息队列消息积压了很多或者集群的磁盘都快写满了。 解决思路有两个： 1、MQ动态扩容，将MQ容量增大，让其能容纳更多的消息 2、消费端加大消费能力，迅速处理掉积压。 第一个例子： 如果你积压了几百万到上千万的数据，即使消费者恢复了，也需要大概1小时 ...