RocketMQ一些细节执行流程
NameServer
功能
一 是维护Broker的服务地址并进行及时的更新。
二 是给Producer和Consumer提供服务获取Broker列表
启动流程
整个NameServer的核心就是一个NamesrvController对象。响应客户端请求的。 在创建NamesrvController对象时,有两个关键的配置 NamesrvConfig 这个是NameServer自己运行需要的配置信息。 NettyServerConfig 包含Netty服务端的配置参数,默认占用了9876端口。可以 在配置文件中覆盖。 然后在启动服务时,启动几个重要组件: RemotingServer 这个就是用来响应请求的。
还有一个定时任务会定时扫描不活动的Broker。这个Broker管理是通过 routeInfoManager这个功能组件。 在关闭服务时,关闭了四个东西 RemotingServer
remotingExecutor Netty服务线程池;
scheduledExecutorService 定时任务;
fileWat
共有 0 条评论