当前位置：网站首页>Service registration of Nacos registry

Service registration of Nacos registry

2022-07-19 21:58:00 【InfoQ】


5 nacos Service registration of the registry

This article is based on nacos 1.1.4  Analysis of the source code

Nacos Provides SDK and Open API Realize service registration in the form of , The essence of both methods is the same ,SDK Method provides an access encapsulation , The bottom layer is based on HTTP  The agreement completes the requested , So we are directly based on Open API The request mode analyzes the service registration principle of the server .

/nacos/v1/ns/instance

The service interface request address provided by the service registration is nacos/v1/ns/instance, The implementation code is nacos-naming Under the InstanceController class ：

@RestController
@RequestMapping(UtilsAndCommons.NACOS_NAMING_CONTEXT + "/instance")
public class InstanceController {
 @CanDistro
 @PostMapping
 public String register(HttpServletRequest request) throws Exception {

 String serviceName = WebUtils.required(request, CommonParams.SERVICE_NAME);
 String namespaceId = WebUtils.optional(request, CommonParams.NAMESPACE_ID, Constants.DEFAULT_NAMESPACE_ID);

 serviceManager.registerInstance(namespaceId, serviceName, parseInstance(request));
 return "ok";
 }
}

call registerInstance Method ：

public void registerInstance(String namespaceId, String serviceName, Instance instance) throws NacosException {

 createEmptyService(namespaceId, serviceName, instance.isEphemeral());

 Service service = getService(namespaceId, serviceName);

 if (service == null) {
 throw new NacosException(NacosException.INVALID_PARAM,
 "service not found, namespace: " + namespaceId + ", service: " + serviceName);
 }

 addInstance(namespaceId, serviceName, instance.isEphemeral(), instance);
}

  • Create an empty service , It's actually initialization serviceMap
  • getService： from serviceMap According to the namespaceId and serviceName Get the service object
  • call addInstance Add service instance .

createEmptyService

createEmptyService Used to create an empty service , call createServiceIfAbsent

public void createServiceIfAbsent(String namespaceId, String serviceName, boolean local, Cluster cluster) throws NacosException {
 Service service = getService(namespaceId, serviceName);
 if (service == null) {

 Loggers.SRV_LOG.info("creating empty service {}:{}", namespaceId, serviceName);
 service = new Service();
 service.setName(serviceName);
 service.setNamespaceId(namespaceId);
 service.setGroupName(NamingUtils.getGroupName(serviceName));
 // now validate the service. if failed, exception will be thrown
 service.setLastModifiedMillis(System.currentTimeMillis());
 service.recalculateChecksum();
 if (cluster != null) {
 cluster.setService(service);
 service.getClusterMap().put(cluster.getName(), cluster);
 }
 service.validate();

 putServiceAndInit(service);
 if (!local) {
 addOrReplaceService(service);
 }
 }
}

  • according to namespaceId and serviceName From the cache Service example
  • without , Create and call putServiceAndInit() Save to cache .

putServiceAndInit Method ：

private void putServiceAndInit(Service service) throws NacosException {
 putService(service);
 service.init();
 consistencyService.listen(KeyBuilder.buildInstanceListKey(service.getNamespaceId(), service.getName(), true), service);
 consistencyService.listen(KeyBuilder.buildInstanceListKey(service.getNamespaceId(), service.getName(), false), service);
 Loggers.SRV_LOG.info("[NEW-SERVICE] {}", service.toJSON());
}

  • adopt putService Method to cache the service into memory
  • service.init(); Establish a heartbeat detection mechanism , Continuously detect the time when all instances of the current service last sent heartbeat packets through scheduled tasks . If the timeout , Is set healthy by false Indicates that the service is unhealthy , And send service change events .
  • consistencyService.listen Realize data consistency monitoring

summary ：

Nacos Provides SDK and Open API Realize service registration in the form of , The essence of both methods is the same

The service interface request address provided by the service registration is nacos/v1/ns/instance

Service registration process ：

  • nacos Client pass Open API Send a service registration request in the form of
  • The server receives the request ：
  • Construct a Service Object to save to Map Collection
  • Use a scheduled task to establish a heartbeat detection mechanism for all instances under the current service .
  • Synchronize service data based on data consistency protocol .nacos Service registration is very important for us , We need to understand the principle and registration process , Then analyze the source code , To better understand nacos How to realize the registration of services , Only in this way can we understand thoroughly nacos The operating mechanism of , What problems will we encounter in our work in the future , We can check in time , Rapid positioning , In this way, we can better improve efficiency and complete tasks in work and study . If you think this article is good , Please leave a comment like this ~~
原网站

版权声明
本文为[InfoQ]所创，转载请带上原文链接，感谢
https://yzsam.com/2022/200/202207181329465945.html

边栏推荐

猜你喜欢

随机推荐