短视频

来源：短视频

不会的技术就不要写在简历里面！你说你熟悉RocketMQ，结果问怎么处理消息挤压都不知道！这不是给自己挖坑吗？所以跟你们说过简历里面写的技术一定要会要不然就相当于浪费面试机会，现在的环境本来面试机会就少，呐。我给大家准备了一份80万字的java面试资料，不会的技术就去里面学就行了， 都给你总结了面试的回答概要，扣666就会发给你。

哈喽大家我是徐庶，顺便讲下RocketMQ消息挤压问题。

一般生产者发送消息的速度会快于消费者消费消息的速度，这时就会产生消息积压，从而导致消息可能丢失

甚至影响整个系统的性能和稳定性。

那怎么解决呢？

我给你提供4种解决方案，有更多的方式欢迎在评论区交流。

1. 增加消费者数量：既然消息会挤压能说明消息的消费能力不足嘛，增加消费者服务不就完了嘛。

2. 提升消费者的处理能力：当然也有可能是消费者代码处理能力不行，导致消费性能低下， 可以针对消费者的处理逻辑进行优化。

3. 增加消息队列的分区数：如果消息队列采用了分区机制，可以通过增加分区数来提高消息的并行化处理能力，从而减少消息在单个分区内的积压。

4. 调整消息的生产速率：既然消息消费不过来， 那上游就不要给这么快的消息嘛， 太快了人家受不了,慢一点。但是需要业务运行的情况下才可以啊。

5 . 监控和报警：建立监控和报警系统，实时监控消息队列的积压情况，及时发现并处理积压问题，当然这是兜底方案不是解决方案了。

好~ 如果视频看完对你有用别忘了给我三连支持一下，感谢~~~