C/C++教程

全站最硬核 百万字强肝RocketMq源码 火热更新中~(三十五)

本文主要是介绍全站最硬核 百万字强肝RocketMq源码 火热更新中~(三十五),对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

从宏观上总结下吧,因为内部底层很多。

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;

是一个服务的状态枚举类,包含:刚创建,运行中,已销毁,启动失败

这篇关于全站最硬核 百万字强肝RocketMq源码 火热更新中~(三十五)的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!