共计 10487 个字符，预计需要花费 27 分钟才能阅读完成。
在看这篇文章之前，最好对 NACOS 相关功能有所了解，推荐看完 Spring Cloud Alibaba Nacos（功能篇）。
针对功能，有目的的去找相对应的源代码，进一步了解功能是如何被实现出来的。
本文针对有一定源代码阅读经验的人群，不会深入太多的细节，还需要读者打开源码跟踪，自行领会。
一、引子
进入 GitHub 对应的页面，将 NACOS 工程 clone 下来。目录和文件看起来很冗长，但是对于看源代码真正有帮助的部分并不多。
有了这三张图，就能顺利找到突破口了，核心内容就集中在 nacos-console，nacos-naming，nacos-config，顺藤摸瓜，就能看到不少内容了。
如果还是感觉无从下手的话，那就移步 nacos-example，里面有主要业务的调用入口，一看便知。
二、配置服务
首先从一个工厂类说起：com.alibaba.nacos.api.NacosFactory。
里面的静态方法用于创建 ConfigService 和 NamingService，代码类似，以创建 ConfigService 为例：
public static ConfigService createConfigService(Properties properties) throws NacosException {
try {Class<?> driverImplClass = Class.forName("com.alibaba.nacos.client.config.NacosConfigService");
Constructor constructor = driverImplClass.getConstructor(Properties.class);
ConfigService vendorImpl = (ConfigService) constructor.newInstance(properties);
return vendorImpl;
} catch (Throwable e) {throw new NacosException(-400, e.getMessage());
}
}没有什么复杂的逻辑，使用的是基本的反射原理。构造参数传入了 properties，这些属性可以通过 bootstrap.yml 中指定，对应的是 NacosConfigProperties。
需要细看的是构造函数中对于 namespace 初始化的那部分内容。
private void initNamespace(Properties properties) {
String namespaceTmp = null;
String isUseCloudNamespaceParsing =
properties.getProperty(PropertyKeyConst.IS_USE_CLOUD_NAMESPACE_PARSING,
System.getProperty(SystemPropertyKeyConst.IS_USE_CLOUD_NAMESPACE_PARSING,
String.valueOf(Constants.DEFAULT_USE_CLOUD_NAMESPACE_PARSING)));
if (Boolean.valueOf(isUseCloudNamespaceParsing)) {namespaceTmp = TemplateUtils.stringBlankAndThenExecute(namespaceTmp, new Callable<String>() {
@Override
public String call() {return TenantUtil.getUserTenantForAcm();
}
});
namespaceTmp = TemplateUtils.stringBlankAndThenExecute(namespaceTmp, new Callable<String>() {
@Override
public String call() {String namespace = System.getenv(PropertyKeyConst.SystemEnv.ALIBABA_ALIWARE_NAMESPACE);
return StringUtils.isNotBlank(namespace) ? namespace : EMPTY;
}
});
}
if (StringUtils.isBlank(namespaceTmp)) {namespaceTmp = properties.getProperty(PropertyKeyConst.NAMESPACE);
}
namespace = StringUtils.isNotBlank(namespaceTmp) ? namespaceTmp.trim() : EMPTY;
properties.put(PropertyKeyConst.NAMESPACE, namespace);
}传入的 properties 会指定是否解析云环境中的 namespace 参数，如果是的，就是去读取阿里云环境的系统变量；如果不是，那么就读取 properties 中指定的 namespace，没有指定的话，最终解析出来的是空字符串。从代码上看出来，获取云环境的 namespace 做成了异步化的形式，但是目前版本还是使用的同步调用。
继续跟踪 ConfigService，里面定义了一系列接口方法，正是我们所要看的。
每个业务实现最终都归结为 Http 请求，就是配置的 serverAddr，多个地址会依次轮转使用，当然是在一定超时时间内依次请求，都请求不成功了，那就会抛出异常。
请求方是 nacos-client，接收方最终都是落到 nacos-config 服务上，最后使用 JdbcTemplate 进行数据持久化。
这一部分的代码一看就明白，发布配置，获取配置和删除配置都有所体现，就不展开阐述了。
重点解析一下配置监听部分的源代码。
先将注意力放在 com.alibaba.nacos.client.config.impl.CacheData 这个数据结构上，是个典型的充血模型，主要是充当 listener 管理者的角色，这样看来，类名取得并不是那么友好了。
实际上，可以看出 CacheData 将配置信息（namespace, content）和 listener 聚合在一起了，可以认为一项配置可以附加多种 listener 实施监听（因为 listener 接口可能有多种实现），每种 listener 只会有一个实例附加在配置上。
public void addListener(Listener listener) {if (null == listener) {throw new IllegalArgumentException("listener is null");
}
ManagerListenerWrap wrap = new ManagerListenerWrap(listener);
if (listeners.addIfAbsent(wrap)) {LOGGER.info("[{}] [add-listener] ok, tenant={}, dataId={}, group={}, cnt={}", name, tenant, dataId, group,
listeners.size());
}
}使用了 CopyOnWriteArrayList.addIfAbsent 方法，这个方法最重要就是 equals 方法，ManagerListenerWrap 是对 listener 的另外一种形式的包裹，其实现了 equals 方法：
@Override
public boolean equals(Object obj) {if (null == obj || obj.getClass() != getClass()) {return false;}
if (obj == this) {return true;}
ManagerListenerWrap other = (ManagerListenerWrap) obj;
return listener.equals(other.listener);
}再往上层翻，可以找到对于 listener 更高层的管理 API：com.alibaba.nacos.client.config.impl.ClientWorker。
同样是对 listener 的管理，但是增加了重复校验，其中 cacheMap 是关键，如下定义：
private final AtomicReference<Map<String, CacheData>> cacheMap = new AtomicReference<Map<String, CacheData>>()使用了具有原子性操作特性的 AtomicReference，可以避免并发带来的数据不一致的问题，里面包裹的是一个 HashMap，value 是 CacheData 对象，而 key 是有一定生成规则的，在 GroupKey 这个类中可以找到：
static public String getKeyTenant(String dataId, String group, String tenant) {StringBuilder sb = new StringBuilder();
urlEncode(dataId, sb);
sb.append('+');
urlEncode(group, sb);
if (StringUtils.isNotEmpty(tenant)) {sb.append('+');
urlEncode(tenant, sb);
}
return sb.toString();}实际上是将配置信息用“+”号进行拼接，如果配置信息中本身存在了“+”和“%”，会使用 urlEncode 方法进行编码转义。当然，也有配套的解析方法，这里就不再展开讲解了。
接下来的无非就是就 cacheMap 的一系列 get 和 set 操作，用以维护 listener。特别注意的是，每次更新操作都是先生成一个 copy 对象，操作此对象之后，再整个 set（覆盖）到 cacheMap 中。
最后说一下 listener 是如何运行起来的。
仍然是在 ClientWorker 当中可以找到，将注意力转移到构造函数中。其中，可以注意到，初始化了两个线程池：
executor = Executors.newScheduledThreadPool(1, new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {Thread t = new Thread(r);
t.setName("com.alibaba.nacos.client.Worker." + agent.getName());
t.setDaemon(true);
return t;
}
});
executorService = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors(), new ThreadFactory() {
@Override
public Thread newThread(Runnable r) {Thread t = new Thread(r);
t.setName("com.alibaba.nacos.client.Worker.longPolling." + agent.getName());
t.setDaemon(true);
return t;
}
});
executor.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
try {checkConfigInfo();
} catch (Throwable e) {LOGGER.error("[" + agent.getName() + "] [sub-check] rotate check error", e);
}
}
}, 1L, 10L, TimeUnit.MILLISECONDS);
两个用于执行定时任务的 scheduledThreadPool，而这两个线程池的分工也是嵌套的：executor 用于发布配置检查的任务，而 executorService 则是任务的接收者，是真正执行任务的角色。
所以发布任务的线程池只分配了 1 个核心线程数，而执行任务的线程池的核心线程是 CPU 核数。
因为配置检查是一个长轮询的过程，一个任务执行者能监测的配置数量需要得到控制，所以 NACOS 目前使用了一个比较简单的分任务规则：
public void checkConfigInfo() {
// 分任务
int listenerSize = cacheMap.get().size();
// 向上取整为批数
int longingTaskCount = (int) Math.ceil(listenerSize / ParamUtil.getPerTaskConfigSize());
if (longingTaskCount > currentLongingTaskCount) {for (int i = (int) currentLongingTaskCount; i < longingTaskCount; i++) {
// 要判断任务是否在执行 这块需要好好想想。任务列表现在是无序的。变化过程可能有问题
executorService.execute(new LongPollingRunnable(i));
}
currentLongingTaskCount = longingTaskCount;
}
}在 ParamUtil.getPerTaskConfigSize() 中返回的是每个任务能监测的配置数量上限，默认是 3000 条，可以通过系统变量 PER_TASK_CONFIG_SIZE 更改这个上限。
从代码上可以看出，如果当前 listener 的数量没有超过 3000 个，配置监测的线程池还运转不起来。如果细看这个部分的代码，还是会发现一些问题的，主要是围绕着任务管理衍生出来的一系列问题。
长轮询里面主要有两部分逻辑：
- 检查本地配置，与 CacheData 存储的信息保持一致；
- 检查 server 端配置，更新 CacheData 存储的信息。
三、服务注册与发现
有了上述的基础，这部分代码看起来会比较轻松了，结构上基本相似。
直接进入 com.alibaba.nacos.api.naming.NamingService，里面有多个 registerInstance 重构方法，用于服务注册。
先看看 Instance 实体类包含的内容：id，ip，port，serviceName，clusterName（所在集群），weight（权重），healthy（是否正常），enabled（是否启用），ephemeral（是否是临时的），这 9 个属性全部都可以在 Console 中有所体现。
然后，直接看注册服务的方法：
@Override
public void registerInstance(String serviceName, String groupName, Instance instance) throws NacosException {if (instance.isEphemeral()) {BeatInfo beatInfo = new BeatInfo();
beatInfo.setServiceName(NamingUtils.getGroupedName(serviceName, groupName));
beatInfo.setIp(instance.getIp());
beatInfo.setPort(instance.getPort());
beatInfo.setCluster(instance.getClusterName());
beatInfo.setWeight(instance.getWeight());
beatInfo.setMetadata(instance.getMetadata());
beatInfo.setScheduled(false);
beatReactor.addBeatInfo(NamingUtils.getGroupedName(serviceName, groupName), beatInfo);
}
serverProxy.registerService(NamingUtils.getGroupedName(serviceName, groupName), groupName, instance);
}前面一大段代码是对临时服务实例的处理，就是在构造一个心跳包发送给 NACOS 服务。
registerService 方法就是封装了 HTTP 请求，最终在 InstanceController 中处理请求。
如果项目集成了 spring-cloud-starter-alibaba-nacos-discovery，服务启动后默认是自动注册的。如果想看自动注册的过程，可以从 AbstractAutoServiceRegistration 开始着手，当中有一段代码：
@EventListener(WebServerInitializedEvent.class)
public void bind(WebServerInitializedEvent event) {ApplicationContext context = event.getApplicationContext();
if (context instanceof ConfigurableWebServerApplicationContext) {
if ("management".equals(((ConfigurableWebServerApplicationContext) context).getServerNamespace())) {return;}
}
this.port.compareAndSet(0, event.getWebServer().getPort());
this.start();}监听了 Web 服务初始化完成的事件，最终会执行 start 方法：
public void start() {if (!isEnabled()) {if (logger.isDebugEnabled()) {logger.debug("Discovery Lifecycle disabled. Not starting");
}
return;
}
// only initialize if nonSecurePort is greater than 0 and it isn't already running
// because of containerPortInitializer below
if (!this.running.get()) {register();
if (shouldRegisterManagement()) {registerManagement();
}
this.context.publishEvent(new InstanceRegisteredEvent<>(this, getConfiguration()));
this.running.compareAndSet(false, true);
}
}其中，register 方法就是最核心的部分了，来源于 NacosServiceRegistry 的实现：
@Override
public void register(NacosRegistration registration) {if (!registration.isRegisterEnabled()) {logger.info("Nacos Registration is disabled...");
return;
}
if (StringUtils.isEmpty(registration.getServiceId())) {logger.info("No service to register for nacos client...");
return;
}
NamingService namingService = registration.getNacosNamingService();
String serviceId = registration.getServiceId();
Instance instance = new Instance();
instance.setIp(registration.getHost());
instance.setPort(registration.getPort());
instance.setWeight(registration.getRegisterWeight());
instance.setClusterName(registration.getCluster());
instance.setMetadata(registration.getMetadata());
try {namingService.registerInstance(serviceId, instance);
logger.info("nacos registry, {} {}:{} register finished", serviceId, instance.getIp(), instance.getPort());
}catch (Exception e) {logger.error("nacos registry, {} register failed...{},", serviceId, registration.toString(), e);
}
}这段代码就非常熟悉了，最终就回到了上述的 namingService.registerInstance 方法。
/**
* Map<namespace, Map<group::serviceName, Service>>
*/
private Map<String, Map<String, Service>> serviceMap = new ConcurrentHashMap<>();以上出现了另外一个实体类：com.alibaba.nacos.naming.core.Service，Service 是包含了 Instance，一个 Service 下有多个 Instance，即可组成一个 Cluster。
在调用 registerInstance 注册实例的时候，如果发现对应的 Service 没有被注册，那么会 registerService，并且会初始化对应的 Cluster，启动健康检查的定时器。
和 registerInstance 相反的是 deregisterInstance，即为取消注册，也可以认为是服务实例下线。
最后来看看 NACOS 如何实现服务发现功能。
从消费者（调用方）的角度来看，集成的 starter 项目中有个类：NacosServerList，最重要的是继承了 AbstractServerList，实现了两个关键的接口方法，相当于是 NACOS 与 Ribbon 的对接点。
public interface ServerList<T extends Server> {public List<T> getInitialListOfServers();
/**
* Return updated list of servers. This is called say every 30 secs
* (configurable) by the Loadbalancer's Ping cycle
*
*/
public List<T> getUpdatedListOfServers();}NACOS 对于这个两个接口的实现，都使用了 getServers 方法，而进入到 getServers 方法体里面，其实就是利用了上述所说的 NacosNamingService.selectInstances 方法，通过 serviceId 获取到 ServiceInfo 对象，然后获取到 Service 下面的所有有效的 Instance。
从提供者（被调用方）的角度看，NACOS 是通过定时器来实时更新 ServiceInfo，主要业务逻辑是在 HostReactor 中实现的。与前述的 serviceMap 不一样，HostReactor 中维护的是 serviceInfoMap。
private Map<String, ServiceInfo> serviceInfoMap;
HostReactor 借助了 FailoverReactor 对 ServiceInfo 做了磁盘缓存，仍然是启动了定时任务，在指定的目录下序列化 ServiceInfo，以此实现了 Failover 机制。而启动 failover-mode 也是有开关的，其实就是一个特定文件的一部分内容，这些配置的监测也是通过定时任务来实现的。
File switchFile = new File(failoverDir + UtilAndComs.FAILOVER_SWITCH);整个过程如下图所示：
四、管理控制台 (Console)
这一部分是管理控制台的实现，其实是一个非常典型的 WEB 项目。
使用了 Spring Security + JWT 进行安全控制，前端技术是 ReactJs，利用 JdbcTemplate 进行数据库持久化。
需要注意的是，控制台提供的功能并不都是从 nacos-console 这个服务中获取的数据，而是分散在了各个服务中。
nacos-console 提供了控制台登录，namespace 管理，控制台服务状态这三部分能力，而配置管理和服务管理分别请求的是 nacos-config 和 nacos-naming 所提供的 API，而这些 API 就是官网所提到的 Open-API。
五、总结
NACOS 相关源码通俗易懂，没有什么高深的理念，也没有进行层层封装和包裹，有一定编程经验的程序员能在半小时之内把握整个项目的脉络。
当然，也会存在一些不可忽视的缺点，比如，注释过少，代码还有很大的重构空间，tenant 和 namespace 两个概念混淆使用。
关于 Spring Cloud Alibaba Nacos 的介绍到此就结束了，希望对你有所帮助。
