标签：全站 Service private ServiceState DefaultMQAdminExt 源码 apache final 硬核
从宏观上总结下吧，因为内部底层很多。
NamesrvController包含四部分：服务器远程连接、执行器、定时任务、文件监控
接下来回到起点：KVConfigManager。
抱歉，KVConfigManager也结束了。现在明白了，其实我们的起点KVConfigManager是一个小类，属于是对于全局配置的管理，还是我们之前说的，基于namespace做key的kv配置存储
private final HashMap<String/* Namespace */, HashMap<String/* Key */, String/* Value */>> configTable =
new HashMap<String, HashMap<String, String>>();
org.apache.rocketmq.namesrv.processor.ClusterTestRequestProcessor
接下来顺着包继续找，是一个集群测试请求处理器，看下对集群请求的处理是怎样的：
private static final InternalLogger log = InternalLoggerFactory.getLogger(LoggerName.NAMESRV_LOGGER_NAME);
private final DefaultMQAdminExt adminExt;
private final String productEnvName;
进来首先声明一个日志，字符串类型生产环境名称，还有一个DefaultMQAdminExt 默认mq管理扩展（我们暂且这样称呼它），之后我们进去看下这个管理扩展内部到底干了什么：
org.apache.rocketmq.tools.admin.DefaultMQAdminExt
private final DefaultMQAdminExtImpl defaultMQAdminExtImpl;
private String adminExtGroup = "admin_ext_group";
private String createTopicKey = TopicValidator.AUTO_CREATE_TOPIC_KEY_TOPIC;
private long timeoutMillis = 5000;
进来后首先声明一个默认mq管理扩展实现，超时时间，还有一个枚举类，获取的值是自动创建topic的topic，这里有两个类，一个是DefaultMQAdminExtImpl，一个是TopicValidator。我们分别看下：
org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl
private final InternalLogger log = ClientLogger.getLog();
private final DefaultMQAdminExt defaultMQAdminExt;
private ServiceState serviceState = ServiceState.CREATE_JUST;
private MQClientInstance mqClientInstance;
private RPCHook rpcHook;
private long timeoutMillis = 20000;
private Random random = new Random();
还是先看声明，这些声明里我们还没有读过的，应该就是ServiceState和MQClientInstance 看下ServiceState：
org.apache.rocketmq.common.ServiceState
/**
* Service just created,not start
*/
CREATE_JUST,
/**
* Service Running
*/
RUNNING,
/**
* Service shutdown
*/
SHUTDOWN_ALREADY,
/**
* Service Start failure
*/
START_FAILED;
是一个服务的状态枚举类，包含：刚创建，运行中，已销毁，启动失败
标签：全站,Service,private,ServiceState,DefaultMQAdminExt,源码,apache,final,硬核 来源： https://blog.csdn.net/GBS20200720/article/details/122649238
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。