微服务框架

【SpringCloud+RabbitMQ+Docker+Redis+搜索+分布式，系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】

服务异步通讯

52 惰性队列

52.1 消息堆积问题

52.1.1 消息堆积问题

当生产者发送消息的速度超过了消费者处理消息的速度，就会导致队列中的消息堆积，直到队列存储消息达到上限。

最早接收到的消息，可能就会成为死信，会被丢弃，这就是消息堆积问题。

【举个栗子】

这个队列 的体积只有5个，消费者现在不知道什么原因 阻塞 住了

现在生产者 不断的发送消息，嗯，很想当然的，它就被灌满了，放满了之后，再来消息，显然就放不进去了

这个时候，最早接收的 消息就会成为死信

而且死信在 默认情况下会被 丢弃

现在队列中就有 新的空间了

生产者 就可以发送新的 消息进去了

【但是】现在有消息被丢了，这对有些 对消息安全性要去较高的场景下，这是不可接受的。

解决消息堆积有三种种思路：

• 增加更多消费者，提高消费速度
• 在消费者内开启线程池加快消息处理速度
• 扩大队列容积，提高堆积上限