Nacos

介绍

Dynamic Naming and Configuration Service
动态的命名和配置服务

反正可以实现注册中心的功能

注册中心架构

服务提供者
服务消费者
注册中心

1. 提供者告知注册中心可以提供服务的地址
2. 注册中心注册服务
3. 消费者拉取服务列表

面临问题

1. 提供者宕机怎么处理
   Nacos client 中会启动一个线程上报心跳，5s一次
   默认配置下 15s 没有上报心跳则 instance 健康状态切换为 false
   30s 没有上报则直接删除 instance

源码分析

实例注册-接口

Nacos 使用 Java 代码编写其实就是用的 Spring boot
查看官网 Open-API 注册实例接口是：@PostMapping /nacos/v1/ns/instance

实例注册-入口

com.alibaba.nacos.naming.controllers.InstanceController#register

//读取 request 传输的参数，组装成 instance
final Instance instance = parseInstance(request);
serviceManager.registerInstance(namespaceId, serviceName, instance);
return "ok"; 

registerInstance(namespaceId, serviceName, instance):

//如果缓存中不存在 则创建空的Service
createEmptyService(namespaceId, serviceName, instance.isEphemeral());
//从缓存中读取
Service service = getService(namespaceId, serviceName);
//注册实例
addInstance(namespaceId, serviceName, instance.isEphemeral(), instance);

实例注册-创建一个(Nacos)Service

createEmptyService(namespaceId, serviceName, instance.isEphemeral()):
createServiceIfAbsent(namespaceId, serviceName, local, null):

//根据 namespaceId, serviceName 去缓存中查询一下是否已经有 service 
Service service = getService(namespaceId, serviceName);
if (service == null) {
	//没有则注册
	service = new Service();
	//省略属性赋值
	...
	putServiceAndInit(service);
	//这个local就是是否临时的意思 是临时就返回 true 默认就是true
	if (!local) {
        addOrReplaceService(service);
    }
}

putServiceAndInit(service):

//Map<String, Map<String, Service>>
//key 为 namespaceId; value 为 Map<service.getName(), service>
putService(service);
//从缓存中获取
service = getService(service.getNamespaceId(), service.getName());
//注册一个 心跳检查任务
//维护一个 Map<String, Cluster> clusterMap 执行所有的 value.init()
service.init();
//注册对一个Servce 发生变动的监听
//最后一个参数是 是否是临时节点
String key = KeyBuilder.buildInstanceListKey(namespaceId(), name(), true);
consistencyService.listen(key , service);
key = KeyBuilder.buildInstanceListKey(namespaceId(), name(), false);
consistencyService.listen(key , service);

实例注册-注册(Nacos)Service

addInstance(namespaceId, serviceName, instance.isEphemeral(), instance):