集群管理
- 集群发现
- +NameServer
- 集群管理
- +broker
- 停写
- 下线
1.主要用于NameServer的发现和运维:

2. +集群记录:用于往cluster表新增一条记录:

3. 所谓集群发现是指客户端通过域名的方式发现Name Server集群,继而发现broker集群。或者broker通过域名的方式发现Name Server。
1. 客户端:
客户端通过编码+属性设置的方式来实现,关键代码如下:
// 设置Name Server域名 setProperty("rocketmq.namesrv.domain", "${nameServerDomain}"); // 设置单元名 clientConfig.setUnitName("clusterId");
2. broker:
broker通过配置来实现,关键配置如下:
rmqAddressServerDomain=${nameServerDomain} rmqAddressServerSubGroup=nsaddr-1 fetchNamesrvAddrByAddressServer=true
3. 无论通过哪种方式,均取决于rocketmq的Name Server发现逻辑的URL拼装代码:
// MixAll的wsAddr组装逻辑 public static String getWSAddr() { String wsDomainName = System.getProperty("rocketmq.namesrv.domain", DEFAULT_NAMESRV_ADDR_LOOKUP); String wsDomainSubgroup = System.getProperty("rocketmq.namesrv.domain.subgroup", "nsaddr"); String wsAddr = "http://" + wsDomainName + ":8080/rocketmq/" + wsDomainSubgroup; if (wsDomainName.indexOf(":") > 0) { wsAddr = "http://" + wsDomainName + "/rocketmq/" + wsDomainSubgroup; } return wsAddr; } // TopAddressing.fetchNSAddr的url组装逻辑 String url = this.wsAddr; if (!UtilAll.isBlank(this.unitName)) { url = url + "-" + this.unitName + "?nofix=1"; }
用于部署name server,并且会建立cluster表和name_server表的关联:
1.“一键安装”将会分步骤进行,任何一个步骤失败自动暂停,解决问题后,点击“继续”执行。
2. 安装成功后将会在“进程信息”处列出启动的NameServer进程。

主要展示集群的状况,在此可以进行broker的运维:

注意:broker上下线需要点击“刷新broker”按钮,手动刷新broker列表,从而更新监控列表。
1. “一键安装”将会分步骤进行,任何一个步骤失败自动暂停,解决问题后,点击“继续”执行。
2. 安装成功后将会在“进程信息”处列出启动的broker进程。
3. 关键步骤解释:
- “生成配置文件”中的“topic配置”是指将尝试从集群中已存在的节点同步其topic配置,master启动时自动加载集群中已有的topic。
- “初始化配置”中如果成功执行os.sh将会生成/opt/mqcloud/.mq_cloud_inited,防止os.sh执行多次。
- “启动”阶段将会进行询问“是否自动启动?”,选择“否”,可以到服务器查看或更改配置后,再“继续”启动。

在“master”下线前,执行停写操作,可以暂时擦除broker的写权限,客户端将不再往此broker发送消息。

“下线”即关闭,对应linux的kill,slave可以直接下线,master需要先停写,再下线。

流程审核
- 审核列表
- 新建topic
- 关联生产者
- 其他注意事项
所有前端涉及到数据修改的请求都会发送到审核流程(用户信息修改除外)

审核新建topic注意:测试的topic建在测试集群;如果拒绝,需要填写拒绝理由,详见下图:

关联生产者之前需要“校验一下”,如果没有链接,需要咨询申请人,是否填错:

1. 跳过堆积:
跳过堆积将会把偏移量重置到当前时间的前一分钟,客户端无需重启。
跳过堆积无法重置重试队列的数据,如果重试队列大量堆积,建议客户端空消费,很快会清空。
2. 删除消费者:
为了保障数据的安全性,无人关联的消费者禁止删除,包括管理员。
所以,如果需要删除,管理员可以自己关联一下消费者,然后发送删除申请。
监控
配置及展示默认监控指标阈值及自定义消费者监控指标阈值,部分邮件的监控报警数据来自这里,这里只保存最新的监控数据。

用户管理
所有注册用户可以从这里查看。

机器管理
- 机器列表
- 添加机器
- 机器监控
- 监控预警
MQCloud集群所有的机器可以在这里查看。

添加机器前,需要按照初始化脚本,进行初始化。

点击ip会弹出监控页面,包含了load,内存,硬盘,网络等等指标。

配置机器的预警参数,不填则不预警

其他
- 通知管理
- 客户端版本
用于向前端展示通知,同时有效的只能有一条。

客户端启动时会从集群查询集群归属,消费方式等数据,并上报版本。
