SpringCloud 服務註冊中的nacos實現過程

如下圖,org.springframework.cloud.spring-cloud-commons包下定義瞭一系列接口,其中就包括serviceregistry的系列規范,並通過SPI機制去調用接口實現。

在該包的META-INF/spring.factories文件中,可以找到EnableAutoConfiguration.class為key的value中有AutoServiceRegistrationAutoConfiguration.class這一項。

來看看這個AutoServiceRegistrationAutoConfiguration配置類:

對應的,在com.alibaba.cloud.nacos包下(位於spring-cloud-starter-nacos-discovery jar包中)的META-INF/spring.fatories有個nacos服務註冊配置類,如下圖:

這個NacosServiceRegistryAutoConfiguration 配置類就定義瞭上面SpringCloud的AutoServiceRegistration接口的實現類:

package com.alibaba.cloud.nacos.registry;

...

/**
 * @author xiaojing
 * @author <a href="mailto:[email protected]" rel="external nofollow" >Mercy</a>
 */
@Configuration(proxyBeanMethods = false)
@EnableConfigurationProperties
@ConditionalOnNacosDiscoveryEnabled
@ConditionalOnProperty(value = "spring.cloud.service-registry.auto-registration.enabled",
		matchIfMissing = true)
@AutoConfigureAfter({ AutoServiceRegistrationConfiguration.class,
		AutoServiceRegistrationAutoConfiguration.class,
		NacosDiscoveryAutoConfiguration.class })
public class NacosServiceRegistryAutoConfiguration {

	@Bean
	public NacosServiceRegistry nacosServiceRegistry(
			NacosDiscoveryProperties nacosDiscoveryProperties) {
		return new NacosServiceRegistry(nacosDiscoveryProperties);
	}

	@Bean
	@ConditionalOnBean(AutoServiceRegistrationProperties.class)
	public NacosRegistration nacosRegistration(
			ObjectProvider<List<NacosRegistrationCustomizer>> registrationCustomizers,
			NacosDiscoveryProperties nacosDiscoveryProperties,
			ApplicationContext context) {
		return new NacosRegistration(registrationCustomizers.getIfAvailable(),
				nacosDiscoveryProperties, context);
	}
	/**
	 ** 這裡,這個NacosAutoServiceRegistration就是AutoServiceRegistration接口的實現類
	**/
	@Bean
	@ConditionalOnBean(AutoServiceRegistrationProperties.class)
	public NacosAutoServiceRegistration nacosAutoServiceRegistration(
			NacosServiceRegistry registry,
			AutoServiceRegistrationProperties autoServiceRegistrationProperties,
			NacosRegistration registration) {
		return new NacosAutoServiceRegistration(registry,
				autoServiceRegistrationProperties, registration);
	}

}

NacosAutoServiceRegistration中的register()方法開始註冊服務,整個調用流程為:

繼續追根溯源,這個registry()方法是在AbstractAutoServiceRegistration implements ApplicationListener<WebServerInitializedEvent>類的onApplicationEvent()方法(onApplicationEvent->bind->start->registey) 。
調用的心跳默認5秒一次,具體可參考BeatReactor類中的buildBeatInfo()方法,其中有個beatInfo.setPeriod(instance.getInstanceHeartBeatInterval());這裡獲取到一個常量5s。
更加詳細的流程可以參考:源碼閱讀|年輕人可以不講武德,但是你得會閱讀Naocs源碼

另外上面最後一步的NamingClientProxy接口的實現如下,利用到瞭委托模式(delegate)也叫代理模式?:

到此這篇關於SpringCloud 服務註冊中的nacos實現過程的文章就介紹到這瞭,更多相關SpringCloud 服務註冊nacos內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!

推薦閱讀: