zoukankan      html  css  js  c++  java
  • 《RocketMQ源码系列》broker是如何注册到nameserver的

    broker发起注册

       broker启动的时候会先对一些组件初始化,初始化完成后就会调用 start() 方法进行启动。这个时候它会先启动各个组件,然后通过线程池去发起注册请求。

      此时就先 对 topic 进行一些配置,然后就通过  brokerOuterAPI 组件去进行调用。可以看到它是先构造了请求头、请求体等对象,然后通过初始化的 brokerOuterExecutor 线程池向每一个 nameserver 去发起注册,我们接下来就看看注册的方法逻辑就好了。

       然后就是基于请求头请求体构造一个 command 对象,通过前文提到的 RemotingClient 组件去发送请求。

     

      首先会获取到一个 channel,它是 netty 的 bootstrap 组件去和 nameserver 端建立的。然后以这种 rpc 的方式去进行注册。

       整一个链路相当于就是执行完了,接下来就看 nameserver 会怎么去执行这个请求。

     

    nameserver处理注册

      nameserver 在启动的时候,先会执行初始化方法创建 NamesrvController,在这个过程中,是创建了一个 线程池 来处理网络请求的,它是将 nameServer的默认请求组件 (DefaultRequestProcessor) 注册了进来.

      DefaultRequestProcessor就是解析netty通信的这个 channel ,然后通过寄存器组件保存这个注册信息了。其实整个过程不必太纠结,毕竟底层全是netty代码。

  • 相关阅读:
    Django--URLconf
    Django--视图层
    Django 初识之安装下载以及模型目录简介
    jQuery基础
    BOM&DOM
    带你快速上手前端三剑客之css
    mysql 触发器、流程控制、事务等
    前端之html
    python中pymsql常用方法(1)
    18、设计模式-行为型模式-迭代器模式
  • 原文地址:https://www.cnblogs.com/wlwl/p/14985575.html
Copyright © 2011-2022 走看看