ToB企服应用市场:ToB评测及商务社交产业平台

标题: nacos服务注册流程 [打印本页]
作者: 大连密封材料    时间: 2024-9-11 23:32
标题: nacos服务注册流程
一、客户端主动注册实例流程

1.首先客户端必要引入服务发现包

  1.   <groupId>com.alibaba.cloud</groupId>
  2.   <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  3.   <version>2.2.6.RELEASE</version>
复制代码
2.  NacosServiceRegistryAutoConfiguration 设置类

此类在spring-cloud-starter-alibaba-nacos-discovery客户包里面会主动在当前SPRINGBOOT容器注册
。


3.此设置类最核心的实体注册类为NacosAutoServiceRegistration，

查看此类的继承属性

发现此类继承于spring cloud common的AbstractAutoServiceRegistration抽象继承类，此类包罗了与SPRING对接的一系列主动注册功能。并且实现了ApplicationListener接口，所以会监听SPRING WEB事件。


4.监听ServletWebServerInitializedEvent事件


5.AbstractAutoServiceRegistration主动更新服务端口


6.NacosAutoServiceRegistration更新端口，以及设置里面的分组，集群等信息。


7.跳到父类的注册方法


8.最终调用了NacosServiceRegistry.registry


9.接着触发了NacosNamingService.registerInstance

注意这里，如果是临时节点，还会触发客户端定时发送心跳。
这里已经跳到了nacos-client-1.4.2的包，相当于是具体注册中心客户端的实现。

10.接着跳到了NamingProxy.registerService，


11.最终发起HTTP调用请求，NamingProxy

  1. public String reqApi(String api, Map<String, String> params, Map<String, String> body, List<String> servers,
  2.             String method) throws NacosException {
  3.         
  4.         params.put(CommonParams.NAMESPACE_ID, getNamespaceId());
  5.         
  6.         if (CollectionUtils.isEmpty(servers) && StringUtils.isBlank(nacosDomain)) {
  7.             throw new NacosException(NacosException.INVALID_PARAM, "no server available");
  8.         }
  9.         
  10.         NacosException exception = new NacosException();
  11.         
  12.         if (StringUtils.isNotBlank(nacosDomain)) {
  13.             for (int i = 0; i < maxRetry; i++) {
  14.                 try {
  15.                     return callServer(api, params, body, nacosDomain, method);
  16.                 } catch (NacosException e) {
  17.                     exception = e;
  18.                     if (NAMING_LOGGER.isDebugEnabled()) {
  19.                         NAMING_LOGGER.debug("request {} failed.", nacosDomain, e);
  20.                     }
  21.                 }
  22.             }
  23.         } else {
  24.             Random random = new Random(System.currentTimeMillis());
  25.             int index = random.nextInt(servers.size());
  26.             
  27.             for (int i = 0; i < servers.size(); i++) {
  28.                 String server = servers.get(index);
  29.                 try {
  30.                     return callServer(api, params, body, server, method);
  31.                 } catch (NacosException e) {
  32.                     exception = e;
  33.                     if (NAMING_LOGGER.isDebugEnabled()) {
  34.                         NAMING_LOGGER.debug("request {} failed.", server, e);
  35.                     }
  36.                 }
  37.                 index = (index + 1) % servers.size();
  38.             }
  39.         }
  40.         
  41.         NAMING_LOGGER.error("request: {} failed, servers: {}, code: {}, msg: {}", api, servers, exception.getErrCode(),
  42.                 exception.getErrMsg());
  43.         
  44.         throw new NacosException(exception.getErrCode(),
  45.                 "failed to req API:" + api + " after all servers(" + servers + ") tried: " + exception.getMessage());
  46.         
  47.     }
  48.    
复制代码
如果是带域名，或者单机运行，则直接发起HTTP调用，如果是集群NACOS服务列表，则随机找到一台NACOS服务器发起请求。

12.客户端注册完成

二、服务端注册流程

1.下载1.4.2源码，本地启动

-Dnacos.standalone=true -Dnacos.home=e:\\nacos
启动类为com.alibaba.nacos.Nacos
2.服务端是SPRINGBOOT项目，找到控制器接口


3.首先辈入InstanceController.register


