Client service registration of Nacos registry

4 nacos Client service registration of the registry

register() Method

Nacos The core method of service registration is NacosServiceRegistry Of register Method ：

public void register(Registration registration) {
 if (StringUtils.isEmpty(registration.getServiceId())) {
 log.warn("No service to register for nacos client...");
 } else {
 String serviceId = registration.getServiceId();
 String group = this.nacosDiscoveryProperties.getGroup();
 Instance instance = this.getNacosInstanceFromRegistration(registration);

 try {
 this.namingService.registerInstance(serviceId, group, instance);
 log.info("nacos registry, {} {} {}:{} register finished", new Object[]{group, serviceId, instance.getIp(), instance.getPort()});
 } catch (Exception var6) {
 log.error("nacos registry, {} register failed...{},", new Object[]{serviceId, registration.toString(), var6});
 ReflectionUtils.rethrowRuntimeException(var6);
 }

 }
}


First judge the corresponding ServiceId Is it empty , If it is not empty, get serviceId、group and instance, Then we call... In the method Nacos Client  Of registerInstance Complete service registration , Let's take a look registerInstance() Method implementation

registerInstance() Method ：

@Override
public void registerInstance(String serviceName, String groupName, Instance instance) throws NacosException {

 if (instance.isEphemeral()) {
 BeatInfo beatInfo = new BeatInfo();
 beatInfo.setServiceName(NamingUtils.getGroupedName(serviceName, groupName));
 beatInfo.setIp(instance.getIp());
 beatInfo.setPort(instance.getPort());
 beatInfo.setCluster(instance.getClusterName());
 beatInfo.setWeight(instance.getWeight());
 beatInfo.setMetadata(instance.getMetadata());
 beatInfo.setScheduled(false);
 long instanceInterval = instance.getInstanceHeartBeatInterval();
 beatInfo.setPeriod(instanceInterval == 0 ? DEFAULT_HEART_BEAT_INTERVAL : instanceInterval);

 beatReactor.addBeatInfo(NamingUtils.getGroupedName(serviceName, groupName), beatInfo);
 }

 serverProxy.registerService(NamingUtils.getGroupedName(serviceName, groupName), groupName, instance);
}


• First, create BeatInfo object , And fill in the relevant attribute information ,BeatInfo Is to save the relevant information of the instance heartbeat , Include ip Address 、 Port number 、 In the cluster 、 Weight information, etc

• adopt beatReactor.addBeatInfo Create heartbeat information to realize health monitoring , Parameters have ServiceName、groupName And heartbeat instance objects , So as to determine which service and which group are the following instances ,Naocs Server You must ensure that the registered service instance is healthy , And heartbeat detection is the means to serve health testing

• serverProxy.registerService Implement service registration .

addBeatInfo Method ：

public void addBeatInfo(String serviceName, BeatInfo beatInfo) {
 NAMING_LOGGER.info("[BEAT] adding beat: {} to beat map.", beatInfo);
 String key = buildKey(serviceName, beatInfo.getIp(), beatInfo.getPort());
 BeatInfo existBeat = null;
 //fix #1733
 if ((existBeat = dom2Beat.remove(key)) != null) {
 existBeat.setStopped(true);
 }
 dom2Beat.put(key, beatInfo);
 executorService.schedule(new BeatTask(beatInfo), beatInfo.getPeriod(), TimeUnit.MILLISECONDS);
 MetricsMonitor.getDom2BeatSizeMonitor().set(dom2Beat.size());
}


The so-called heartbeat mechanism is that the client passes schedule Method sends a data packet to the server regularly , Then start a thread to continuously detect the response from the server , If no response is received from the server within the set time , The server is considered to have failed .Nacos The server constantly updates the service status according to the heartbeat packet of the client .

registerService() Method

The next step is serverProxy.registerService Register the service , Entering the method, you can see that it is actually a HTTP Agreed POST request , That is to say Nacos Provides Open API To register services ,SDK It was packaged , The content of the source code is not pasted here

summary

Let's summarize ,nacos The registration of services is realized by calling NacosServiceRegistry Of register() Method , Get from method serviceId and group Etc , structure BeatInfo Heartbeat instance object , The thread sends through the timer BeatInfo Heartbeat information , So that the server can always know whether the service is running well , The real registration is serverProxy.registerService() Register the service , The essence is sending POST Request to nacos Server side . We will analyze in the next article nacos What does the server do for service registration .