文章目录

前言确定前端路由CatalogController.listDetail()ServiceManager总结

前文我们分析了Nacos中客户端注册时数据分发的设计链路#xff0c;本文根据Nacos前端页面请求#xff0c;看下前端页面中的服务列表的数据源于哪里。

确定前端…本文收录于专栏

前言确定前端路由CatalogController.listDetail()ServiceManager总结

前文我们分析了Nacos中客户端注册时数据分发的设计链路本文根据Nacos前端页面请求看下前端页面中的服务列表的数据源于哪里。

确定前端路由

我们已经向Nacos中注册了一个服务现在去前端确定查询的路由是什么

确定前端请求路由/nacos/v1/ns/catalog/services

package

com.alibaba.nacos.naming.controllers;

CatalogController.listDetail()CatalogController.listDetail()

/***

listDetail(RequestParam(required

false)

withInstances,RequestParam(defaultValue

Constants.DEFAULT_NAMESPACE_ID)

String

namespaceId,RequestParam(required

false)

containedInstance,RequestParam(required

false)

{//前端withInstances传的是false,不走这个分支if

(withInstances)

judgeCatalogService().pageListServiceDetail(namespaceId,

groupName,

pageSize);}//确定是走的这里获取的服务列表return

judgeCatalogService().pageListService(namespaceId,

groupName,

}查看judgeCatalogService().pageListService(namespaceId,

groupName,

JacksonUtils.createEmptyJsonNode();ListServiceView

serviceViews

LinkedList();//获取服务列表CollectionService

services

serviceStorage.getData(each).ipCount()).collect(Collectors.toList());}result.put(FieldsConstants.COUNT,

doPage(services,

metadataManager.getServiceMetadata(each).orElseGet(ServiceMetadata::new);ServiceView

serviceView

ServiceView();serviceView.setName(each.getName());serviceView.setGroupName(each.getGroup());serviceView.setClusterCount(serviceStorage.getClusters(each).size());serviceView.setIpCount(serviceStorage.getData(each).ipCount());serviceView.setHealthyInstanceCount(countHealthyInstance(serviceStorage.getData(each)));serviceView.setTriggerFlag(isProtectThreshold(serviceView,

serviceMetadata)

false);serviceViews.add(serviceView);}result.set(FieldsConstants.SERVICE_LIST,

JacksonUtils.transferToJsonNode(serviceViews));return

result;

StringUtils.isBlank(serviceName)

(noFilter)

{//我们前端默认传的这两个参数都是空所以会走这里的逻辑return

ServiceManager.getInstance().getSingletons(namespaceId);}CollectionService

result

StringJoiner(Constants.SERVICE_INFO_SPLITER);regex.add(getRegexString(group));regex.add(getRegexString(serviceName));String

regexString

ServiceManager.getInstance().getSingletons(namespaceId))

{if

(each.getGroupedServiceName().matches(regexString))

result;

}ServiceManager.getInstance()这里一看就是一个经典的单例写法那我们接下来把精力放到getSingletons这个方法上。

ServiceManager

namespaceSingletonMaps.getOrDefault(namespace,

new

}通过代码我们发现获取制定namespace下的服务是从一个map中获取的。

/***

}我们可以发现ServiceManager这个类是一个单例模式的实现其中维护了两个map其中一个namespaceSingletonMaps用于存放制定namespace下的服务那么这个map中的数据是在什么时机存放进去的呢

/**1.

{singletonRepository.computeIfAbsent(service,

key

MetadataEvent.ServiceMetadataEvent(service,

false));return

singletonRepository.get(service);namespaceSingletonMaps.computeIfAbsent(result.getNamespace(),

namespace

ConcurrentHashSet());namespaceSingletonMaps.get(result.getNamespace()).add(result);return

result;

}观察代码我们发现往map中写数据的只有这一个方法那么这个方法是在什么时机被调用的呢

InstanceRequestHandler接收所有实例注册、注销相关的请求InstanceRequestHandler处理注册请求时会调用EphemeralClientOperationServiceImpl中的registerInstance方法registerInstance方法中除了我们之前讲的发布客户端服务注册事件ClientOperationEvent.ClientRegisterServiceEvent之外还会往ServiceManager中的map添加数据

registerInstance方法对ServiceManager的处理逻辑如下

Service

ServiceManager.getInstance().getSingleton(service);总结

通过以上梳理我们知道了前端服务列表中获取的数据是源于ServiceManager类中一个map的缓存缓存中的数据是在客户端服务注册时添加进去的。