從實現(xiàn)原理來講，Nacos 為什么這么強？
今天來分享一下Nacos注冊中心的底層原理，從服務(wù)注冊到服務(wù)發(fā)現(xiàn)，非常細致
一、 Nacos介紹
再講Nacos之前，先來講一下服務(wù)注冊和發(fā)現(xiàn)。我們知道，現(xiàn)在微服務(wù)架構(gòu)是目前開發(fā)的一個趨勢。服務(wù)消費者要去調(diào)用多個服務(wù)提供者組成的集群。這里需要做到以下幾點：
- 服務(wù)消費者需要在本地配置文件中維護服務(wù)提供者集群的每個節(jié)點的請求地址。
- 服務(wù)提供者集群中如果某個節(jié)點宕機，服務(wù)消費者的本地配置中需要同步刪除這個節(jié)點的請求地址，防止請求發(fā)送到已經(jīng)宕機的節(jié)點上造成請求失敗。
因此需要引入服務(wù)注冊中心，它具有以下幾個功能：
- 服務(wù)地址的管理。
- 服務(wù)注冊。
- 服務(wù)動態(tài)感知。
而Nacos致力于解決微服務(wù)中的統(tǒng)一配置，服務(wù)注冊和發(fā)現(xiàn)等問題。Nacos集成了注冊中心和配置中心。其相關(guān)特性包括：
- 服務(wù)發(fā)現(xiàn)和服務(wù)健康監(jiān)測
Nacos支持基于DNS和RPC的服務(wù)發(fā)現(xiàn)，即服務(wù)消費者可以使用DNS或者HTTP的方式來查找和發(fā)現(xiàn)服務(wù)。Nacos提供對服務(wù)的實時的健康檢查，阻止向不健康的主機或者服務(wù)實例發(fā)送請求。Nacos支持傳輸層（Ping/TCP）、應(yīng)用層（HTTP、Mysql）的健康檢查。
- 動態(tài)配置服務(wù)
動態(tài)配置服務(wù)可以以中心化、外部化和動態(tài)化的方式管理所有環(huán)境的應(yīng)用配置和服務(wù)配置。
- 動態(tài)DNS服務(wù)
支持權(quán)重路由，讓開發(fā)者更容易的實現(xiàn)中間層的負載均衡、更靈活的路由策略、流量控制以及DNS解析服務(wù)。
- 服務(wù)和元數(shù)據(jù)管理
Nacos允許開發(fā)者從微服務(wù)平臺建設(shè)的視角來管理數(shù)據(jù)中心的所有服務(wù)和元數(shù)據(jù)。如：服務(wù)的生命周期、靜態(tài)依賴分析、服務(wù)的健康狀態(tài)、服務(wù)的流量管理、路由和安全策略等。
二、Nacos注冊中心實現(xiàn)原理分析
2.1 Nacos架構(gòu)圖
以下是Nacos的架構(gòu)圖：
圖片
其中分為這么幾個模塊：
- Provider APP：服務(wù)提供者。
- Consumer APP：服務(wù)消費者。
- Name Server：通過Virtual IP或者DNS的方式實現(xiàn)Nacos高可用集群的服務(wù)路由。
- Nacos Server：Nacos服務(wù)提供者。
OpenAPI：功能訪問入口。
Config Service、Naming Service：Nacos提供的配置服務(wù)、名字服務(wù)模塊。
Consistency Protocol：一致性協(xié)議，用來實現(xiàn)Nacos集群節(jié)點的數(shù)據(jù)同步，使用Raft算法實現(xiàn)。
其中包含：
- Nacos Console：Nacos控制臺。
小總結(jié)：
- 服務(wù)提供者通過VIP（Virtual IP）訪問Nacos Server高可用集群，基于OpenAPI完成服務(wù)的注冊和服務(wù)的查詢。
- Nacos Server的底層則通過數(shù)據(jù)一致性算法（Raft）來完成節(jié)點的數(shù)據(jù)同步。
2.2 注冊中心的原理
這里對其原理做一個大致的介紹，在后文則從源碼角度進行分析。
首先，服務(wù)注冊的功能體現(xiàn)在：
- 服務(wù)實例啟動時注冊到服務(wù)注冊表、關(guān)閉時則注銷（服務(wù)注冊）。
- 服務(wù)消費者可以通過查詢服務(wù)注冊表來獲得可用的實例（服務(wù)發(fā)現(xiàn)）。
- 服務(wù)注冊中心需要調(diào)用服務(wù)實例的健康檢查API來驗證其是否可以正確的處理請求（健康檢查）。
Nacos服務(wù)注冊和發(fā)現(xiàn)的實現(xiàn)原理的圖如下：
圖片
三、Nacos源碼分析
前提（在本地或者虛機上先啟動好Nacos）這一部分從2個角度來講Nacos是如何實現(xiàn)的：
- 服務(wù)注冊。
- 服務(wù)發(fā)現(xiàn)
3.1 Nacos服務(wù)注冊
首先看下一個包：spring-cloud-commons
圖片
這個ServiceRegistry接口是SpringCloud提供的服務(wù)注冊的標準，集成到SpringCloud中實現(xiàn)服務(wù)注冊的組件，都需要實現(xiàn)這個接口。來看下它的結(jié)構(gòu)：
public interface ServiceRegistry<R extends Registration> {
void register(R registration);
void deregister(R registration);
void close();
void setStatus(R registration, String status);
<T> T getStatus(R registration);
}那么對于Nacos而言，該接口的實現(xiàn)類是NacosServiceRegistry，該類在這個pom包下：
圖片
再回過頭來看spring-cloud-commons包:
圖片
spring.factories主要是包含了自動裝配的配置信息，如圖：
圖片
在我之前的文章里我有提到過，在spring.factories中配置EnableAutoConfiguration的內(nèi)容后，項目在啟動的時候，會導(dǎo)入相應(yīng)的自動配置類，那么也就允許對該類的相關(guān)屬性進行一個自動裝配。那么顯然，在這里導(dǎo)入了AutoServiceRegistrationAutoConfiguration這個類，而這個類顧名思義是服務(wù)注冊相關(guān)的配置類。
該類的完整代碼如下：
@Configuration(
proxyBeanMethods = false
)
@Import({AutoServiceRegistrationConfiguration.class})
@ConditionalOnProperty(
value = {"spring.cloud.service-registry.auto-registration.enabled"},
matchIfMissing = true
)
public class AutoServiceRegistrationAutoConfiguration {
@Autowired(
required = false
)
private AutoServiceRegistration autoServiceRegistration;
@Autowired
private AutoServiceRegistrationProperties properties;
public AutoServiceRegistrationAutoConfiguration() {
}
@PostConstruct
protected void init() {
if (this.autoServiceRegistration == null && this.properties.isFailFast()) {
throw new IllegalStateException("Auto Service Registration has been requested, but there is no AutoServiceRegistration bean");
}
}
}這里做一個分析，AutoServiceRegistrationAutoConfiguration中注入了AutoServiceRegistration實例，該類的關(guān)系圖如下：
圖片
我們先來看一下這個抽象類AbstractAutoServiceRegistration：
public abstract class AbstractAutoServiceRegistration<R extends Registration> implements AutoServiceRegistration,
ApplicationContextAware,
ApplicationListener<WebServerInitializedEvent> {
public void onApplicationEvent(WebServerInitializedEvent event) {
this.bind(event);
}
}這里實現(xiàn)了ApplicationListener接口，并且傳入了WebServerInitializedEvent作為泛型，啥意思嘞，意思是：
- NacosAutoServiceRegistration監(jiān)聽WebServerInitializedEvent事件。
- 也就是WebServer初始化完成后，會調(diào)用對應(yīng)的事件綁定方法，調(diào)用onApplicationEvent（），該方法最終調(diào)用NacosServiceRegistry的register（）方法（NacosServiceRegistry實現(xiàn)了Spring的一個服務(wù)注冊標準接口）。
對于register（）方法，主要調(diào)用的是Nacos Client SDK中的NamingService下的registerInstance（）方法完成服務(wù)的注冊。
public void register(Registration registration) {
if (StringUtils.isEmpty(registration.getServiceId())) {
log.warn("No service to register for nacos client...");
} else {
String serviceId = registration.getServiceId();
String group = this.nacosDiscoveryProperties.getGroup();
Instance instance = this.getNacosInstanceFromRegistration(registration);
try {
this.namingService.registerInstance(serviceId, group, instance);
log.info("nacos registry, {} {} {}:{} register finished", new Object[]{group, serviceId, instance.getIp(), instance.getPort()});
} catch (Exception var6) {
log.error("nacos registry, {} register failed...{},", new Object[]{serviceId, registration.toString(), var6});
ReflectionUtils.rethrowRuntimeException(var6);
}
}
}
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);
long instanceInterval = instance.getInstanceHeartBeatInterval();
beatInfo.setPeriod(instanceInterval == 0L ? DEFAULT_HEART_BEAT_INTERVAL : instanceInterval);
// 1.addBeatInfo（）負責創(chuàng)建心跳信息實現(xiàn)健康監(jiān)測。因為Nacos Server必須要確保注冊的服務(wù)實例是健康的。
// 而心跳監(jiān)測就是服務(wù)健康監(jiān)測的一種手段。
this.beatReactor.addBeatInfo(NamingUtils.getGroupedName(serviceName, groupName), beatInfo);
}
// 2.registerService（）實現(xiàn)服務(wù)的注冊
this.serverProxy.registerService(NamingUtils.getGroupedName(serviceName, groupName), groupName, instance);
}再來看一下心跳監(jiān)測的方法addBeatInfo（）：
public void addBeatInfo(String serviceName, BeatInfo beatInfo) {
LogUtils.NAMING_LOGGER.info("[BEAT] adding beat: {} to beat map.", beatInfo);
String key = this.buildKey(serviceName, beatInfo.getIp(), beatInfo.getPort());
BeatInfo existBeat = null;
if ((existBeat = (BeatInfo)this.dom2Beat.remove(key)) != null) {
existBeat.setStopped(true);
}
this.dom2Beat.put(key, beatInfo);
// 通過schedule（）方法，定時的向服務(wù)端發(fā)送一個數(shù)據(jù)包，然后啟動一個線程不斷地檢測服務(wù)端的回應(yīng)。
// 如果在指定的時間內(nèi)沒有收到服務(wù)端的回應(yīng)，那么認為服務(wù)器出現(xiàn)了故障。
// 參數(shù)1：可以說是這個實例的相關(guān)信息。
// 參數(shù)2：一個long類型的時間，代表從現(xiàn)在開始推遲執(zhí)行的時間，默認是5000
// 參數(shù)3：時間的單位，默認是毫秒，結(jié)合5000即代表每5秒發(fā)送一次心跳數(shù)據(jù)包
this.executorService.schedule(new BeatReactor.BeatTask(beatInfo), beatInfo.getPeriod(), TimeUnit.MILLISECONDS);
MetricsMonitor.getDom2BeatSizeMonitor().set((double)this.dom2Beat.size());
}心跳檢查如果正常，即代表這個需要注冊的服務(wù)是健康的，那么執(zhí)行下面的注冊方法registerInstance（）：
public void registerService(String serviceName, String groupName, Instance instance) throws NacosException {
LogUtils.NAMING_LOGGER.info("[REGISTER-SERVICE] {} registering service {} with instance: {}", new Object[]{this.namespaceId, serviceName, instance});
Map<String, String> params = new HashMap(9);
params.put("namespaceId", this.namespaceId);
params.put("serviceName", serviceName);
params.put("groupName", groupName);
params.put("clusterName", instance.getClusterName());
params.put("ip", instance.getIp());
params.put("port", String.valueOf(instance.getPort()));
params.put("weight", String.valueOf(instance.getWeight()));
params.put("enable", String.valueOf(instance.isEnabled()));
params.put("healthy", String.valueOf(instance.isHealthy()));
params.put("ephemeral", String.valueOf(instance.isEphemeral()));
params.put("metadata", JSON.toJSONString(instance.getMetadata()));
// 這里可以看出來，把上述服務(wù)實例的一些必要參數(shù)保存到一個Map中，通過OpenAPI的方式發(fā)送注冊請求
this.reqAPI(UtilAndComs.NACOS_URL_INSTANCE, params, (String)"POST");
}下面直接Debug走一遍。兩個前提（這里不再展開）：
- 啟動一個Nacos服務(wù)。
- 搞一個Maven項目，集成Nacos。
案例1：用Debug來理解Nacos服務(wù)注冊流程
1.項目初始化后，根據(jù)上文說法，會執(zhí)行抽象類AbstractAutoServiceRegistration下面的onApplicationEvent（）方法，即事件被監(jiān)聽到。
圖片
2.作為抽象類的子類實現(xiàn)NacosAutoServiceRegistration，監(jiān)聽到Web服務(wù)啟動后， 開始執(zhí)行super.register（）方法。
圖片
3.執(zhí)行NacosServiceRegistry下的register（）方法（super），前面說過，集成到SpringCloud中實現(xiàn)服務(wù)注冊的組件，都需要實現(xiàn)ServiceRegistry這個接口，而對于Nacos而言，NacosServiceRegistry就是具體的實現(xiàn)子類。執(zhí)行注冊方法需要傳入的三個參數(shù)：
- 實例名稱serviceId。
- 實例歸屬的組。
- 具體實例
圖片
而registerInstance（）主要做兩件事：
- 檢查服務(wù)的健康（this.beatReactor.addBeatInfo（））。
- 執(zhí)行服務(wù)的注冊（this.serverProxy.registerService（））。
圖片
服務(wù)健康的檢查：
圖片
檢查通過后，發(fā)送OpenAPI進行服務(wù)的注冊：
圖片
服務(wù)注冊小總結(jié)☆：
這里來做一個大框架式的梳理（也許前面寫的有點亂，這里通過幾個問答的形式來進行總結(jié)）
問題1：Nacos的服務(wù)注冊為什么和spring-cloud-commons這個包扯上關(guān)系？
回答：
1.首先，Nacos的服務(wù)注冊肯定少不了pom包：spring-cloud-starter-alibaba-nacos-discovery吧。
2.這個包下面包括了spring-cloud-commons包，那么這個包有什么用？
3.spring-cloud-commons中有一個接口叫做ServiceRegistry，而集成到SpringCloud中實現(xiàn)服務(wù)注冊的組件，都需要實現(xiàn)這個接口。
4.因此對于需要注冊到Nacos上的服務(wù)，也需要實現(xiàn)這個接口，那么具體的實現(xiàn)子類為NacosServiceRegistry。
問題2：為什么我的項目加了這幾個依賴，服務(wù)啟動時依舊沒有注冊到Nacos中？
回答：
1.本文提到過，進行Nacos服務(wù)注冊的時候，會有一個事件的監(jiān)聽過程，而監(jiān)聽的對象是WebServer，因此，這個項目需要是一個Web項目！
2.因此查看你的pom文件中是否有依賴：spring-boot-starter-web。
問題3：除此之外，spring-cloud-commons這個包還有什么作用？
回答：
1.這個包下的spring.factories文件中，配置了相關(guān)的服務(wù)注冊的置類，即支持其自動裝配。
2.這個配置類叫做AutoServiceRegistrationAutoConfiguration。其注入了類AutoServiceRegistration，而NacosAutoServiceRegistration是該類的一個具體實現(xiàn)。
3.當WebServer初始化的時候，通過綁定的事件監(jiān)聽器，會實現(xiàn)監(jiān)聽，執(zhí)行服務(wù)的注冊邏輯。
說白了：
- 第一件事情：引入一個Spring監(jiān)聽器，當容器初始化后，執(zhí)行Nacos服務(wù)的注冊。
- 第二件事情：而Nacos服務(wù)注冊的方法的實現(xiàn)，其需要實現(xiàn)的接口來自于該包下的ServiceRegistry接口。
接下來就對Nacos注冊的流程進行一個總結(jié)：
- 服務(wù)（項目）啟動時，根據(jù)spring-cloud-commons中spring.factories的配置，自動裝配了類AutoServiceRegistrationAutoConfiguration。
- AutoServiceRegistrationAutoConfiguration類中注入了類AutoServiceRegistration，其最終實現(xiàn)子類實現(xiàn)了Spring的監(jiān)聽器。
- 根據(jù)監(jiān)聽器，執(zhí)行了服務(wù)注冊方法。而這個服務(wù)注冊方法則是調(diào)用了NacosServiceRegistry的register（）方法。
- 該方法主要調(diào)用的是Nacos Client SDK中的NamingService下的registerInstance（）方法完成服務(wù)的注冊。
- registerInstance（）方法主要做兩件事：服務(wù)實例的健康監(jiān)測和實例的注冊。
- 通過schedule（）方法定時的發(fā)送數(shù)據(jù)包，檢測實例的健康。
- 若健康監(jiān)測通過，調(diào)用registerService（）方法，通過OpenAPI方式執(zhí)行服務(wù)注冊，其中將實例Instance的相關(guān)信息存儲到HashMap中。
3.2 Nacos服務(wù)發(fā)現(xiàn)
有一點我們需要清楚：Nacos服務(wù)的發(fā)現(xiàn)發(fā)生在什么時候。例如：微服務(wù)發(fā)生遠程接口調(diào)用的時候。一般我們在使用OpenFeign進行遠程接口調(diào)用時，都需要用到對應(yīng)的微服務(wù)名稱，而這個名稱就是用來進行服務(wù)發(fā)現(xiàn)的。
舉個例子：
@FeignClient("test-application")
public interface MyFeignService {
@RequestMapping("getInfoById")
R info(@PathVariable("id") Long id);
}接下來直接開始講重點，Nacos在進行服務(wù)發(fā)現(xiàn)的時候，會調(diào)用NacosServerList類下的getServers()方法：
public class NacosServerList extends AbstractServerList<NacosServer> {
private List<NacosServer> getServers() {
try {
String group = this.discoveryProperties.getGroup();
// 1.通過唯一的serviceId（一般是服務(wù)名稱）和組來獲得對應(yīng)的所有實例。
List<Instance> instances = this.discoveryProperties.namingServiceInstance().selectInstances(this.serviceId, group, true);
// 2.將List<Instance>轉(zhuǎn)換成List<NacosServer>數(shù)據(jù)，然后返回。
return this.instancesToServerList(instances);
} catch (Exception var3) {
throw new IllegalStateException("Can not get service instances from nacos, serviceId=" + this.serviceId, var3);
}
}
}接下來來看一下NacosNamingService.selectInstances（）方法：
public List<Instance> selectInstances(String serviceName, String groupName, boolean healthy) throws NacosException {
return this.selectInstances(serviceName, groupName, healthy, true);
}該方法最終會調(diào)用到其重載方法：
public List<Instance> selectInstances(String serviceName, String groupName, List<String> clusters,
boolean healthy, boolean subscribe) throws NacosException {
// 保存服務(wù)實例信息的對象
ServiceInfo serviceInfo;
// 如果該消費者訂閱了這個服務(wù)，那么會在本地維護一個服務(wù)列表，服務(wù)從本地獲取
if (subscribe) {
serviceInfo = this.hostReactor.getServiceInfo(NamingUtils.getGroupedName(serviceName, groupName), StringUtils.join(clusters, ","));
} else {
// 否則實例會從服務(wù)中心進行獲取。
serviceInfo = this.hostReactor.getServiceInfoDirectlyFromServer(NamingUtils.getGroupedName(serviceName, groupName), StringUtils.join(clusters, ","));
}
return this.selectInstances(serviceInfo, healthy);
}這里應(yīng)該重點關(guān)注this.hostReactor這個對象，它里面比較重要的是幾個Map類型的存儲結(jié)構(gòu)：
public class HostReactor {
private static final long DEFAULT_DELAY = 1000L;
private static final long UPDATE_HOLD_INTERVAL = 5000L;
// 存放線程異步調(diào)用的一個回調(diào)結(jié)果
private final Map<String, ScheduledFuture<?>> futureMap;
// 本地已存在的服務(wù)列表，key是服務(wù)名稱，value是ServiceInfo
private Map<String, ServiceInfo> serviceInfoMap;
// 待更新的實例列表
private Map<String, Object> updatingMap;
// 定時任務(wù)（負責服務(wù)列表的實時更新）
private ScheduledExecutorService executor;
....
}再看一看它的getServiceInfo（）方法：
public ServiceInfo getServiceInfo(String serviceName, String clusters) {
LogUtils.NAMING_LOGGER.debug("failover-mode: " + this.failoverReactor.isFailoverSwitch());
String key = ServiceInfo.getKey(serviceName, clusters);
if (this.failoverReactor.isFailoverSwitch()) {
return this.failoverReactor.getService(key);
} else {
// 1.先通過serverName即服務(wù)名獲得一個serviceInfo
ServiceInfo serviceObj = this.getServiceInfo0(serviceName, clusters);
// 如果沒有serviceInfo，則通過傳進來的參數(shù)new出一個新的serviceInfo對象，并且同時維護到本地Map和更新Map
// 這里是serviceInfoMap和updatingMap
if (null == serviceObj) {
serviceObj = new ServiceInfo(serviceName, clusters);
this.serviceInfoMap.put(serviceObj.getKey(), serviceObj);
this.updatingMap.put(serviceName, new Object());
// 2.updateServiceNow（），立刻去Nacos服務(wù)端拉去數(shù)據(jù)。
this.updateServiceNow(serviceName, clusters);
this.updatingMap.remove(serviceName);
} else if (this.updatingMap.containsKey(serviceName)) {
synchronized(serviceObj) {
try {
serviceObj.wait(5000L);
} catch (InterruptedException var8) {
LogUtils.NAMING_LOGGER.error("[getServiceInfo] serviceName:" + serviceName + ", clusters:" + clusters, var8);
}
}
}
// 3.定時更新實例信息
this.scheduleUpdateIfAbsent(serviceName, clusters);
// 最后返回服務(wù)實例數(shù)據(jù)（前面已經(jīng)進行了更新）
return (ServiceInfo)this.serviceInfoMap.get(serviceObj.getKey());
}
}來看下scheduleUpdateIfAbsent（）方法：
// 通過心跳的方式，每10秒去更新一次數(shù)據(jù)，并不是只有在調(diào)用服務(wù)的時候才會進行更新，而是通過定時任務(wù)來異步進行。
public void scheduleUpdateIfAbsent(String serviceName, String clusters) {
if (this.futureMap.get(ServiceInfo.getKey(serviceName, clusters)) == null) {
synchronized(this.futureMap) {
if (this.futureMap.get(ServiceInfo.getKey(serviceName, clusters)) == null) {
// 創(chuàng)建一個UpdateTask的更新線程任務(wù)，每10秒去異步更新集合數(shù)據(jù)
ScheduledFuture<?> future = this.addTask(new HostReactor.UpdateTask(serviceName, clusters));
this.futureMap.put(ServiceInfo.getKey(serviceName, clusters), future);
}
}
}
}案例2：用Debug來理解Nacos服務(wù)發(fā)現(xiàn)流程
1.進行遠程接口調(diào)用，觸發(fā)服務(wù)的發(fā)現(xiàn)，調(diào)用NacosServerList的getServers（）方法。傳入的serviceId和對應(yīng)Feign接口上的接口@FeignClient中的名稱一致。
圖片
例如，我這里調(diào)用的Feign接口是：
@FeignClient("gulimall-member")
public interface MemberFeignService {
@RequestMapping("/member/member/info/{id}")
R info(@PathVariable("id") Long id);
}這里可以看出來，返回的是一個Instance類型的List，對應(yīng)的服務(wù)也發(fā)現(xiàn)并返回了。
圖片
2.這里則調(diào)用了NacosNamingService的selectInstances（）方法，我這里的subscribe值是true，即代表我這個消費者直接訂閱了這個服務(wù)，因此最終的信息是從本地Map中獲取，即Nacos維護了一個注冊列表。
圖片
3.再看下HostReactor的getServiceInfo（）方法：最終所需要的結(jié)果是從serviceInfoMap中獲取，并且通過多個Map進行維護服務(wù)實例，若存在數(shù)據(jù)的變化，還會通過強制睡眠5秒鐘的方式來等待數(shù)據(jù)的更新。
圖片
4.無論怎樣都會調(diào)用this.scheduleUpdateIfAbsent(serviceName, clusters)方法：
圖片
5.通過scheduleUpdateIfAbsent（）方法定時的獲取實時的實例數(shù)據(jù)，并且負責維護本地的服務(wù)注冊列表，若服務(wù)發(fā)生更新，則更新本地的服務(wù)數(shù)據(jù)。
圖片
服務(wù)發(fā)現(xiàn)小總結(jié)☆：
經(jīng)常有人說過，Nacos有個好處，就是當一個服務(wù)掛了之后，短時間內(nèi)不會造成影響，因為有個本地注冊列表，在服務(wù)不更新的情況下，服務(wù)還能夠正常的運轉(zhuǎn)，其原因如下：
- Nacos的服務(wù)發(fā)現(xiàn)，一般是通過訂閱的形式來獲取服務(wù)數(shù)據(jù)。
- 而通過訂閱的方式，則是從本地的服務(wù)注冊列表中獲取（可以理解為緩存）。相反，如果不訂閱，那么服務(wù)的信息將會從Nacos服務(wù)端獲取，這時候就需要對應(yīng)的服務(wù)是健康的。（宕機就不能使用了）
- 在代碼設(shè)計上，通過Map來存放實例數(shù)據(jù)，key為實例名稱，value為實例的相關(guān)信息數(shù)據(jù)（ServiceInfo對象）。
最后，服務(wù)發(fā)現(xiàn)的流程就是：
- 以調(diào)用遠程接口（OpenFeign）為例，當執(zhí)行遠程調(diào)用時，需要經(jīng)過服務(wù)發(fā)現(xiàn)的過程。
- 服務(wù)發(fā)現(xiàn)先執(zhí)行NacosServerList類中的getServers()方法，根據(jù)遠程調(diào)用接口上@FeignClient中的屬性作為serviceId傳入NacosNamingService.selectInstances（）方法中進行調(diào)用。
- 根據(jù)subscribe的值來決定服務(wù)是從本地注冊列表中獲取還是從Nacos服務(wù)端中獲取。
- 以本地注冊列表為例，通過調(diào)用HostReactor.getServiceInfo（）來獲取服務(wù)的信息（serviceInfo），Nacos本地注冊列表由3個Map來共同維護。
本地Map–>serviceInfoMap，
更新Map–>updatingMap
異步更新結(jié)果Map–>futureMap,
最終的結(jié)果從serviceInfoMap當中獲取。
- HostReactor類中的getServiceInfo（）方法通過this.scheduleUpdateIfAbsent() 方法和updateServiceNow（）方法實現(xiàn)服務(wù)的定時更新和立刻更新。
- 而對于scheduleUpdateIfAbsent（）方法，則通過線程池來進行異步的更新，將回調(diào)的結(jié)果（Future）保存到futureMap中，并且發(fā)生提交線程任務(wù)時，還負責更新本地注冊列表中的數(shù)據(jù)。
