一.Nacos源码搭建

  1. 源码地址：
  2. git clone https://gitee.com/mirrors/Nacos.git
  1. 启动问题1.找不到类
  2. 在ideal控制台使用：mvn compile
  4. 启动问题2.服务找不到（nacos默认使用集群形式）
  5. -Dnacos.standalone=true

Nacos源码2.0.3一、源码环境搭建以及启动 - 图1
Nacos源码2.0.3一、源码环境搭建以及启动 - 图2

二、nacos2.0.3依赖包

  1. <dependency>
  2.             <groupId>com.alibaba.cloud</groupId>
  3.             <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
  4.             <version>2.2.6.RELEASE</version>
  5.             <exclusions>
  6.                 <exclusion>
  7.                     <groupId>com.alibaba.nacos</groupId>
  8.                     <artifactId>nacos-client</artifactId>
  9.                 </exclusion>
  10.             </exclusions>
  11.         </dependency>
  12.         <dependency>
  13.             <groupId>com.alibaba.cloud</groupId>
  14.             <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
  15.             <version>2.2.6.RELEASE</version>
  16.             <exclusions>
  17.                 <exclusion>
  18.                     <groupId>com.alibaba.nacos</groupId>
  19.                     <artifactId>nacos-client</artifactId>
  20.                 </exclusion>
  21.             </exclusions>
  22.         </dependency>
  23.         <dependency>
  24.             <groupId>com.alibaba.nacos</groupId>
  25.             <artifactId>nacos-client</artifactId>
  26.         </dependency>
  27.         <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
  28.         <dependency>
  29.             <groupId>org.springframework.boot</groupId>
  30.             <artifactId>spring-boot-starter-web</artifactId>
  31.         </dependency>
  33.         <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
  34.         <dependency>
  35.             <groupId>org.projectlombok</groupId>
  36.             <artifactId>lombok</artifactId>
  37.         </dependency>

二. Nacos启动注入类

NacosDiscoveryClientConfiguration

  1. @Configuration(
  2.     proxyBeanMethods = false
  3. )
  4. @ConditionalOnDiscoveryEnabled
  5. @ConditionalOnBlockingDiscoveryEnabled
  6. @ConditionalOnNacosDiscoveryEnabled
  7. @AutoConfigureBefore({SimpleDiscoveryClientAutoConfiguration.class, CommonsClientAutoConfiguration.class})
  8. @AutoConfigureAfter({NacosDiscoveryAutoConfiguration.class})
  9. public class NacosDiscoveryClientConfiguration {
  10.     public NacosDiscoveryClientConfiguration() {
  11.     }
  13.     @Bean
  14.     public DiscoveryClient nacosDiscoveryClient(NacosServiceDiscovery nacosServiceDiscovery) {
  15.         return new NacosDiscoveryClient(nacosServiceDiscovery);
  16.     }
  18.     @Bean
  19.     @ConditionalOnMissingBean
  20.     @ConditionalOnProperty(
  21.         value = {"spring.cloud.nacos.discovery.watch.enabled"},
  22.         matchIfMissing = true
  23.     )
  24.     public NacosWatch nacosWatch(NacosServiceManager nacosServiceManager, NacosDiscoveryProperties nacosDiscoveryProperties) {
  25.         return new NacosWatch(nacosServiceManager, nacosDiscoveryProperties);
  26.     }
  27. }

NacosDiscoveryClient

  1. public class NacosDiscoveryClient implements DiscoveryClient {
  2.     private static final Logger log = LoggerFactory.getLogger(NacosDiscoveryClient.class);
  3.     public static final String DESCRIPTION = "Spring Cloud Nacos Discovery Client";
  4.     private NacosServiceDiscovery serviceDiscovery;
  6.     public NacosDiscoveryClient(NacosServiceDiscovery nacosServiceDiscovery) {
  7.         this.serviceDiscovery = nacosServiceDiscovery;
  8.     }
  9. }

