| 产品版本 | 更新内容 | 更新日期 |
| V6.0.4 | Monitor-MQ新增RocketMQ、Kafka监控能力 | 2023年12月29日 |
1、 简介
苍穹平台目前支持3种开源消息中间件,RabbitMQ、RocketMQ、Kafka。可通过修改MC配置项进行切换,切换MQ类型后苍穹容器需重启才生效。每一种消息中间件的设计理论不同,遵循协议不同,因此不同MQ类型的监控页有差异。
2、 RabbitMQ
2.1、配置参考

2.2、RabbitMQ监控
队列列表页

列名解释如下:
队列:真实队列名称;
虚拟主机: vhost;
消息总数:消息总数=待消费+消费中;
待消费:未消费的消息总数;
消费中:消费者程序正在消费中,但未 ack 确认的消息总数;
状态: running 表示正常运行中;
消费者列表页

列名解释如下:
通道:客户端IP;
通道详情: tcp连接详情,客户端IP端口与服务端IP端口;
消费者标签:消费者唯一ID;
并发度: mqqueueconfig.xml配置文件中consumer标签的concurrency属性,默认并发度=1,即单个节点内只允许并发消费1条消息,配置参考如下;

3、 RocketMQ
3.1、配置参考
3.2、RocketMQ监控
主题列表页

列名解释如下:
队列:真实topic;
注:主题包含重试topic,格式:%RETRY%+消费者组,消费者组默认为订阅topic
例子:%RETRY%devfeature_sit_test_tmc-fcs-checkrepeat,订阅topic= devfeature_sit_test_tmc-fcs-checkrepeat
消费者分组概念可参考官方文档
https://rocketmq.apache.org/zh/docs/dom