5 张图告诉你 RocketMQ 为什么不使用 Zookeeper 做注册中心

刺骨的言语ヽ痛彻心扉 2024-04-08 10:08 31阅读 0赞

RocketMQ 选择了自己写 NameServer 做注册中心而没有选择 Zookeeper，这是为什么呢？

首先看一下 RocketMQ 的架构，如下图：

![b338c1e8e210a8b261d1c04acda6feed.png][]

RocketMQ 的 Broker 注册到 NameServer 集群，而生产者和消费者则需要从 NameServer 拉取消息。

### 1 NameServer ###

#### 1.1 Broker 注册 ####

Broker 启动时，会向 NameServer 发送注册消息，相关的 UML 类图如下：

![f048ad9b6702c47f28f708c5b6c981af.png][]

我们看一下 BrokerOuterAPI 的 registerBrokerAll 方法，代码如下：

//BrokerOuterAPI.java
    public List<RegisterBrokerResult> registerBrokerAll(
     //省略参数
     final boolean compressed) {
    
     final List<RegisterBrokerResult> registerBrokerResultList = new CopyOnWriteArrayList<>();
     List<String> nameServerAddressList = this.remotingClient.getNameServerAddressList();
     if (nameServerAddressList != null && nameServerAddressList.size() > 0) {
            //省略 requestHeader 封装
      final CountDownLatch countDownLatch = new CountDownLatch(nameServerAddressList.size());
      for (final String namesrvAddr : nameServerAddressList) {
       brokerOuterExecutor.execute(new Runnable() {
        @Override
        public void run() {
         try {
          RegisterBrokerResult result = registerBroker(namesrvAddr, oneway, timeoutMills, requestHeader, body);
          if (result != null) {
           registerBrokerResultList.add(result);
          }
         } catch (Exception e) {
         } finally {
          countDownLatch.countDown();
         }
        }
       });
      }
    
      try {
       countDownLatch.await(timeoutMills, TimeUnit.MILLISECONDS);
      } catch (InterruptedException e) {
      }
     }
     return registerBrokerResultList;
    }

可以看到，当 Broker 启动时，会向所有的 NameServer 发送注册消息，NameServer 端的注册内容如下：

[b338c1e8e210a8b261d1c04acda6feed.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/08/156661aeaf8e490bab1231a65c8d351e.png
[f048ad9b6702c47f28f708c5b6c981af.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/08/53349384b60d46a2b8ad03aed1b80a16.png