我們來看看實例列表的更新，對應的方法是addIpAddresses(service, ephemeral, ips);：

private List<Instance> addIpAddresses(Service service, boolean ephemeral, Instance... ips) throws NacosException {return updateIpAddresses(service, UtilsAndCommons.UPDATE_INSTANCE_ACTION_ADD, ephemeral, ips); }

繼續(xù)進入updateIpAddresses方法：

public List<Instance> updateIpAddresses(Service service, String action, boolean ephemeral, Instance... ips)throws NacosException {// 根據(jù)namespaceId、serviceName獲取當前服務的實例列表，返回值是Datum// 第一次來，肯定是nullDatum datum = consistencyService.get(KeyBuilder.buildInstanceListKey(service.getNamespaceId(), service.getName(), ephemeral));// 得到服務中現(xiàn)有的實例列表List<Instance> currentIPs = service.allIPs(ephemeral);// 創(chuàng)建map，保存實例列表，key為ip地址，value是Instance對象Map<String, Instance> currentInstances = new HashMap<>(currentIPs.size());// 創(chuàng)建Set集合，保存實例的instanceIdSet<String> currentInstanceIds = Sets.newHashSet();// 遍歷要現(xiàn)有的實例列表for (Instance instance : currentIPs) {// 添加到map中currentInstances.put(instance.toIpAddr(), instance);// 添加instanceId到set中currentInstanceIds.add(instance.getInstanceId());}// 創(chuàng)建map，用來保存更新后的實例列表Map<String, Instance> instanceMap;if (datum != null && null != datum.value) {// 如果服務中已經(jīng)有舊的數(shù)據(jù)，則先保存舊的實例列表instanceMap = setValid(((Instances) datum.value).getInstanceList(), currentInstances);} else {// 如果沒有舊數(shù)據(jù)，則直接創(chuàng)建新的mapinstanceMap = new HashMap<>(ips.length);}// 遍歷實例列表for (Instance instance : ips) {// 判斷服務中是否包含要注冊的實例的cluster信息if (!service.getClusterMap().containsKey(instance.getClusterName())) {// 如果不包含，創(chuàng)建新的clusterCluster cluster = new Cluster(instance.getClusterName(), service);cluster.init();// 將集群放入service的注冊表service.getClusterMap().put(instance.getClusterName(), cluster);Loggers.SRV_LOG.warn("cluster: {} not found, ip: {}, will create new cluster with default configuration.",instance.getClusterName(), instance.toJson());}// 刪除實例 or 新增實例 ？if (UtilsAndCommons.UPDATE_INSTANCE_ACTION_REMOVE.equals(action)) {instanceMap.remove(instance.getDatumKey());} else {// 新增實例，instance生成全新的instanceIdInstance oldInstance = instanceMap.get(instance.getDatumKey());if (oldInstance != null) {instance.setInstanceId(oldInstance.getInstanceId());} else {instance.setInstanceId(instance.generateInstanceId(currentInstanceIds));}// 放入instance列表instanceMap.put(instance.getDatumKey(), instance);}}if (instanceMap.size() <= 0 && UtilsAndCommons.UPDATE_INSTANCE_ACTION_ADD.equals(action)) {throw new IllegalArgumentException("ip list can not be empty, service: " + service.getName() + ", ip list: " + JacksonUtils.toJson(instanceMap.values()));}// 將instanceMap中的所有實例轉為List返回return new ArrayList<>(instanceMap.values()); }

簡單來講，就是先獲取舊的實例列表，然后把新的實例信息與舊的做對比，新的實例就添加，老的實例同步ID。然后返回最新的實例列表。

總結

以上是生活随笔為你收集整理的Nacos源码更服务列表的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內容還不錯，歡迎將生活随笔推薦給好友。