4.进入ServiceManager.register，此类就是客户端服务实例的管理类，保存客户端实例的注册表。

  1. @Component
  2. public class ServiceManager implements RecordListener<Service> {
  3.    
  4.     /**
  5.      * Map(namespace, Map(group::serviceName, Service)). 真正的注册表
  6.      */
  7.     private final Map<String, Map<String, Service>> serviceMap = new ConcurrentHashMap<>();
  8.    
  9.     private final LinkedBlockingDeque<ServiceKey> toBeUpdatedServicesQueue = new LinkedBlockingDeque<>(1024 * 1024);
  10.    
  11.     private final Synchronizer synchronizer = new ServiceStatusSynchronizer();
  12.    
  13.     private final Lock lock = new ReentrantLock();
  14.    
  15.     @Resource(name = "consistencyDelegate")
  16.     //一致性协调协议
  17.     private ConsistencyService consistencyService;
  18.    
  19.     private final SwitchDomain switchDomain;
  20.    
  21.     private final DistroMapper distroMapper;
  22.    
  23.     private final ServerMemberManager memberManager;
  24.    
  25.     private final PushService pushService;
  26.    
  27.     private final RaftPeerSet raftPeerSet;
复制代码
5.如果服务不存在，则会创建一个空的Service对象。


注意，此时的servicename已经带了分组了。
6.调试日志输出品级

由于服务端源码有多个线程协作，调试比力贫苦，发起看代码，然后加日志打印输出。
可以把naming的LOGBACK日志输出品级调成DEBUG
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!--
  3.   ~ Copyright 1999-2018 Alibaba Group Holding Ltd.
  4.   ~
  5.   ~ Licensed under the Apache License, Version 2.0 (the "License");
  6.   ~ you may not use this file except in compliance with the License.
  7.   ~ You may obtain a copy of the License at
  8.   ~
  9.   ~      http://www.apache.org/licenses/LICENSE-2.0
  10.   ~
  11.   ~ Unless required by applicable law or agreed to in writing, software
  12.   ~ distributed under the License is distributed on an "AS IS" BASIS,
  13.   ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14.   ~ See the License for the specific language governing permissions and
  15.   ~ limitations under the License.
  16.   -->
  18. <included>
  20.     <springProperty scope="context" name="logPath" source="nacos.logs.path" defaultValue="${user.home}/nacos/logs"/>
  21.     <property name="LOG_HOME" value="${logPath}"/>
  23.     <appender name="naming-server"
  24.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  25.         <file>${LOG_HOME}/naming-server.log</file>
  26.         <append>true</append>
  27.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  28.             <fileNamePattern>${LOG_HOME}/naming-server.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  29.             <maxFileSize>2GB</maxFileSize>
  30.             <maxHistory>15</maxHistory>
  31.             <totalSizeCap>7GB</totalSizeCap>
  32.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  33.         </rollingPolicy>
  34.         <encoder>
  35.             <Pattern>%date %level  [%C:%M:%L] %msg%n%n</Pattern>
  36.             <charset>UTF-8</charset>
  37.         </encoder>
  38.     </appender>
  39.     <appender name="naming-raft"
  40.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  41.         <file>${LOG_HOME}/naming-raft.log</file>
  42.         <append>true</append>
  43.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  44.             <fileNamePattern>${LOG_HOME}/naming-raft.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  45.             <maxFileSize>20MB</maxFileSize>
  46.             <maxHistory>15</maxHistory>
  47.             <totalSizeCap>128MB</totalSizeCap>
  48.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  49.         </rollingPolicy>
  50.         <encoder>
  51.             <Pattern>%date %level  [%C:%M:%L] %msg%n%n</Pattern>
  52.             <charset>UTF-8</charset>
  53.         </encoder>
  54.     </appender>
  55.     <appender name="naming-event"
  56.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  57.         <file>${LOG_HOME}/naming-event.log</file>
  58.         <append>true</append>
  59.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  60.             <fileNamePattern>${LOG_HOME}/naming-event.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  61.             <maxFileSize>20MB</maxFileSize>
  62.             <maxHistory>15</maxHistory>
  63.             <totalSizeCap>128MB</totalSizeCap>
  64.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  65.         </rollingPolicy>
  66.         <encoder>
  67.             <Pattern>%date %level [%C:%M:%L] %msg%n%n</Pattern>
  68.             <charset>UTF-8</charset>
  69.         </encoder>
  70.     </appender>
  71.     <appender name="naming-push"
  72.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  73.         <file>${LOG_HOME}/naming-push.log</file>
  74.         <append>true</append>
  75.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  76.             <fileNamePattern>${LOG_HOME}/naming-push.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  77.             <maxFileSize>20MB</maxFileSize>
  78.             <maxHistory>15</maxHistory>
  79.             <totalSizeCap>128MB</totalSizeCap>
  80.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  81.         </rollingPolicy>
  82.         <encoder>
  83.             <Pattern>%date %level  [%C:%M:%L] %msg%n%n</Pattern>
  84.             <charset>UTF-8</charset>
  85.         </encoder>
  86.     </appender>
  87.     <appender name="naming-rt"
  88.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  89.         <file>${LOG_HOME}/naming-rt.log</file>
  90.         <append>true</append>
  91.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  92.             <fileNamePattern>${LOG_HOME}/naming-rt.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  93.             <maxFileSize>1GB</maxFileSize>
  94.             <maxHistory>15</maxHistory>
  95.             <totalSizeCap>3GB</totalSizeCap>
  96.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  97.         </rollingPolicy>
  98.         <encoder>
  99.             <Pattern>%date %level  [%C:%M:%L] %msg%n%n</Pattern>
  100.             <charset>UTF-8</charset>
  101.         </encoder>
  102.     </appender>
  104.     <appender name="naming-performance"
  105.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  106.         <file>${LOG_HOME}/naming-performance.log</file>
  107.         <append>true</append>
  108.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  109.             <fileNamePattern>${LOG_HOME}/naming-performance.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  110.             <maxFileSize>50MB</maxFileSize>
  111.             <maxHistory>15</maxHistory>
  112.             <totalSizeCap>512MB</totalSizeCap>
  113.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  114.         </rollingPolicy>
  115.         <encoder>
  116.             <Pattern>%date %level  [%C:%M:%L] %msg%n%n</Pattern>
  117.             <charset>UTF-8</charset>
  118.         </encoder>
  119.     </appender>
  121.     <appender name="naming-router"
  122.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  123.         <file>${LOG_HOME}/naming-router.log</file>
  124.         <append>true</append>
  125.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  126.             <fileNamePattern>${LOG_HOME}/naming-router.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  127.             <maxFileSize>2GB</maxFileSize>
  128.             <maxHistory>15</maxHistory>
  129.             <totalSizeCap>7GB</totalSizeCap>
  130.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  131.         </rollingPolicy>
  132.         <encoder>
  133.             <Pattern>%date|%msg%n</Pattern>
  134.             <charset>UTF-8</charset>
  135.         </encoder>
  136.     </appender>
  138.     <appender name="naming-cache"
  139.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  140.         <file>${LOG_HOME}/naming-cache.log</file>
  141.         <append>true</append>
  142.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  143.             <fileNamePattern>${LOG_HOME}/naming-cache.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  144.             <maxFileSize>1GB</maxFileSize>
  145.             <maxHistory>15</maxHistory>
  146.             <totalSizeCap>3GB</totalSizeCap>
  147.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  148.         </rollingPolicy>
  149.         <encoder>
  150.             <Pattern>%date|%msg%n</Pattern>
  151.             <charset>UTF-8</charset>
  152.         </encoder>
  153.     </appender>
  155.     <appender name="naming-device"
  156.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  157.         <file>${LOG_HOME}/naming-device.log</file>
  158.         <append>true</append>
  159.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  160.             <fileNamePattern>${LOG_HOME}/naming-device.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  161.             <maxFileSize>2GB</maxFileSize>
  162.             <maxHistory>15</maxHistory>
  163.             <totalSizeCap>7GB</totalSizeCap>
  164.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  165.         </rollingPolicy>
  166.         <encoder>
  167.             <Pattern>%date|%msg%n</Pattern>
  168.             <charset>UTF-8</charset>
  169.         </encoder>
  170.     </appender>
  172.     <appender name="naming-tag"
  173.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  174.         <file>${LOG_HOME}/naming-tag.log</file>
  175.         <append>true</append>
  176.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  177.             <fileNamePattern>${LOG_HOME}/naming-tag.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  178.             <maxFileSize>1GB</maxFileSize>
  179.             <maxHistory>15</maxHistory>
  180.             <totalSizeCap>3GB</totalSizeCap>
  181.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  182.         </rollingPolicy>
  183.         <encoder>
  184.             <Pattern>%date %level %msg%n%n</Pattern>
  185.             <charset>UTF-8</charset>
  186.         </encoder>
  187.     </appender>
  189.     <appender name="naming-debug"
  190.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  191.         <file>${LOG_HOME}/naming-debug.log</file>
  192.         <append>true</append>
  193.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  194.             <fileNamePattern>${LOG_HOME}/naming-debug.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  195.             <maxFileSize>20MB</maxFileSize>
  196.             <maxHistory>15</maxHistory>
  197.             <totalSizeCap>128MB</totalSizeCap>
  198.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  199.         </rollingPolicy>
  200.         <encoder>
  201.             <Pattern>%date %level %msg%n%n</Pattern>
  202.             <charset>UTF-8</charset>
  203.         </encoder>
  204.     </appender>
  206.     <appender name="naming-distro"
  207.         class="ch.qos.logback.core.rolling.RollingFileAppender">
  208.         <file>${LOG_HOME}/naming-distro.log</file>
  209.         <append>true</append>
  210.         <rollingPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
  211.             <fileNamePattern>${LOG_HOME}/naming-distro.log.%d{yyyy-MM-dd}.%i</fileNamePattern>
  212.             <maxFileSize>1GB</maxFileSize>
  213.             <maxHistory>7</maxHistory>
  214.             <totalSizeCap>3GB</totalSizeCap>
  215.             <cleanHistoryOnStart>true</cleanHistoryOnStart>
  216.         </rollingPolicy>
  217.         <encoder>
  218.             <Pattern>%date %level  [%C:%M:%L] %msg%n%n</Pattern>
  219.             <charset>UTF-8</charset>
  220.         </encoder>
  221.     </appender>
  223.     <appender name="CONSOLE2" class="ch.qos.logback.core.ConsoleAppender">
  224.         <encoder>
  225.             <Pattern>%date %level [%thread] [%C:%M:%L] %msg%n%n</Pattern>
  226.             <charset>UTF-8</charset>
  227.         </encoder>
  228.     </appender>
  230.     <logger name="com.alibaba.nacos.naming.main" additivity="false">
  231.         <level value="DEBUG"/>
  232.         <appender-ref ref="naming-server"/>
  233.         <appender-ref ref="CONSOLE2"/>
  234.     </logger>
  235.     <logger name="com.alibaba.nacos.naming.raft" additivity="false">
  236.         <level value="DEBUG"/>
  237.         <appender-ref ref="naming-raft"/>
  238.         <appender-ref ref="CONSOLE2"/>
  239.     </logger>
  240.     <logger name="com.alibaba.nacos.naming.distro" additivity="false">
  241.         <level value="DEBUG"/>
  242.         <appender-ref ref="naming-distro"/>
  243.         <appender-ref ref="CONSOLE2"/>
  244.     </logger>
  245.     <logger name="com.alibaba.nacos.naming.event" additivity="false">
  246.         <level value="DEBUG"/>
  247.         <appender-ref ref="naming-event"/>
  248.         <appender-ref ref="CONSOLE2"/>
  249.     </logger>
  250.     <logger name="com.alibaba.nacos.naming.push" additivity="false">
  251.         <level value="DEBUG"/>
  252.         <appender-ref ref="naming-push"/>
  253.         <appender-ref ref="CONSOLE2"/>
  254.     </logger>
  255.     <logger name="com.alibaba.nacos.naming.rt" additivity="false">
  256.         <level value="DEBUG"/>
  257.         <appender-ref ref="naming-rt"/>
  258.         <appender-ref ref="CONSOLE2"/>
  259.     </logger>
  260.     <logger name="com.alibaba.nacos.naming.performance" additivity="false">
  261.         <level value="DEBUG"/>
  262.         <appender-ref ref="naming-performance"/>
  263.     </logger>
  264.     <logger name="com.alibaba.nacos.naming.router" additivity="false">
  265.         <level value="DEBUG"/>
  266.         <appender-ref ref="naming-router"/>
  267.     </logger>
  268.     <logger name="com.alibaba.nacos.naming.cache" additivity="false">
  269.         <level value="DEBUG"/>
  270.         <appender-ref ref="naming-cache"/>
  271.     </logger>
  272.     <logger name="com.alibaba.nacos.naming.debug" additivity="false">
  273.         <level value="DEBUG"/>
  274.         <appender-ref ref="naming-debug"/>
  275.         <appender-ref ref="CONSOLE2"/>
  276.     </logger>
  278. </included>
复制代码
7.业务日志APPENDER类分析

有一个统一的日志输出类，将各种业务分别用差别的APPENDER对象输出
  1. public class Loggers {
  2.    
  3. //客户端推送
  4.     public static final Logger PUSH = LoggerFactory.getLogger("com.alibaba.nacos.naming.push");
  5.    
  6. //心跳检测
  7.     public static final Logger CHECK_RT = LoggerFactory.getLogger("com.alibaba.nacos.naming.rt");
  8.    
  9. //服务相关业务
  10.     public static final Logger SRV_LOG = LoggerFactory.getLogger("com.alibaba.nacos.naming.main");
  11.    
  12. //通知事件，如新服务注册，变更，下线等。
  13.     public static final Logger EVT_LOG = LoggerFactory.getLogger("com.alibaba.nacos.naming.event");
  14.    
  16. //一致性RAFT系统 CP
  17.     public static final Logger RAFT = LoggerFactory.getLogger("com.alibaba.nacos.naming.raft");
  18.    
  19. //一致性协议 ，AP
  20.     public static final Logger DISTRO = LoggerFactory.getLogger("com.alibaba.nacos.naming.distro");
  21.    
  23. //性能分析
  24.     public static final Logger PERFORMANCE_LOG = LoggerFactory.getLogger("com.alibaba.nacos.naming.performance");
复制代码
8.注册后的serviceMap布局如下:


单个Service的示例布局如下：
  1. {
  2.     "name":"mall@@joyday",
  3.     "protectThreshold":0,
  4.     "groupName":"mall",
  5.     "metadata":{
  7.     },
  8.     "finalizeCount":2,
  9.     "owners":[
  11.     ],
  12.     "resetWeight":false,
  13.     "enabled":true,
  14.     "selector":{
  15.         "type":"none"
  16.     },
  17.     "namespaceId":"public",
  18.     "ipDeleteTimeout":30000,
  19.     "lastModifiedMillis":1722671874301,
  20.     "checksum":"f936119262bea62fbfbb16c10f955e96",
  21.     "clusterMap":{
  22.         "beijing":{
  23.             "serviceName":"mall@@joyday",
  24.             "name":"beijing",
  25.             "healthChecker":{
  26.                 "type":"TCP"
  27.             },
  28.             "defaultPort":80,
  29.             "defaultCheckPort":80,
  30.             "useIPPort4Check":true,
  31.             "metadata":{
  33.             },
  34.             "sitegroup":"",
  35.             "defCkport":80,
  36.             "empty":false,
  37.             "defIPPort":80
  38.         }
  39.     },
  40.     "empty":false
  41. }
复制代码
9.进入ServiceMananger.addInstance，查看保存到一致性服务的dataStore中的KEY，为定名空间+分组+服务名，值为Instances，这个对象里面又包罗了一个instance的LIST.

10.进入ServiceMananger.updateIpAddresses,可以更具体看到dataMap,这个就是把dataMap看成旧的注册表，把二级缓存Service中的ClusterMap作为新对象进行比力，从而把新的实例加进到datamap中。

11.进入到DistroConsistencyServiceImpl.onPut，查看单个dataTum


12.Service为此中一个listener,异步收到消息。

13.再将厘革的Instances中的实例保存重新刷新到Service的clusterMap中，Service.
  1. updateIPs
复制代码

注意在这里，会给pushService发出关照，关照相干客户端此服务的实例发生厘革。

14.我们再启动一个新的实例，查看clusterMap,dataStore的厘革。看到端口酿成了8066


15.第一次8064服务启动日志
  1. 2024-08-03 16:40:36,500 DEBUG [http-nio-8848-exec-5] [com.alibaba.nacos.naming.controllers.InstanceController:doSrvIpxt:691] no instance to serve for service: mall@@joyday
  3. 2024-08-03 16:40:37,151 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.ServiceManager:createServiceIfAbsent:471] creating empty service public:mall@@joyday
  5. 2024-08-03 16:40:37,158 DEBUG [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.Service:recalculateChecksum:549] service to json: {"invalidIPCount":0,"name":"mall@@joyday","ipCount":0,"owners":[],"protectThreshold":0.0,"clusters":[]}
  7. 2024-08-03 16:40:37,162 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.consistency.persistent.raft.RaftCore:listen:962] add listener: com.alibaba.nacos.naming.iplist.public##mall@@joyday
  9. 2024-08-03 16:40:37,251 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.ServiceManager:putServiceAndInit:902] [NEW-SERVICE] {"name":"mall@@joyday","protectThreshold":0.0,"groupName":"mall","metadata":{},"finalizeCount":0,"owners":[],"resetWeight":false,"enabled":true,"selector":{"type":"none"},"namespaceId":"public","ipDeleteTimeout":30000,"lastModifiedMillis":1722674437153,"checksum":"45e19250c6a2ded80ed14b5aca7a6ee4","clusterMap":{},"empty":true}
  11. 2024-08-03 16:40:37,251 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.ServiceManager:createServiceIfAbsent:491] createServiceIfAbsent end getClusterMap {}
  13. 2024-08-03 16:40:37,251 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.ServiceManager:addInstance:652]  addInstance key:com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday
  15. 2024-08-03 16:40:37,252 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.ServiceManager:updateIpAddresses:806]  updateIpAddresses before  currentIPs:[],instanceMap:{}
  17. 2024-08-03 16:40:37,257 WARN [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.ServiceManager:updateIpAddresses:815] cluster: beijing not found, ip: {"instanceId":"10.6.33.23#8064#beijing#mall@@joyday","ip":"10.6.33.23","port":8064,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722674437147,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000}, will create new cluster with default configuration.
  19. 2024-08-03 16:40:37,259 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.ServiceManager:updateIpAddresses:839]  updateIpAddresses after  currentIPs:[],instanceMap:{10.6.33.23:8064:unknown:beijing=10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing}
  21. 2024-08-03 16:40:37,259 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.core.ServiceManager:addInstance:661]  addInstance after addIpAddresses new instanceList:[10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing]
  23. 2024-08-03 16:40:37,259 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:put:108]  distro put key:com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday,value:{"instanceList":[{"instanceId":"10.6.33.23#8064#beijing#mall@@joyday","ip":"10.6.33.23","port":8064,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722674437147,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000}]}
  25. 2024-08-03 16:40:37,260 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:onPut:132] createServiceIfAbsent start dataStore {}
  27. 2024-08-03 16:40:37,260 INFO [http-nio-8848-exec-7] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:onPut:141] createServiceIfAbsent end dataStore {com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday=com.alibaba.nacos.naming.consistency.Datum@72f532aa}
  29. 2024-08-03 16:40:37,263 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:onChange:178] [NACOS-RAFT] datum service is changed, key: com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday, value: {"instanceList":[{"instanceId":"10.6.33.23#8064#beijing#mall@@joyday","ip":"10.6.33.23","port":8064,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722674437147,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000}]}
  31. 2024-08-03 16:40:37,263 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:updateIPs:237] updateIPs before, instances: [10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing], ephemeral: true
  33. 2024-08-03 16:40:37,264 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Cluster:updateIps:277] mall@@joyday {SYNC} {IP-NEW} cluster: beijing, new ips size: 1, content: [10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing]
  35. 2024-08-03 16:40:37,266 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:updateIPs:290] [IP-UPDATED] namespace: public, service: mall@@joyday, ips: 10.6.33.23:8064_true,
  37. 2024-08-03 16:40:37,269 DEBUG [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:recalculateChecksum:549] service to json: {"invalidIPCount":0,"name":"mall@@joyday","ipCount":1,"owners":[],"protectThreshold":0.0,"clusters":[{"healthChecker":{},"defIPPort":80,"defCkport":80,"name":"beijing","useIPPort4Check":true,"sitegroup":""}]}
  39. 2024-08-03 16:40:37,269 DEBUG [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl$Notifier:handle:447] [NACOS-DISTRO] datum change notified, key: com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday, listener count: 1, action: CHANGE
  41. 2024-08-03 16:40:38,267 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:lambda$onApplicationEvent$1:127] mall@@joyday is changed, add it to push queue.
  43. 2024-08-03 16:40:38,272 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:lambda$onApplicationEvent$1:166] serviceName: mall@@joyday changed, schedule push for: 10.6.33.23:62522, agent: Nacos-Java-Client:v1.4.2, key: 10.6.33.23,62522,373503109817900
  45. 2024-08-03 16:40:38,272 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:udpPush:614] send udp packet: 10.6.33.23,62522,373503109817900
  47. 2024-08-03 16:40:38,278 INFO [com.alibaba.nacos.naming.push.receiver] [com.alibaba.nacos.naming.push.PushService$Receiver:run:687] received ack: {"type": "push-ack", "lastRefTime":"373503109817900", "data":""} from: 10.6.33.23:62522, cost: 6 ms, unacked: 0, total push: 1
