其他分享
首页 > 其他分享> > RabbitMQ----消息堆积

RabbitMQ----消息堆积

作者:互联网

消息堆积的原因

生产者生产的消息比较多,而消费者消费的比较慢,那么消费者为啥会慢?因为业务逻辑耗时太久。业务为啥会耗时太久呢?

  • 业务设置不合理:瞬时查询出10万数据放到MQ,而消费者只有1个,全量同步导致瞬时堆积;
  • 异常:

        事务顺序执行:abcd四个事务顺序执行,b事务执行中发生异常阻塞;

        死锁:业务涉及多线程产生死锁;

        慢查询

  •  重发次数超了:在redis或者数据库中记录重试次数,达到最大重试次数以后消息进入死信队列或者其他队列,再单独针对这些消息进行处理;

解决消息堆积

消息堆积问题,基本都是因为消费者处理的时间大于生产者的生产时间,此时的处理思路就是提高消费者的消费速率

解决思路有下面几个:

  1. 将消费者中的业务逻辑分散开处理,比如说消费者中有两个业务处理,此时可以分两个通道,分开处理。
  2. 增加消费者;
  3. 多线程消费

标签:消费者,处理,业务,RabbitMQ,----,消息,多线程,堆积
来源: https://blog.csdn.net/jim_007/article/details/120181244