门户网站建设所需条件,游戏开服网,管理咨询公司税收优惠,缔造自助建站Nacos客户端服务发现源码分析
总体流程
首先我们先通过一个图来直观的看一下#xff0c;Nacos客户端的服务发现#xff0c;其实就是封装参数、调用服务接口、获得返回实例列表。 但是如果我们要是细化这个流程#xff0c;会发现不仅包括了通过NamingService获取服务列表…Nacos客户端服务发现源码分析
总体流程
首先我们先通过一个图来直观的看一下Nacos客户端的服务发现其实就是封装参数、调用服务接口、获得返回实例列表。 但是如果我们要是细化这个流程会发现不仅包括了通过NamingService获取服务列表在获取服务列表的过程中还涉及到通信流程协议Http or gPRC、订阅流程、故障转移流程等。下面我们来详细的捋一捋。
入口其实这个入口我们在之前看过就在NamingTest中可以看到
public class NamingTest {Testpublic void testServiceList() throws Exception {......NamingService namingService NacosFactory.createNamingService(properties);namingService.registerInstance(nacos.test.1, instance);ThreadUtils.sleep(5000L);ListInstance list namingService.getAllInstances(nacos.test.1);System.out.println(list);}
} 在这里我们主要要关注getAllInstances方法那我们就需要看一下这个方法的具体操作当然这其中需要经过一系列的重载方法调用
其实这里的方法比入口多出了几个参数这里不仅有服务名称还有分组名、集群列表、是否订阅重载方法中的其他参数已经在各种重载方法的调用过程中设置了默认值比如
分组名称默认DEFAULT_GROUOP
集群列表默认为空数组
是否订阅订阅
Override
public ListInstance getAllInstances(String serviceName, String groupName, ListString clusters,boolean subscribe) throws NacosException {ServiceInfo serviceInfo;String clusterString StringUtils.join(clusters, ,);// 是否是订阅模式if (subscribe) {// 先从客户端缓存获取服务信息serviceInfo serviceInfoHolder.getServiceInfo(serviceName, , clusterString);if (null serviceInfo) {// 如果本地缓存不存在服务信息则进行订阅serviceInfo clientProxy.subscribe(serviceName, groupName, clusterString);}} else {// 如果未订阅服务信息则直接从服务器进行查询serviceInfo clientProxy.queryInstancesOfService(serviceName, groupName, clusterString, 0, false);}// 从服务信息中获取实例列表ListInstance list;if (serviceInfo null || CollectionUtils.isEmpty(list serviceInfo.getHosts())) {return new ArrayListInstance();}return list;
} 此方法的流程图 这个流程基本逻辑为
如果是订阅模式则直接从本地缓存获取服务信息(ServiceInfo)然后从中获取实例列表这是因为订阅机制会自动同步服务器实例的变化到本地。如果本地缓存中没有那说明是首次调用则进行订阅在订阅完成后会获得服务信息。
如果是非订阅模式那就直接请求服务器端获得服务信息。
订阅处理流程
在刚才的流程中涉及到了订阅的逻辑入口代码为获取实例列表中的方法
serviceInfo clientProxy.subscribe(serviceName, groupName, clusterString); 以下是具体分析。首先这里的clientProxy是NamingClientProxy类的对象对应的实现类是NamingClientProxyDelegate对应subscribe实现如下
Override
public ServiceInfo subscribe(String serviceName, String groupName, String clusters) throws NacosException {String serviceNameWithGroup NamingUtils.getGroupedName(serviceName, groupName);String serviceKey ServiceInfo.getKey(serviceNameWithGroup, clusters);// 定时调度UpdateTaskserviceInfoUpdateService.scheduleUpdateIfAbsent(serviceName, groupName, clusters);// 获取缓存中的ServiceInfoServiceInfo result serviceInfoHolder.getServiceInfoMap().get(serviceKey);if (null result) {// 如果为null则进行订阅逻辑处理基于gRPC协议result grpcClientProxy.subscribe(serviceName, groupName, clusters);}// ServiceInfo本地缓存处理serviceInfoHolder.processServiceInfo(result);return result;
} 在这段代码中可以看到在获取服务实例列表时特别是首次也进行了订阅逻辑的拓展基本流程图如下 具体流程分析
1. 订阅方法先开启定时任务这个定时任务的主要作用就是用来定时同步服务端的实例信息并进行本地缓存更新等操作但是如果是首次这里将会直接返回来走下一步。
2. 判断本地缓存是否存在如果本地缓存存在ServiceInfo信息则直接返回。如果不存在则默认采用gRPC协议进行订阅并返回ServiceInfo。
3. grpcClientProxy的subscribe订阅方法就是直接向服务器发送了一个订阅请求并返回结果。
4. 最后ServiceInfo本地缓存处理。这里会将获得的最新ServiceInfo与本地内存中的ServiceInfo进行比较更新发布变更时间磁盘文件存储等操作。其实这一步的操作在订阅定时任务中也进行了处理。