复制代码
dataStore-dataTum
 key:com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday
{com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday
com.alibaba.nacos.naming.consistency.Datum@72f532aa}
  1. {
  2.     "instanceList":[
  3.         {
  4.             "instanceId":"10.6.33.23#8064#beijing#mall@@joyday",
  5.             "ip":"10.6.33.23",
  6.             "port":8064,
  7.             "weight":1,
  8.             "healthy":true,
  9.             "enabled":true,
  10.             "ephemeral":true,
  11.             "clusterName":"beijing",
  12.             "serviceName":"mall@@joyday",
  13.             "metadata":{
  14.                 "preserved.register.source":"SPRING_CLOUD"
  15.             },
  16.             "lastBeat":1722674437147,
  17.             "marked":false,
  18.             "app":"unknown",
  19.             "instanceHeartBeatInterval":5000,
  20.             "instanceHeartBeatTimeOut":15000,
  21.             "ipDeleteTimeout":30000
  22.         }
  23.     ]
  24. }
复制代码
servicemap布局
{public={mall@@joyday=Service{name='mall@@joyday', protectThreshold=0.0, appName='null', groupName='mall', metadata={}}}}
16.第二次8066服务启动日志
  1. 2024-08-03 16:53:45,870 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.core.ServiceManager:createServiceIfAbsent:492] createServiceIfAbsent end getClusterMap {beijing=com.alibaba.nacos.naming.core.Cluster@f27590dd}
  3. 2024-08-03 16:53:45,870 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.core.ServiceManager:addInstance:653]  addInstance key:com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday
  5. 2024-08-03 16:53:45,870 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.core.ServiceManager:addInstance:656]  addInstance ,serviceMap:{public={mall@@joyday=Service{name='mall@@joyday', protectThreshold=0.0, appName='null', groupName='mall', metadata={}}}}
  7. 2024-08-03 16:53:45,871 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.core.ServiceManager:updateIpAddresses:809]  updateIpAddresses before  currentIPs:[10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing],instanceMap:{10.6.33.23:8064:unknown:beijing=10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing}
  9. 2024-08-03 16:53:45,871 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.core.ServiceManager:updateIpAddresses:842]  updateIpAddresses after  currentIPs:[10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing],instanceMap:{10.6.33.23:8064:unknown:beijing=10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing=10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing}
  11. 2024-08-03 16:53:45,872 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.core.ServiceManager:addInstance:664]  addInstance after addIpAddresses new instanceList:[10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing]
  13. 2024-08-03 16:53:45,872 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:put:108]  distro put key:com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday,value:{"instanceList":[{"instanceId":"10.6.33.23#8064#beijing#mall@@joyday","ip":"10.6.33.23","port":8064,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"dubbo.metadata-service.urls":"[ "dubbo://10.6.33.23:20880/com.alibaba.cloud.dubbo.service.DubboMetadataService?anyhost=true&application=joyday&bind.ip=10.6.33.23&bind.port=20880&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&group=joyday&interface=com.alibaba.cloud.dubbo.service.DubboMetadataService&methods=getAllServiceKeys,getServiceRestMetadata,getExportedURLs,getAllExportedURLs&pid=38352&qos.enable=false&release=2.7.8&revision=2.2.6.RELEASE&side=provider&timestamp=1722675134397&version=1.0.0" ]","dubbo.metadata.revision":"0","preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722675221548,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000},{"instanceId":"10.6.33.23#8066#beijing#mall@@joyday","ip":"10.6.33.23","port":8066,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722675225870,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000}]}
  15. 2024-08-03 16:53:45,872 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:onPut:132] createServiceIfAbsent start dataStore {com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday=com.alibaba.nacos.naming.consistency.Datum@41cab4c3}
  17. 2024-08-03 16:53:45,872 INFO [http-nio-8848-exec-6] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:onPut:141] createServiceIfAbsent end dataStore {com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday=com.alibaba.nacos.naming.consistency.Datum@36aea586}
  19. 2024-08-03 16:53:45,872 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:onChange:178] [NACOS-RAFT] datum service is changed, key: com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday, value: {"instanceList":[{"instanceId":"10.6.33.23#8064#beijing#mall@@joyday","ip":"10.6.33.23","port":8064,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"dubbo.metadata-service.urls":"[ "dubbo://10.6.33.23:20880/com.alibaba.cloud.dubbo.service.DubboMetadataService?anyhost=true&application=joyday&bind.ip=10.6.33.23&bind.port=20880&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&group=joyday&interface=com.alibaba.cloud.dubbo.service.DubboMetadataService&methods=getAllServiceKeys,getServiceRestMetadata,getExportedURLs,getAllExportedURLs&pid=38352&qos.enable=false&release=2.7.8&revision=2.2.6.RELEASE&side=provider&timestamp=1722675134397&version=1.0.0" ]","dubbo.metadata.revision":"0","preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722675221548,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000},{"instanceId":"10.6.33.23#8066#beijing#mall@@joyday","ip":"10.6.33.23","port":8066,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722675225870,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000}]}
  21. 2024-08-03 16:53:45,873 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:updateIPs:237] updateIPs before, instances: [10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing], ephemeral: true
  23. 2024-08-03 16:53:45,873 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Cluster:updateIps:277] mall@@joyday {SYNC} {IP-NEW} cluster: beijing, new ips size: 1, content: [10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing]
  25. 2024-08-03 16:53:45,873 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:updateIPs:290] [IP-UPDATED] namespace: public, service: mall@@joyday, ips: 10.6.33.23:8064_true,10.6.33.23:8066_true,
  27. 2024-08-03 16:53:45,873 DEBUG [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:recalculateChecksum:549] service to json: {"invalidIPCount":0,"name":"mall@@joyday","ipCount":2,"owners":[],"protectThreshold":0.0,"clusters":[{"healthChecker":{},"defIPPort":80,"defCkport":80,"name":"beijing","useIPPort4Check":true,"sitegroup":""}]}
  29. 2024-08-03 16:53:45,873 DEBUG [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl$Notifier:handle:447] [NACOS-DISTRO] datum change notified, key: com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday, listener count: 1, action: CHANGE
  31. 2024-08-03 16:53:46,566 DEBUG [http-nio-8848-exec-8] [com.alibaba.nacos.naming.controllers.InstanceController:beat:494] [CLIENT-BEAT] full arguments: beat: null, serviceName: mall@@joyday
  33. 2024-08-03 16:53:46,878 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:lambda$onApplicationEvent$1:127] mall@@joyday is changed, add it to push queue.
  35. 2024-08-03 16:53:46,879 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:lambda$onApplicationEvent$1:166] serviceName: mall@@joyday changed, schedule push for: 10.6.33.23:53206, agent: Nacos-Java-Client:v1.4.2, key: 10.6.33.23,53206,374291714306500
  37. 2024-08-03 16:53:46,879 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:udpPush:614] send udp packet: 10.6.33.23,53206,374291714306500
  39. 2024-08-03 16:53:46,880 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:lambda$onApplicationEvent$1:166] serviceName: mall@@joyday changed, schedule push for: 10.6.33.23:62806, agent: Nacos-Java-Client:v1.4.2, key: 10.6.33.23,62806,374291714306500
  41. 2024-08-03 16:53:46,881 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:udpPush:614] send udp packet: 10.6.33.23,62806,374291714306500
  43. 2024-08-03 16:53:46,885 INFO [com.alibaba.nacos.naming.push.receiver] [com.alibaba.nacos.naming.push.PushService$Receiver:run:687] received ack: {"type": "push-ack", "lastRefTime":"374291714306500", "data":""} from: 10.6.33.23:62806, cost: 4 ms, unacked: 1, total push: 4
  45. 2024-08-03 16:53:46,885 INFO [com.alibaba.nacos.naming.push.receiver] [com.alibaba.nacos.naming.push.PushService$Receiver:run:687] received ack: {"type": "push-ack", "lastRefTime":"374291714306500", "data":""} from: 10.6.33.23:53206, cost: 6 ms, unacked: 0, total push: 4
  47. 2024-08-03 16:53:47,494 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.core.ServiceManager:createServiceIfAbsent:492] createServiceIfAbsent end getClusterMap {beijing=com.alibaba.nacos.naming.core.Cluster@f27590dd}
  49. 2024-08-03 16:53:47,494 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.core.ServiceManager:addInstance:653]  addInstance key:com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday
  51. 2024-08-03 16:53:47,495 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.core.ServiceManager:addInstance:656]  addInstance ,serviceMap:{public={mall@@joyday=Service{name='mall@@joyday', protectThreshold=0.0, appName='null', groupName='mall', metadata={}}}}
  53. 2024-08-03 16:53:47,495 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.core.ServiceManager:updateIpAddresses:809]  updateIpAddresses before  currentIPs:[10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing],instanceMap:{10.6.33.23:8064:unknown:beijing=10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing=10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing}
  55. 2024-08-03 16:53:47,496 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.core.ServiceManager:updateIpAddresses:842]  updateIpAddresses after  currentIPs:[10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing],instanceMap:{10.6.33.23:8064:unknown:beijing=10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing=10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing}
  57. 2024-08-03 16:53:47,496 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.core.ServiceManager:addInstance:664]  addInstance after addIpAddresses new instanceList:[10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing]
  59. 2024-08-03 16:53:47,496 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:put:108]  distro put key:com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday,value:{"instanceList":[{"instanceId":"10.6.33.23#8064#beijing#mall@@joyday","ip":"10.6.33.23","port":8064,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"dubbo.metadata-service.urls":"[ "dubbo://10.6.33.23:20880/com.alibaba.cloud.dubbo.service.DubboMetadataService?anyhost=true&application=joyday&bind.ip=10.6.33.23&bind.port=20880&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&group=joyday&interface=com.alibaba.cloud.dubbo.service.DubboMetadataService&methods=getAllServiceKeys,getServiceRestMetadata,getExportedURLs,getAllExportedURLs&pid=38352&qos.enable=false&release=2.7.8&revision=2.2.6.RELEASE&side=provider&timestamp=1722675134397&version=1.0.0" ]","dubbo.metadata.revision":"0","preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722675226566,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000},{"instanceId":"10.6.33.23#8066#beijing#mall@@joyday","ip":"10.6.33.23","port":8066,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"dubbo.metadata-service.urls":"[ "dubbo://10.6.33.23:20881/com.alibaba.cloud.dubbo.service.DubboMetadataService?anyhost=true&application=joyday&bind.ip=10.6.33.23&bind.port=20881&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&group=joyday&interface=com.alibaba.cloud.dubbo.service.DubboMetadataService&methods=getAllServiceKeys,getServiceRestMetadata,getExportedURLs,getAllExportedURLs&pid=44484&qos.enable=false&release=2.7.8&revision=2.2.6.RELEASE&side=provider&timestamp=1722675226758&version=1.0.0" ]","dubbo.metadata.revision":"0","preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722675227493,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000}]}
  61. 2024-08-03 16:53:47,496 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:onPut:132] createServiceIfAbsent start dataStore {com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday=com.alibaba.nacos.naming.consistency.Datum@36aea586}
  63. 2024-08-03 16:53:47,497 INFO [http-nio-8848-exec-9] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl:onPut:141] createServiceIfAbsent end dataStore {com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday=com.alibaba.nacos.naming.consistency.Datum@6ee0d505}
  65. 2024-08-03 16:53:47,497 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:onChange:178] [NACOS-RAFT] datum service is changed, key: com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday, value: {"instanceList":[{"instanceId":"10.6.33.23#8064#beijing#mall@@joyday","ip":"10.6.33.23","port":8064,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"dubbo.metadata-service.urls":"[ "dubbo://10.6.33.23:20880/com.alibaba.cloud.dubbo.service.DubboMetadataService?anyhost=true&application=joyday&bind.ip=10.6.33.23&bind.port=20880&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&group=joyday&interface=com.alibaba.cloud.dubbo.service.DubboMetadataService&methods=getAllServiceKeys,getServiceRestMetadata,getExportedURLs,getAllExportedURLs&pid=38352&qos.enable=false&release=2.7.8&revision=2.2.6.RELEASE&side=provider&timestamp=1722675134397&version=1.0.0" ]","dubbo.metadata.revision":"0","preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722675226566,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000},{"instanceId":"10.6.33.23#8066#beijing#mall@@joyday","ip":"10.6.33.23","port":8066,"weight":1.0,"healthy":true,"enabled":true,"ephemeral":true,"clusterName":"beijing","serviceName":"mall@@joyday","metadata":{"dubbo.metadata-service.urls":"[ "dubbo://10.6.33.23:20881/com.alibaba.cloud.dubbo.service.DubboMetadataService?anyhost=true&application=joyday&bind.ip=10.6.33.23&bind.port=20881&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&group=joyday&interface=com.alibaba.cloud.dubbo.service.DubboMetadataService&methods=getAllServiceKeys,getServiceRestMetadata,getExportedURLs,getAllExportedURLs&pid=44484&qos.enable=false&release=2.7.8&revision=2.2.6.RELEASE&side=provider&timestamp=1722675226758&version=1.0.0" ]","dubbo.metadata.revision":"0","preserved.register.source":"SPRING_CLOUD"},"lastBeat":1722675227493,"marked":false,"app":"unknown","instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"ipDeleteTimeout":30000}]}
  67. 2024-08-03 16:53:47,497 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:updateIPs:237] updateIPs before, instances: [10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing], ephemeral: true
  69. 2024-08-03 16:53:47,497 INFO [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:updateIPs:290] [IP-UPDATED] namespace: public, service: mall@@joyday, ips: 10.6.33.23:8064_true,10.6.33.23:8066_true,
  71. 2024-08-03 16:53:47,498 DEBUG [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.core.Service:recalculateChecksum:549] service to json: {"invalidIPCount":0,"name":"mall@@joyday","ipCount":2,"owners":[],"protectThreshold":0.0,"clusters":[{"healthChecker":{},"defIPPort":80,"defCkport":80,"name":"beijing","useIPPort4Check":true,"sitegroup":""}]}
  73. 2024-08-03 16:53:47,498 DEBUG [com.alibaba.nacos.naming.distro.notifier.0] [com.alibaba.nacos.naming.consistency.ephemeral.distro.DistroConsistencyServiceImpl$Notifier:handle:447] [NACOS-DISTRO] datum change notified, key: com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday, listener count: 1, action: CHANGE
  75. 2024-08-03 16:53:47,674 DEBUG [com.alibaba.nacos.naming.service.worker.0] [com.alibaba.nacos.naming.core.Service:recalculateChecksum:549] service to json: {"invalidIPCount":0,"name":"mall@@joyday","ipCount":2,"owners":[],"protectThreshold":0.0,"clusters":[{"healthChecker":{},"defIPPort":80,"defCkport":80,"name":"beijing","useIPPort4Check":true,"sitegroup":""}]}
  77. 2024-08-03 16:53:48,501 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:lambda$onApplicationEvent$1:127] mall@@joyday is changed, add it to push queue.
  79. 2024-08-03 16:53:48,501 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:lambda$onApplicationEvent$1:166] serviceName: mall@@joyday changed, schedule push for: 10.6.33.23:53206, agent: Nacos-Java-Client:v1.4.2, key: 10.6.33.23,53206,374293336465400
  81. 2024-08-03 16:53:48,501 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:udpPush:614] send udp packet: 10.6.33.23,53206,374293336465400
  83. 2024-08-03 16:53:48,502 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:lambda$onApplicationEvent$1:166] serviceName: mall@@joyday changed, schedule push for: 10.6.33.23:62806, agent: Nacos-Java-Client:v1.4.2, key: 10.6.33.23,62806,374293336465400
  85. 2024-08-03 16:53:48,502 INFO [com.alibaba.nacos.naming.push.udpSender.0] [com.alibaba.nacos.naming.push.PushService:udpPush:614] send udp packet: 10.6.33.23,62806,374293336465400
  87. 2024-08-03 16:53:48,504 INFO [com.alibaba.nacos.naming.push.receiver] [com.alibaba.nacos.naming.push.PushService$Receiver:run:687] received ack: {"type": "push-ack", "lastRefTime":"374293336465400", "data":""} from: 10.6.33.23:53206, cost: 3 ms, unacked: 1, total push: 6
  89. 2024-08-03 16:53:48,505 INFO [com.alibaba.nacos.naming.push.receiver] [com.alibaba.nacos.naming.push.PushService$Receiver:run:687] received ack: {"type": "push-ack", "lastRefTime":"374293336465400", "data":""} from: 10.6.33.23:62806, cost: 3 ms, unacked: 0, total push: 6
  91. 2024-08-03 16:53:51,570 DEBUG [http-nio-8848-exec-4] [com.alibaba.nacos.naming.controllers.InstanceController:beat:494] [CLIENT-BEAT] full arguments: beat: null, serviceName: mall@@joyday
  93. 2024-08-03 16:53:52,685 DEBUG [com.alibaba.nacos.naming.service.worker.0] [com.alibaba.nacos.naming.core.Service:recalculateChecksum:549] service to json: {"invalidIPCount":0,"name":"mall@@joyday","ipCount":2,"owners":[],"protectThreshold":0.0,"clusters":[{"healthChecker":{},"defIPPort":80,"defCkport":80,"name":"beijing","useIPPort4Check":true,"sitegroup":""}]}
