导航
导航
文章目录
  1. 动态修改消费者数量
  2. 停止/开启对消息队列的监听

rabbitmq消费者实现动态处理

对于目前的行云系统功能:

动态修改消费者数量

繁忙时可以增加消费者数量提升处理能力,空闲时减少数量防止资源浪费。

停止/开启对消息队列的监听

消费信息时出现异常及时停止,便于排查事故。

使用rabbitmq的SimpleMessageListenerContainer核心类解决上述问题。

start()、stop()方法开启/关闭消费队列的监听
setConcurrentConsumers(int) 动态设置消费者数量