深入剖析 RocketMQ 5.0 客户端 Nameserver 地址更新机制

2023-12-24 08:26:22

在分布式系统中，服务发现是至关重要的。RocketMQ 5.0 中，客户端如何更新 Nameserver 地址尤为关键。本文将通过源码分析的方式，揭开这一谜题。

Nameserver 地址获取概述

在 RocketMQ 中，客户端通过 Nameserver 发现 Broker 的地址。在 RocketMQ 5.0 中，客户端在启动时会根据配置的 Name Server 地址列表，进行轮询查找。

public List<String> nameServerAddrs() {
    List<String> result = new ArrayList<>(this.namesrvAddrList);
    result.addAll(this.namesrvAddrSet);
    return result;
}

Nameserver 地址更新触发条件

客户端在以下情况下会触发 Nameserver 地址更新：

定期更新： 客户端会周期性地向 Name Server 发送心跳包，如果收到的 Name Server 地址列表与当前客户端持有的列表不同，则客户端会更新自己的 Nameserver 地址列表。
Broker 异常： 当客户端与 Broker 通信异常时，客户端会从 Broker 收到异常信息，其中包含 Nameserver 地址列表。客户端会使用这些地址更新自己的 Nameserver 地址列表。
Nameserver 异常： 当客户端与 Nameserver 通信异常时，客户端会尝试从其他 Nameserver 获取地址列表。如果成功获取到新的地址列表，客户端会更新自己的 Nameserver 地址列表。

Nameserver 地址更新源码实现

客户端更新 Nameserver 地址的源码位于 com.alibaba.rocketmq.client.impl.MQClientManager 类中。

public void updateNameServerAddressList(final List<String> addrs) {
    synchronized (this.namesrvLock) {
        for (String addr : addrs) {
            int index = this.namesrvAddrList.indexOf(addr);
            if (index < 0) {
                this.namesrvAddrList.add(addr);
            }
        }
    }
}