复制代码
 updateIpAddresses after  currentIPs:[10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing],instanceMap:{10.6.33.23:8064:unknown:beijing=10.6.33.23:8064:unknown:beijing_1.0_true_false_beijing, 10.6.33.23:8066:unknown:beijing=10.6.33.23:8066:unknown:beijing_1.0_true_false_beijing}
可以看到经过updateIpAddresses  多了一个实例，
最终写入distro后，也会多了一个实例
distro put key:com.alibaba.nacos.naming.iplist.ephemeral.public##mall@@joyday,value:
  1. {
  2.     "instanceList":[
  3.         {
  4.             "instanceId":"10.6.33.23#8064#beijing#mall@@joyday",
  5.             "ip":"10.6.33.23",
  6.             "port":8064,
  7.             "weight":1,
  8.             "healthy":true,
  9.             "enabled":true,
  10.             "ephemeral":true,
  11.             "clusterName":"beijing",
  12.             "serviceName":"mall@@joyday",
  13.             "metadata":{
  14.                 "dubbo.metadata-service.urls":"[ "dubbo://10.6.33.23:20880/com.alibaba.cloud.dubbo.service.DubboMetadataService?anyhost=true&application=joyday&bind.ip=10.6.33.23&bind.port=20880&deprecated=false&dubbo=2.0.2&dynamic=true&generic=false&group=joyday&interface=com.alibaba.cloud.dubbo.service.DubboMetadataService&methods=getAllServiceKeys,getServiceRestMetadata,getExportedURLs,getAllExportedURLs&pid=38352&qos.enable=false&release=2.7.8&revision=2.2.6.RELEASE&side=provider×tamp=1722675134397&version=1.0.0" ]",
  15.                 "dubbo.metadata.revision":"0",
  16.                 "preserved.register.source":"SPRING_CLOUD"
  17.             },
  18.             "lastBeat":1722675221548,
  19.             "marked":false,
  20.             "app":"unknown",
  21.             "instanceHeartBeatInterval":5000,
  22.             "instanceHeartBeatTimeOut":15000,
  23.             "ipDeleteTimeout":30000
  24.         },
  25.         {
  26.             "instanceId":"10.6.33.23#8066#beijing#mall@@joyday",
  27.             "ip":"10.6.33.23",
  28.             "port":8066,
  29.             "weight":1,
  30.             "healthy":true,
  31.             "enabled":true,
  32.             "ephemeral":true,
  33.             "clusterName":"beijing",
  34.             "serviceName":"mall@@joyday",
  35.             "metadata":{
  36.                 "preserved.register.source":"SPRING_CLOUD"
  37.             },
  38.             "lastBeat":1722675225870,
  39.             "marked":false,
  40.             "app":"unknown",
  41.             "instanceHeartBeatInterval":5000,
  42.             "instanceHeartBeatTimeOut":15000,
  43.             "ipDeleteTimeout":30000
  44.         }
  45.     ]
  46. }
复制代码
三、注册表数据布局

1.数据布局思维导图


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4