nacos客户端语言c,Nacos客户端注册

Nacos - 启动中提到了注册的入口&＃xff0c;这里就讲一下注册的细节。

Tomcat启动成功后&＃xff0c;会调用AbstractAutoServiceRegistration的onApplicationEvent方法&＃xff0c;他会继续调用AbstractAutoServiceRegistration#bind。

AbstractAutoServiceRegistration#bind

public void bind(WebServerInitializedEvent event) { ApplicationContext context &＃61; event.getApplicationContext(); if (context instanceof ConfigurableWebServerApplicationContext) { if ("management".equals(((ConfigurableWebServerApplicationContext) context) .getServerNamespace())) { return; } } // 设置端口号 this.port.compareAndSet(0, event.getWebServer().getPort()); this.start();

}

AbstractAutoServiceRegistration#start

public void start() { if (!isEnabled()) { if (logger.isDebugEnabled()) { logger.debug("Discovery Lifecycle disabled. Not starting"); } return; } // only initialize if nonSecurePort is greater than 0 and it isn&＃39;t already running // because of containerPortInitializer below // 没启动过才注册 if (!this.running.get()) { // 发布InstancePreRegisteredEvent事件 this.context.publishEvent( new InstancePreRegisteredEvent(this, getRegistration())); // 注册 register(); if (shouldRegisterManagement()) { // 注册registerManagement registerManagement(); } // 发布InstanceRegisteredEvent事件 this.context.publishEvent( new InstanceRegisteredEvent<>(this, getConfiguration())); // 设置状态为启动 this.running.compareAndSet(false, true); }

}

NacosAutoServiceRegistration#register

protected void register() { if (!this.registration.getNacosDiscoveryProperties().isRegisterEnabled()) { log.debug("Registration disabled."); return; } // 小于0重新设置端口 if (this.registration.getPort() <0) { this.registration.setPort(getPort().get()); } super.register();

}

AbstractAutoServiceRegistration#register

registration的注入在启动的时候已经说过了。

protected void register(){ this.serviceRegistry.register(getRegistration());

}

NacosServiceRegistry#register

封装好Instance后&＃xff0c;调用NacosNamingService的registerInstance方法注册。Nacos - NacosNamingService初始化以及几个其他定时任务已经讲过了。

public void register(Registration registration){ if (StringUtils.isEmpty(registration.getServiceId())) { log.warn("No service to register for nacos client..."); return; } // 获取NacosNamingService NamingService namingService &＃61; namingService(); // 获取serviceId String serviceId &＃61; registration.getServiceId(); String group &＃61; nacosDiscoveryProperties.getGroup(); // 获取Instance&＃xff0c;一些信息从registration读取&＃xff0c;一些从nacosDiscoveryProperties读取 Instance instance &＃61; getNacosInstanceFromRegistration(registration); try { // 注册 namingService.registerInstance(serviceId, group, instance); log.info("nacos registry, {} {} {}:{} register finished", group, serviceId, instance.getIp(), instance.getPort()); } catch (Exception e) { log.error("nacos registry, {} register failed...{},", serviceId, registration.toString(), e); // rethrow a RuntimeException if the registration is failed. // issue : https://github.com/alibaba/spring-cloud-alibaba/issues/1132 rethrowRuntimeException(e); }

}

NacosNamingService#registerInstance

封装心跳信息、开启定时任务续约以及调用serverProxy注册&＃xff0c;这个url是/nacos/v1/ns/instance。

public void registerInstance(String serviceName, String groupName, Instance instance) throws NacosException { String groupedServiceName &＃61; NamingUtils.getGroupedName(serviceName, groupName); if (instance.isEphemeral()) { // 封装心跳信息 BeatInfo beatInfo &＃61; beatReactor.buildBeatInfo(groupedServiceName, instance); // 开启定时任务续约 beatReactor.addBeatInfo(groupedServiceName, beatInfo); } serverProxy.registerService(groupedServiceName, groupName, instance);

}

文章来源: segmentfault.com&＃xff0c;作者&＃xff1a;大军&＃xff0c;版权归原作者所有&＃xff0c;如需转载&＃xff0c;请联系作者。

原文链接&＃xff1a;segmentfault.com/a/1190000038811549