服务发现与注册

服务发现与注册，是注册中心吗？

是。

但注册中心只是 各微服务治理方案中服务发现与注册的实现而已。

比如 eureka，nacos，zk等都是可以作为 dubbo与 spring cloud 的注册中心。

现在聊一下spring cloud  中 服务的注册与发现的抽象：

AbstractAutoServiceRegistration

这是一个抽象类。

1. 注入。

nacos中

@Bean
@ConditionalOnBean(AutoServiceRegistrationProperties.class)

public NacosAutoServiceRegistration nacosAutoServiceRegistration(

     NacosServiceRegistry registry,
     AutoServiceRegistrationProperties autoServiceRegistrationProperties,
     NacosRegistration registration) {

  return new NacosAutoServiceRegistration(registry,
        autoServiceRegistrationProperties, registration);
}

这个类通过@Bean 注入到spring 容器中。

2. 启动
   

AbstractAutoServiceRegistration 实现了ApplicationListener接口，监听了WebServerInitializedEvent事件。源码如下：

public void onApplicationEvent(WebServerInitializedEvent event) {

   this.bind(event);
}

-->

public void bind(WebServerInitializedEvent event) {

   ApplicationContext context = event.getApplicationContext();
   if (!(context instanceof ConfigurableWebServerApplicationContext) || !"management".equals(((ConfigurableWebServerApplicationContext)context).getServerNamespace())) {

       this.port.compareAndSet(0, event.getWebServer().getPort());
       this.start();
   }

}

-->

public void start() {

   if (!this.isEnabled()) {

       if (logger.isDebugEnabled()) {

           logger.debug("Discovery Lifecycle disabled. Not starting");
       }

   } else {

       if (!this.running.get()) {

           this.context.publishEvent(new InstancePreRegisteredEvent(this, this.getRegistration()));
           this.register();
           if (this.shouldRegisterManagement()) {

               this.registerManagement();
           }

           this.context.publishEvent(new InstanceRegisteredEvent(this, this.getConfiguration()));
           this.running.compareAndSet(false, true);
       }

   }

}

3. 注册

在上面的源码中。this.register() --> 就是服务的注册服务。

this.register()

-->this.serviceRegistry.register(this.getRegistration());

其中 serviceRegistry 的接口定义如下：

public interface ServiceRegistry<R extends Registration> {

   void register(R registration);

   void deregister(R registration);

   void close();

   void setStatus(R registration, String status);

   <T> T getStatus(R registration);
}

该接口具体的实现在各个注册中心中。已nacos为例为：NacosServiceRegistry。各个注册中心的实现不一样，请查看注册中心源码。

4.发现。

服务发现以springcloudalibaba为例：

在springboot启动时，注入了一个配置类

DubboServiceDiscoveryAutoConfiguration其中有一个方法实现了对HeartbeatEvent事件的监听

-->

@EventListener(HeartbeatEvent.class)

public void onHeartbeatEvent(HeartbeatEvent event) {

      ...//省略
           List<ServiceInstance> serviceInstances = getInstances(serviceName);      ...//省略
}

-->该方法调用了spring cloud的统一服务类DscoveryClient类中的服务发现接口

private List<ServiceInstance> getInstances(String serviceName) {

  return discoveryClient.getInstances(serviceName);
}

-->

假如配置的nacos为服务注册中心，那么实现类为 NacosDiscoveryClient。

那么 这个HeartbeatEvent事件由谁发布的呢？

在NacosDiscoveryClientConfiguration的配置类中，注入了一个配置类

@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty(value = "spring.cloud.nacos.discovery.watch.enabled",
     matchIfMissing = true)

public NacosWatch nacosWatch(NacosDiscoveryProperties nacosDiscoveryProperties,
     ObjectProvider<TaskScheduler> taskScheduler) {

  return new NacosWatch(nacosDiscoveryProperties, taskScheduler);
}

-->NacosWatch类中有一个方法

@Override
public void start() {

  if (this.running.compareAndSet(false, true)) {

     this.watchFuture = this.taskScheduler.scheduleWithFixedDelay(

           this::nacosServicesWatch, this.properties.getWatchDelay());
  }

}

-->

public void nacosServicesWatch() {

  // nacos doesn't support watch now , publish an event every 30 seconds.
  this.publisher.publishEvent(

        new HeartbeatEvent(this, nacosWatchIndex.getAndIncrement()));

}

这个类实现了SmartLifecycle接口（当Spring容器加载所有bean并完成初始化之后，会接着回调实现该接口的类中对应的方法（start()方法））

因此，nacos的服务发现是在spring容器加载为所有bean之后，通过NacosWatch发布HeartbeatEvent 事件，DubboServiceDiscoveryAutoConfiguration中的中实现监听这个事件来完成的。

剧终！！！

参考：https://blog.csdn.net/qq_42651904/article/details/121876171