InstanceController: 处理器, 处理服务实例的心跳和注册等请求。
core/Service: 在Nacos客户端的一个微服务名称定义的微服务, 在Nacos服务端是以Service实例的形式出现的。类似于ServiceInfo, ServiceInfo为客户端服务, Service为服务端服务。
RecordListener: Service类实现了RecordListener接口, 这个接口为数据监听接口, 所以Service本身是一个监听器, 可以监听指定数据的变化和删除。
Record: RecordListener接口的泛型为指定了该监听器所要监听的实体类型, 这个类型是一个Record的子接口, Record是Nacos集群传输和存储的记录。
Cluster: 提供某一服务的Instance集群, 和Service为n: 1的状态, Service为1。
Instance: 注册到Nacos中的具体服务实例。
ServiceManager: Nacos中所有service的核心管理者。其中serviceMap属性为Nacos中的服务注册表。
Synchronizer: 同步器。当前Nacos主动发起同步操作。包含两个方法, 一个是当前Nacos主动发送自己的Message给指定Nacos和主动向指定的Nacos获取指定key的Message。
1.InstanceController
处理服务实例的心跳和注册等请求。
2.core/Service
继承pojo/Service, 实现Record和RecordListener接口。
Service类中有一个属性protectThreshold, 为阈值。
与Eureka中的保护阈值对比:
-
相同点: 0-1, 表示健康实例占所有实例的比例
-
保护方式不同:
-
Eureka: 一旦健康实例数量小于阈值, 则不再从注册表中清除不健康的实例
-
Nacos: 如果健康实例数量大于阈值, 则消费者调用到的都是健康实例。一旦健康实例数量小于阈值, 则消费者会从所有实例中进行选择调用, 有可能会调用到不健康实例。这样可以保护健康的实例不会被压崩溃。
-
范围不同:
-
Eureka: 这个阈值针对的是所有服务中的实例
-
Nacos: 这个阈值针对的是当前Service中的服务实例
private int finalizeCount = 0;
private String token;
private List<String> owners = new ArrayList<>();
private Boolean resetWeight = false;
private Boolean enabled = true;
private Selector selector = new NoneSelector();
private String namespaceId;
/**
* IP will be deleted if it has not send beat for some time, default timeout is 30 seconds.
*/
private long ipDeleteTimeout = 30 * 1000;
private volatile long lastModifiedMillis = 0L;
// 校验和，是当前Service的所有SCI信息的字符串拼接
private volatile String checksum;
/**
* TODO set customized push expire time.
*/
private long pushCacheMillis = 0L;
// 重要集合
// key为clusterName
// value为Cluster实例
private Map<String, Cluster> clusterMap = new HashMap<>();
3.RecordListener接口和Record接口
RecordListener是数据监听接口
// 泛型指定了当前监听器正在监听的数据类型
public interface RecordListener<T extends Record> {
/**
* Determine if the listener was registered with this key.
* 判断当前监听器是否监听着指定key的数据
*
* @param key candidate key
* @return true if the listener was registered with this key
*/
boolean interests(String key);
/**
* Determine if the listener is to be removed by matching the 'key'.
* 判断当前监听器是否已经不再监听当前指定key的数据
*
* @param key key to match
* @return true if match success
*/
boolean matchUnlistenKey(String key);
/**
* Action to do if data of target key has changed.
* 若指定key的数据发生了变更，则触发该方法的执行
*
* @param key target key
* @param value data of the key
* @throws Exception exception
*/
void onChange(String key, T value) throws Exception;
/**
* Action to do if data of target key has been removed.
* 若指定key的数据被删除，则触发该方法的执行
*
* @param key target key
* @throws Exception exception
*/
void onDelete(String key) throws Exception;
}
Record是Nacos集群传输和存储的记录。
public interface Record {
/**
* get the checksum of this record, usually for record comparison.
*
* @return checksum of record
*/
String getChecksum();
}
4.Cluster类和Instance类
Cluster类: 提供某一服务的Instance集群, 即隶属于某一Service的Instance集群。
Instance: 注册到Nacos中的具体服务实例。
5.ServiceManager类
ServiceManager: Nacos中所有service的核心管理者。其中serviceMap属性为Nacos Server端的服务注册表。
serviceMap为Naocs Server端的服务注册表。serviceInfoMap为Nacos Client端的服务注册表
6.Synchronizer
service状态同步器
public interface Synchronizer {
/**
* Send message to server.
* 将msg发送给指定的server
*
* @param serverIP target server address
* @param msg message to send
*/
void send(String serverIP, Message msg);
/**
* Get message from server using message key.
*
* @param serverIP source server address
* @param key message key
* @return message
*/
Message get(String serverIP, String key);
}
send方法为将msg发送给指定的server, get方法为得到指定server的msg。
