文章目录
- nacos挂了之后服务会挂吗？不会挂（深入源码分析）
- 展开nacos客户端源码
- 找本地缓存配置相关文件
- 客户端内存缓存
- 客户端健康状态
- 获取配置的实现
nacos挂了之后服务会挂吗？不会挂（深入源码分析）
展开nacos客户端源码
看源码第一步找到maven依赖展开，看看文件夹、文件名，粗略过一遍有些啥文件
如果你有直接调用源码里的方法就直接通过方法进去看怎么实现的
如果没有直接用某个方法，那就去看目录、相关文件逐步分析理解。
找本地缓存配置相关文件
看到这个LocalConfig，本地配置，那进去看看
看类描述、类结构，可以看到类上写了就是为了在灾难发生时从本地恢复配置的工具，点进这个getFailoverFile方法看看
看完你就明白，nacos在你的机器用户空间目录里给你创建了nacos文件夹，下面有个config文件，把配置存储在这了，那这样的话即使你nacos挂了，他还能从内存、本地文件里去获取到配置，提高了可用性。那内存里的配置存哪里了呢，我们去看看其他文件
客户端内存缓存
客户端worker，那进去看看
有个getCache方法看看
方法名getCache，获取缓存的意思，源码实现是
return cacheMap.get(GroupKey.getKeyTenant(dataId, group, tenant));
一下就懂了把，ConcurrentHashMap<String, CacheData> cacheMap
这个key规则怎么生成的呢？看源码，其实就是直接拼接数据ID+分组+租户名 这样搞定了
客户端健康状态
额外顺便还看到了setHealthServer(boolean isHealthServer),设置服务器是否健康的方法，看下哪些地方调用了
你可以看到，这个地方去对服务发起请求之后，如果请求成功，就把nacos服务器状态设置为健康，否则设置为不健康。
还有getServerConfig方法，获取服务器配置,很核心的方法，我们看看怎么实现的
创建返回值、校验参数，构建请求参数，向nacos服务器发起http请求，处理相应数据
如果结果正常就保存快照，设置并返回响应，接口404的时候也一样保存快照返回响应，409请求冲突、403无权访问和其他未知情况就打印error日志抛异常，看着是不是觉得很简单，自己也能写一个nacos
public ConfigResponse getServerConfig(String dataId, String group, String tenant, long readTimeout)
throws NacosException {
ConfigResponse configResponse = new ConfigResponse();
if (StringUtils.isBlank(group)) {
group = Constants.DEFAULT_GROUP;
}
HttpRestResult<String> result = null;
try {
Map<String, String> params = new HashMap<String, String>(3);
if (StringUtils.isBlank(tenant)) {
params.put("dataId", dataId);
params.put("group", group);
} else {
params.put("dataId", dataId);
params.put("group", group);
params.put("tenant", tenant);
}
result = agent.httpGet(Constants.CONFIG_CONTROLLER_PATH, null, params, agent.getEncode(), readTimeout);
} catch (Exception ex) {
String message = String
.format("[%s] [sub-server] get server config exception, dataId=%s, group=%s, tenant=%s",
agent.getName(), dataId, group, tenant);
LOGGER.error(message, ex);
throw new NacosException(NacosException.SERVER_ERROR, ex);
}
switch (result.getCode()) {
case HttpURLConnection.HTTP_OK:
LocalConfigInfoProcessor.saveSnapshot(agent.getName(), dataId, group, tenant, result.getData());
configResponse.setContent(result.getData());
String configType;
if (result.getHeader().getValue(CONFIG_TYPE) != null) {
configType = result.getHeader().getValue(CONFIG_TYPE);
} else {
configType = ConfigType.TEXT.getType();
}
configResponse.setConfigType(configType);
String encryptedDataKey = result.getHeader().getValue(ENCRYPTED_DATA_KEY);
LocalEncryptedDataKeyProcessor
.saveEncryptDataKeySnapshot(agent.getName(), dataId, group, tenant, encryptedDataKey);
configResponse.setEncryptedDataKey(encryptedDataKey);
return configResponse;
case HttpURLConnection.HTTP_NOT_FOUND:
LocalConfigInfoProcessor.saveSnapshot(agent.getName(), dataId, group, tenant, null);
LocalEncryptedDataKeyProcessor.saveEncryptDataKeySnapshot(agent.getName(), dataId, group, tenant, null);
return configResponse;
case HttpURLConnection.HTTP_CONFLICT: {
LOGGER.error(
"[{}] [sub-server-error] get server config being modified concurrently, dataId={}, group={}, "
+ "tenant={}", agent.getName(), dataId, group, tenant);
throw new NacosException(NacosException.CONFLICT,
"data being modified, dataId=" + dataId + ",group=" + group + ",tenant=" + tenant);
}
case HttpURLConnection.HTTP_FORBIDDEN: {
LOGGER.error("[{}] [sub-server-error] no right, dataId={}, group={}, tenant={}", agent.getName(),
dataId, group, tenant);
throw new NacosException(result.getCode(), result.getMessage());
}
default: {
LOGGER.error("[{}] [sub-server-error] dataId={}, group={}, tenant={}, code={}", agent.getName(),
dataId, group, tenant, result.getCode());
throw new NacosException(result.getCode(),
"http error, code=" + result.getCode() + ",dataId=" + dataId + ",group=" + group + ",tenant="
+ tenant);
}
}
}
获取配置的实现
getConfig
先去查了nacos的系统变量
然后调了getLatestConfig获取最新配置方法，有多个实现，文件配置、nacos配置、springcloud配置、zookeeper配置等等，我们看nacos配置
优先去获取seeta的配置了，没有再去configService获取
getConfigInner，先读取了本地的配置，没有的话去读取nacos服务器的配置，读取失败的话就最后去读取快照里的