NacosWatch

  1. 观察者
  2. 创建定时任务线程池(Nacos-Watch-Task-Scheduler）,默认有一个线程，使用AbortPolicy拒绝策略
  1. public class NacosWatch implements ApplicationEventPublisherAware, SmartLifecycle {
  2.     private static final Logger log = LoggerFactory.getLogger(NacosWatch.class);
  3.     private Map<String, EventListener> listenerMap = new ConcurrentHashMap(16);
  4.     private final AtomicBoolean running = new AtomicBoolean(false);
  5.     private final AtomicLong nacosWatchIndex = new AtomicLong(0L);
  6.     private ApplicationEventPublisher publisher;
  7.     private ScheduledFuture<?> watchFuture;
  8.     private NacosServiceManager nacosServiceManager;
  9.     private final NacosDiscoveryProperties properties;
  10.     private final ThreadPoolTaskScheduler taskScheduler;
  12.     public NacosWatch(NacosServiceManager nacosServiceManager, NacosDiscoveryProperties properties) {
  13.         this.nacosServiceManager = nacosServiceManager;
  14.         this.properties = properties;
  15.         this.taskScheduler = getTaskScheduler();
  16.     }
  17.    private static ThreadPoolTaskScheduler getTaskScheduler() {
  18.         ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
  19.         taskScheduler.setBeanName("Nacos-Watch-Task-Scheduler");
  20.         taskScheduler.initialize();
  21.         return taskScheduler;
  22.     }
  23.     public void initialize() {
  24.         if (this.logger.isInfoEnabled()) {
  25.             this.logger.info("Initializing ExecutorService" + (this.beanName != null ? " '" + this.beanName + "'" : ""));
  26.         }
  28.         if (!this.threadNamePrefixSet && this.beanName != null) {
  29.             this.setThreadNamePrefix(this.beanName + "-");
  30.         }
  31.         #使用AbortPolicy策略：丢弃任务并抛出RejectedExecutionException异常
  32.         this.executor = this.initializeExecutor(this.threadFactory, this.rejectedExecutionHandler);
  33.     }
  34. }

NacosDiscoveryAutoConfiguration

  2. @Configuration
  3. @EnableConfigurationProperties
  4. @ConditionalOnNacosDiscoveryEnabled
  5. @ConditionalOnProperty(
  6.     value = {"spring.cloud.service-registry.auto-registration.enabled"},
  7.     matchIfMissing = true
  8. )
  9. @AutoConfigureAfter({AutoServiceRegistrationConfiguration.class, AutoServiceRegistrationAutoConfiguration.class})
  10. public class NacosDiscoveryAutoConfiguration {
  11.     public NacosDiscoveryAutoConfiguration() {
  12.     }
  14.     @Bean
  15.     public NacosServiceRegistry nacosServiceRegistry(NacosDiscoveryProperties nacosDiscoveryProperties) {
  16.         return new NacosServiceRegistry(nacosDiscoveryProperties);
  17.     }
  19.     @Bean
  20.     @ConditionalOnBean({AutoServiceRegistrationProperties.class})
  21.     public NacosRegistration nacosRegistration(NacosDiscoveryProperties nacosDiscoveryProperties, ApplicationContext context) {
  22.         return new NacosRegistration(nacosDiscoveryProperties, context);
  23.     }
  25.     @Bean
  26.     @ConditionalOnBean({AutoServiceRegistrationProperties.class})
  27.     public NacosAutoServiceRegistration nacosAutoServiceRegistration(NacosServiceRegistry registry, AutoServiceRegistrationProperties autoServiceRegistrationProperties, NacosRegistration registration) {
  28.         return new NacosAutoServiceRegistration(registry, autoServiceRegistrationProperties, registration);
  29.     }
  30. }

NacosRegistration

  1. public class NacosRegistration implements Registration, ServiceInstance {
  2.     public static final String MANAGEMENT_PORT = "management.port";
  3.     public static final String MANAGEMENT_CONTEXT_PATH = "management.context-path";
  4.     public static final String MANAGEMENT_ADDRESS = "management.address";
  5.     public static final String MANAGEMENT_ENDPOINT_BASE_PATH = "management.endpoints.web.base-path";
  6.     private NacosDiscoveryProperties nacosDiscoveryProperties;
  7.     private ApplicationContext context;
  9.     public NacosRegistration(NacosDiscoveryProperties nacosDiscoveryProperties, ApplicationContext context) {
  10.         this.nacosDiscoveryProperties = nacosDiscoveryProperties;
  11.         this.context = context;
  12.     }
  14.     @PostConstruct
  15.     public void init() {
  16.         Map<String, String> metadata = this.nacosDiscoveryProperties.getMetadata();
  17.         Environment env = this.context.getEnvironment();
  18.         String endpointBasePath = env.getProperty("management.endpoints.web.base-path");
  19.         if (!StringUtils.isEmpty(endpointBasePath)) {
  20.             metadata.put("management.endpoints.web.base-path", endpointBasePath);
  21.         }
  23.         Integer managementPort = ManagementServerPortUtils.getPort(this.context);
  24.         if (null != managementPort) {
  25.             metadata.put("management.port", managementPort.toString());
  26.             String contextPath = env.getProperty("management.server.servlet.context-path");
  27.             String address = env.getProperty("management.server.address");
  28.             if (!StringUtils.isEmpty(contextPath)) {
  29.                 metadata.put("management.context-path", contextPath);
  30.             }
  32.             if (!StringUtils.isEmpty(address)) {
  33.                 metadata.put("management.address", address);
  34.             }
  35.         }
  37.         if (null != this.nacosDiscoveryProperties.getHeartBeatInterval()) {
  38.             metadata.put("preserved.heart.beat.interval", this.nacosDiscoveryProperties.getHeartBeatInterval().toString());
  39.         }
  41.         if (null != this.nacosDiscoveryProperties.getHeartBeatTimeout()) {
  42.             metadata.put("preserved.heart.beat.timeout", this.nacosDiscoveryProperties.getHeartBeatTimeout().toString());
  43.         }
  45.         if (null != this.nacosDiscoveryProperties.getIpDeleteTimeout()) {
  46.             metadata.put("preserved.ip.delete.timeout", this.nacosDiscoveryProperties.getIpDeleteTimeout().toString());
  47.         }
  49.     }
  50. }

NacosServiceRegistry

  1. public class NacosServiceRegistry implements ServiceRegistry<Registration> {
  2.     private static final Logger log = LoggerFactory.getLogger(NacosServiceRegistry.class);
  3.     private final NacosDiscoveryProperties nacosDiscoveryProperties;
  4.     private final NamingService namingService;
  6.     public NacosServiceRegistry(NacosDiscoveryProperties nacosDiscoveryProperties) {
  7.         this.nacosDiscoveryProperties = nacosDiscoveryProperties;
  8.         #这里会将namingService 注册进容器
  9.         this.namingService = nacosDiscoveryProperties.namingServiceInstance();
  10.     }
  12.     public NamingService namingServiceInstance() {
  13.         if (null != this.namingService) {
  14.             return this.namingService;
  15.         } else {
  16.             try {
  17.                     #这里通过构造器反射获取实例
  18.                 this.namingService = NacosFactory.createNamingService(this.getNacosProperties());
  19.             } catch (Exception var2) {
  20.                 log.error("create naming service error!properties={},e=,", this, var2);
  21.                 return null;
  22.             }
  24.             return this.namingService;
  25.         }
  26.     }
  27. }

NacosNamingService

  1. public class NacosNamingService implements NamingService {
  2.     private static final String DEFAULT_PORT = "8080";
  3.     private static final long DEFAULT_HEART_BEAT_INTERVAL;
  4.     private String namespace;
  5.     private String endpoint;
  6.     private String serverList;
  7.     private String cacheDir;
  8.     private String logName;
  9.     private HostReactor hostReactor;
  10.     private BeatReactor beatReactor;
  11.     private EventDispatcher eventDispatcher;
  12.     private NamingProxy serverProxy;
  14.     public NacosNamingService(String serverList) {
  15.         Properties properties = new Properties();
  16.         properties.setProperty("serverAddr", serverList);
  17.         this.init(properties);
  18.     }
  20.     public NacosNamingService(Properties properties) {
  21.         this.init(properties);
  22.     }
  24.     private void init(Properties properties) {
  25.         this.namespace = InitUtils.initNamespaceForNaming(properties);
  26.         this.initServerAddr(properties);
  27.         InitUtils.initWebRootContext();
  28.         this.initCacheDir();
  29.         this.initLogName(properties);
  30.         this.eventDispatcher = new EventDispatcher();
  31.         this.serverProxy = new NamingProxy(this.namespace, this.endpoint, this.serverList);
  32.         this.serverProxy.setProperties(properties);
  33.         this.beatReactor = new BeatReactor(this.serverProxy, this.initClientBeatThreadCount(properties));
  34.         this.hostReactor = new HostReactor(this.eventDispatcher, this.serverProxy, this.cacheDir, this.isLoadCacheAtStart(properties), this.initPollingThreadCount(properties));
  35.     }
  37.     private int initClientBeatThreadCount(Properties properties) {
  38.         return properties == null ? UtilAndComs.DEFAULT_CLIENT_BEAT_THREAD_COUNT : NumberUtils.toInt(properties.getProperty("namingClientBeatThreadCount"), UtilAndComs.DEFAULT_CLIENT_BEAT_THREAD_COUNT);
  39.     }
  40. }

NacosDiscoveryProperties

  1. @ConfigurationProperties("spring.cloud.nacos.discovery")
  2. public class NacosDiscoveryProperties {
  3.     private static final Logger log = LoggerFactory.getLogger(NacosDiscoveryProperties.class);
  4.     private String serverAddr;
  5.     private String endpoint; # 地域的某个服务的入口域名，通过此域名可以动态地拿到服务端地址
  6.     private String namespace;
  7.     private long watchDelay = 30000L;
  8.     private String logName;# 日志文件名
  9.     @Value("${spring.cloud.nacos.discovery.service:${spring.application.name:}}")
  10.     private String service;
  11.     private float weight = 1.0F;#取值范围 1 到 100，数值越大，权重越大
  12.     private String clusterName = "DEFAULT";
  13.     private String namingLoadCacheAtStart = "false";
  14.     private Map<String, String> metadata = new HashMap();#使用Map格式配置，用户可以根据自己的需要自定义一些和服务相关的元数据信息
  15.     private boolean registerEnabled = true;
  16.     private String ip;# 优先级最高
  17.     private String networkInterface = "";#当IP未配置时，注册的IP为此网卡所对应的IP地址，如果此项也未配置，则默认取第一块网卡的地址
  18.     private int port = -1;# 默认情况下不用配置，会自动探测
  19.     private boolean secure = false;
  20.     private String accessKey;# 当要上阿里云时，阿里云上面的一个云账号名
  21.     private String secretKey;# 当要上阿里云时，阿里云上面的一个云账号密码
  22.     private Integer heartBeatInterval;
  23.     private Integer heartBeatTimeout;
  24.     private Integer ipDeleteTimeout;
  25.     @Autowired
  26.     private InetUtils inetUtils;
  27.     @Autowired
  28.     private Environment environment;
  29.     private NamingService namingService;
  30.     private NamingMaintainService namingMaintainService;
  32.     public NacosDiscoveryProperties() {
  33.     }
  35.     @PostConstruct
  36.     public void init() throws SocketException {
  37.         this.metadata.put("preserved.register.source", "SPRING_CLOUD");
  38.         if (this.secure) {
  39.             this.metadata.put("secure", "true");
  40.         }
  42.         this.serverAddr = Objects.toString(this.serverAddr, "");
  43.         if (this.serverAddr.lastIndexOf("/") != -1) {
  44.             this.serverAddr = this.serverAddr.substring(0, this.serverAddr.length() - 1);
  45.         }
  47.         this.endpoint = Objects.toString(this.endpoint, "");
  48.         this.namespace = Objects.toString(this.namespace, "");
  49.         this.logName = Objects.toString(this.logName, "");
  50.         if (StringUtils.isEmpty(this.ip)) {
  51.             if (StringUtils.isEmpty(this.networkInterface)) {
  52.                 this.ip = this.inetUtils.findFirstNonLoopbackHostInfo().getIpAddress();
  53.             } else {
  54.                 NetworkInterface netInterface = NetworkInterface.getByName(this.networkInterface);
  55.                 if (null == netInterface) {
  56.                     throw new IllegalArgumentException("no such interface " + this.networkInterface);
  57.                 }
  59.                 Enumeration inetAddress = netInterface.getInetAddresses();
  61.                 while(inetAddress.hasMoreElements()) {
  62.                     InetAddress currentAddress = (InetAddress)inetAddress.nextElement();
  63.                     if (currentAddress instanceof Inet4Address && !currentAddress.isLoopbackAddress()) {
  64.                         this.ip = currentAddress.getHostAddress();
  65.                         break;
  66.                     }
  67.                 }
  69.                 if (StringUtils.isEmpty(this.ip)) {
  70.                     throw new RuntimeException("cannot find available ip from network interface " + this.networkInterface);
  71.                 }
  72.             }
  73.         }
  75.         this.overrideFromEnv(this.environment);
  76.     }
  77. }