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/domainModel/07consumergroup/

状态列表页

列名解释如下：
队列：不同分片的队列，默认4个分片；

最小位点：该分片队列的最小偏移量；

最大位点：该分片队列的最大偏移量；

上次更新时间：发送消息到该分片队列的最新时间；

消费者列表页

列名解释如下：
订阅组：消费者分组；

代理者：即Broker；

队列：分片队列ID；

消费者终端：IP@instanceName；

代理者位点：该分片队列的最大偏移量，即状态列表页的最大位点；

消费者位点：消费者分组的最大偏移量；

差值：代理者位点-消费者位点，即未消费消息总数；

上次时间：消费者分组的最新消费时间；

4、 Kafka监控

4.1、配置参考

4.2、Kafka监控

主题列表页

队列：真实topic；

状态列表页

列名解释如下：
主题：真实topic；

分区：topic分片，默认4；

消息总数：该分片的消息总数；

消费者列表页

列名解释如下：
订阅组：消费者分组；

分区：topic分片ID；

代理者位点：该分片的消息最大偏移量；

消费者位点：消费者分组的最大偏移量；

差值：代理者位点-消费者位点，即未消费消息总数；

组内活跃线程数：跨节点统计该分组有n个消费者；