对于目前的行云系统功能:
动态修改消费者数量
繁忙时可以增加消费者数量提升处理能力,空闲时减少数量防止资源浪费。
停止/开启对消息队列的监听
消费信息时出现异常及时停止,便于排查事故。
使用rabbitmq的SimpleMessageListenerContainer核心类解决上述问题。
start()、stop()方法开启/关闭消费队列的监听 |
- 本文标题: rabbitmq消费者实现动态处理
- 文章作者: sherryriver(木木三可)
- 发布时间: 2019.10.16
- 本文链接: https://sherryriver.github.io/2019/10/16/rabbitmq实现动态处理/
- 许可协议: "署名-非商用-相同方式共享 4.0" 转载请保留原文链接及作者。