百度360必应搜狗淘宝本站头条
tomcat 乱码无法与服务器建立安全连接是什么意思sysv-rc-confdocker映射容器目录到宿主机internet explorer 增强的安全配置已启用
当前位置：网站首页 > 技术文章 > 正文

RocketMQ篇8:NameServer源码解析（rocketmq原理解析）

nanshan 2024-10-09 12:55 17 浏览 0 评论

模块入口代码功能

NamesrvStartup是模块的启动入口，NamesrvController是用来协调各个调用模块功能的代码。

1、解析命令行参数

main0函数主要完成两个功能，第一个功能是解析命令行参数；

-c命令行参数是指定配置文件的位置

-p命令行参数是用来打印所有配置项的值。

2、初始化NameServer的Controller

main0函数的另一个功能是初始化Controller。

根据解析出的配置参数，调用controller.initialize()来初始化，然后调用controller.start()让NameServer开发服务。

还有一个逻辑是注册ShutdonwHookThread，当程序退出的时候回调用controller.shutdonw来做退出前的清理工作。

NameServer的总控逻辑

NameServer的总控逻辑在NamesrvController中，是集群的协调者，它只是简单地接受其他角色报上来的状态，然后根据请求返回响应的状态。

1、线程池初始化

启动了一个默认8个线程的线程池，还有两个定时执行的线程，一个用来扫描失效的Broker，另一个用来打印配置信息。

2、启动通信服务，关联初始化的线程池

启动负责通信的服务remotingServer，监听一些端口，收到Broker、Client等发过来的请求后，根据请求的命令，调用不同的Processor来处理。这些不同的处理逻辑被放到上面初始化的线程池中执行。

核心业务逻辑处理

NameServer的核心业务逻辑，在DefaultRequestProcessor中。网络通信服务模块收到请求后，就调用这个Processor来代理。

根据RequestCode调用不同的函数来处理，如：REGISTER_BROKER是集群中新加入一个Broker；GET_ROUTEINFO_BY_TOPIC是请求获取一个Topic的路由信息；WIPE_WRITE_PERM_OF_BROKER是删除一个Broker的写权限。

集群状态存储

NameServer作为集群的协调者，需要保存和维护集群的各种元数据，是通过RouteInfoManager类来实现的。

每个结构存储着一类集群信息，具体请看我之前发布的文章：《RocketMQ篇3：分布式消息队列的协调者》中的集群状态的存储结构

因为在NameServer的场景中，读取操作多，更改操作少。RouteManager中使用的是可重入的读写锁（ReentrantReadWriteLock）

相关推荐

详细了解ICMP协议（icmp协议的工作原理）

最近跟大家分享了一些网络故障排查的命令，今天给大家分享一下，这些命令背后的协议(ICMP)以及原理，只有了解了原理，我们才能更好的用好这些命令什么是ICMP协议Internet控制报文协议ICMP（I...

Firewalld防火墙与ICMP攻击（防火墙policy）

提到ICMP大家应该都很熟悉，可能有人会说：不就是ping吗？但是说到ICMP攻击以及相关防御措施可能就有的人不是非常清楚了。ICMP的概念要想理解ICMP攻击以及防范我们还得从ICMP的概念说起，...

不可错过!5张图带你搞懂容器网络原理

使用容器总是感觉像使用魔法一样。对于那些理解底层原理的人来说容器很好用，但是对于不理解的人来说就是个噩梦。很幸运的是，我们已经研究容器技术很久了，甚至成功揭秘容器只是隔离并受限的Linux进程，运...

Iptables防火墙详细介绍（iptables防火墙的原理）

一：Linux防火墙基础：Linux防火墙体系主要工作在网络层，针对TCP/IP数据包实施过滤和限制，属于典型的包过滤防火墙（也称网络层防火墙）；Linux防火墙体系基于内核编码实现，具有非常稳定的...

盘点几个实现VLAN间路由的好方法!

在真实的网络中，常常需要跨VLAN通信。许多网络工作者通常选择一些方法来实现不同VLAN中的主机之间的相互访问，如单臂路由。然而，由于单臂路由技术的一些限制，如带宽和转发效率，这种技术是很少使用。三层...

iptables使用详解（iptables入门）

前言最近买了一个VPS，并在上面搭了DOCKER，然后再DOCKER中安装Mysql。但只要将网络端口映射到宿主机上，那么外部网络就可以直接访问该数据。属实吓人。为此，我们需要使用防火墙。说到防火墙，...

网络安全-Kali系统hping3及netwox的使用

Kali-linux系统自身集成Scapy、hping3、netwox等工具，用于渗透测试及网络攻击ScapyScapy是一个Python程序，Scapy是一个功能强大的交互式数据包操作程序，能够发送...

网络工具中的瑞士军刀:Ping和Tracert

引言：Ping命令是一种存在于Windows、Unix和Linux系统下的一种命令。往往常用于测试分析判断网络问题所在，ping命令使用ICMP协议，该协议是TCP/IP协议簇的一个子协议，用于在IP...

如何确定一个网站是否支持IPv6?（如何判断一个网站）

IPv6是互联网协议（IP）的第六版，是互联网工程任务组（IETF）设计的用于替代IPv4的下一代IP协议。为什么国家大力推进互联网协议第六版（IPv6）规模部署？IPv6是为了解决IPv4存在的地址...

西门子Profinet故障诊断入门-4（西门子profinet模块）

Ping指令如何使用1.概述在做PROFINETIO通讯调试时经常遇到PROFINETIO通讯不通的情况，诊断时可以利用多种诊断工具和方法，这里介绍一下Ping指令的使用方法，利用"pi...

Linux 网络设备 - Bridge & Veth Pair

我们继续介绍Linux中常见的网络设备，今天主要讲的是LinuxBridge和VethPair，理解清楚这两种设备对后续理解容器化网络会比较有帮助。1.vethpair两端互通我们先...

Ip地址、子网掩码、网关三者如何协调工作你真的理解了吗?

首先我们来看看以下这两个地址是否可以相互通信呢？初步一看，貌似可以通信，但是再细看，发现两者的掩码完全不同，故而肯定不能通信了？然而并非如此，如果对两者的通信有更深刻的认识，相信就会发现他们到底能否相...

一文精通虚拟端口通道vPC，精品文章，爱了

今天给大家带来的是虚拟端口通道相关的技术：简介传统数据中心使用生成树来防止第2层环路，这已经使用了多年，但确实有局限性，为了防止环路，生成树会阻止一些链路并保持其他链路处于活动状态，如下所示，阻塞...

5张图诠释了容器网络（容器中的网络模式及特点）

使用容器总是感觉像使用魔法一样。对于那些理解底层原理的人来说容器很好用，但是对于不理解的人来说就是个噩梦。很幸运的是，我们已经研究容器技术很久了，甚至成功揭秘容器只是隔离并受限的Linux进程，...

抓包结果显示Destination unreachable(port unreachable)怎么排查

当Wireshark抓包结果显示Destinationunreachable(Portunreachable)时，表示目标主机的指定端口没有服务监听或无法响应请求。以下是详细的排查步骤和...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表