举报网站怎么做,邯郸网站制作个人,湖州网站集约化平台,宝山品牌网站建设一、引言 在 Nacos 后台管理服务列表中#xff0c;我们可以看到微服务列表#xff0c;其中有一栏叫“健康实例数” #xff08;如下图#xff09;#xff0c;表示对应的客户端实例信息是否可用状态。 那Nacos服务端是怎么感知客户端的状态是否可用呢 #xff1f; 本章…一、引言 在 Nacos 后台管理服务列表中我们可以看到微服务列表其中有一栏叫“健康实例数” 如下图表示对应的客户端实例信息是否可用状态。 那Nacos服务端是怎么感知客户端的状态是否可用呢 本章重点 实例心跳接口做了哪些事情 服务端是怎么维护不健康的实例的怎么下线不健康实例的做了哪些操作 二、目录
目录
一、引言
二、目录
三、服务端实例心跳接口源码分析
四、服务端实例心跳健康检查定时任务源码分析
五、总结 三、服务端实例心跳接口源码分析
主线任务实例心跳接口做了哪些事情 在客户端服务发起注册的时候 (在第二章节)会开启一个心跳任务每5s发送一次健康心跳检查告诉服务端我这个服务还活着。前面已经讲过 public JsonNode sendBeat(BeatInfo beatInfo, boolean lightBeatEnabled) throws NacosException {if (NAMING_LOGGER.isDebugEnabled()) {NAMING_LOGGER.debug([BEAT] {} sending beat to server: {}, namespaceId, beatInfo.toString());}// 组装请求参数MapString, String params new HashMapString, String(8);MapString, String bodyMap new HashMapString, String(2);if (!lightBeatEnabled) {bodyMap.put(beat, JacksonUtils.toJson(beatInfo));}params.put(CommonParams.NAMESPACE_ID, namespaceId);params.put(CommonParams.SERVICE_NAME, beatInfo.getServiceName());params.put(CommonParams.CLUSTER_NAME, beatInfo.getCluster());params.put(ip, beatInfo.getIp());params.put(port, String.valueOf(beatInfo.getPort()));// 发送实例心跳接口请求String result reqApi(UtilAndComs.nacosUrlBase /instance/beat, params, bodyMap, HttpMethod.PUT);return JacksonUtils.toObj(result);
} 服务端接受到实例心跳接口会现在内存注册表中找 Instance如果找不到会重新注册。然后提交一个 clientBeatProcessor 异步任务更改 lastBeat 属性 CanDistro
PutMapping(/beat)
Secured(parser NamingResourceParser.class, action ActionTypes.WRITE)
public ObjectNode beat(HttpServletRequest request) throws Exception {// 省略部分代码// 获取请求参数namespaceId、serviceNameString namespaceId WebUtils.optional(request, CommonParams.NAMESPACE_ID, Constants.DEFAULT_NAMESPACE_ID);String serviceName WebUtils.required(request, CommonParams.SERVICE_NAME);NamingUtils.checkServiceNameFormat(serviceName);Loggers.SRV_LOG.debug([CLIENT-BEAT] full arguments: beat: {}, serviceName: {}, clientBeat, serviceName);// 通过namespaceId、serviceName、ip、port、clusterName 从内存注册表当中获取对应的 Instance 实例对象Instance instance serviceManager.getInstance(namespaceId, serviceName, clusterName, ip, port);// 如果 instance 为空那么会重新注册if (instance null) {if (clientBeat null) {result.put(CommonParams.CODE, NamingResponseCode.RESOURCE_NOT_FOUND);return result;}instance new Instance();instance.setPort(clientBeat.getPort());instance.setIp(clientBeat.getIp());instance.setWeight(clientBeat.getWeight());instance.setMetadata(clientBeat.getMetadata());instance.setClusterName(clusterName);instance.setServiceName(serviceName);instance.setInstanceId(instance.getInstanceId());instance.setEphemeral(clientBeat.isEphemeral());// 这里调用重新注册的方法serviceManager.registerInstance(namespaceId, serviceName, instance);}// 通过namespaceId、serviceName获取对应的 ServiceService service serviceManager.getService(namespaceId, serviceName);if (service null) {throw new NacosException(NacosException.SERVER_ERROR,service not found: serviceName namespaceId);}if (clientBeat null) {clientBeat new RsInfo();clientBeat.setIp(ip);clientBeat.setPort(port);clientBeat.setCluster(clusterName);}// 重点开启异步任务更改 lastBeat 属性service.processClientBeat(clientBeat);// 省略部分代码return result;
} 接着往下看重点 service.processClientBeat() 任务这个方法会开启一个异步任务异步任务的话肯定会有run 方法那我们直接看 clientBeatProcessor 对象中的 run 方法 public void processClientBeat(final RsInfo rsInfo) {ClientBeatProcessor clientBeatProcessor new ClientBeatProcessor();clientBeatProcessor.setService(this);clientBeatProcessor.setRsInfo(rsInfo);// 立即执行HealthCheckReactor.scheduleNow(clientBeatProcessor);
} 在异步任务当中首先会获取当前节点下所有的临时实例然后通过 ipport 找到当前 instance然后把 instance 中的 lastBeat属性更改为当前时间并且如果 该 instance 为不健康状态更改为健康状态 public class ClientBeatProcessor implements Runnable {public static final long CLIENT_BEAT_TIMEOUT TimeUnit.SECONDS.toMillis(15);private RsInfo rsInfo;private Service service;JsonIgnorepublic PushService getPushService() {return ApplicationUtils.getBean(PushService.class);}public RsInfo getRsInfo() {return rsInfo;}public void setRsInfo(RsInfo rsInfo) {this.rsInfo rsInfo;}public Service getService() {return service;}public void setService(Service service) {this.service service;}Overridepublic void run() {Service service this.service;if (Loggers.EVT_LOG.isDebugEnabled()) {Loggers.EVT_LOG.debug([CLIENT-BEAT] processing beat: {}, rsInfo.toString());}// 本小节重点方法// 获取当前 ip、clusterNameString ip rsInfo.getIp();String clusterName rsInfo.getCluster();int port rsInfo.getPort();Cluster cluster service.getClusterMap().get(clusterName);// 获取当前 cluster 下所有的临时实例ListInstance instances cluster.allIPs(true);// 遍历临时实例for (Instance instance : instances) {// 通过判断ip、port确认是否是当前 instance 的实例if (instance.getIp().equals(ip) instance.getPort() port) {if (Loggers.EVT_LOG.isDebugEnabled()) {Loggers.EVT_LOG.debug([CLIENT-BEAT] refresh beat: {}, rsInfo.toString());}// 把 lastBeat属性更改为当前时间instance.setLastBeat(System.currentTimeMillis());if (!instance.isMarked()) {// 如果 instance 为不健康状态更改为健康状态if (!instance.isHealthy()) {instance.setHealthy(true);Loggers.EVT_LOG.info(service: {} {POS} {IP-ENABLED} valid: {}:{}{}, region: {}, msg: client beat ok,cluster.getService().getName(), ip, port, cluster.getName(),UtilsAndCommons.LOCALHOST_SITE);getPushService().serviceChanged(service);}}}}}
} 小结 首先在 客户端服务发起注册的时候 (在第二章节)会开启一个心跳任务每5s发送一次健康心跳检查告诉服务端我这个服务还活着。前面已经讲过 那么服务端接受到了 实例心跳接口的请求会现在内存注册表中找 Instance如果找不到会重新注册。然后提交一个 clientBeatProcessor 异步任务在异步任务当中首先会找到当前集群下的所有临时实例然后通过 ip port 找到当前instance 实例把当前instance 中的 lastBeat属性更改为当前时间如果 instance 为不健康状态更改为健康状态到此实例心跳接口就结束了。 四、服务端实例心跳健康检查定时任务源码分析
主线任务服务端是怎么维护不健康的实例的怎么下线不健康实例的做了哪些操作 这块代码是在服务端 register注册接口当中的之前分析过 register 注册逻辑因为这块是分支代码前面没细看。 我们来看下 createEmptyService 这个方法了里面有个异步任务作用就是检查有哪些客户端是不健康的状态如果不健康就需要对它进行处理 public void registerInstance(String namespaceId, String serviceName, Instance instance) throws NacosException {// 不知道是创建了一个什么服务createEmptyService(namespaceId, serviceName, instance.isEphemeral());// 根据namespaceId、serviceName获取 Service服务Service service getService(namespaceId, serviceName);// service为空就抛出异常if (service null) {throw new NacosException(NacosException.INVALID_PARAM,service not found, namespace: namespaceId , service: serviceName);}// 上面都是分支代码// 主线任务:添加服务实例addInstance(namespaceId, serviceName, instance.isEphemeral(), instance);
} 我们直接看重点代码直接跳到开启异步任务这里。上面的代码流程createEmptyService()- createServiceIfAbsent()- putServiceAndInit(service) - service.init(); public void init() {// 开启异步延时任务 clientBeatCheckTask 每5s执行一次HealthCheckReactor.scheduleCheck(clientBeatCheckTask);for (Map.EntryString, Cluster entry : clusterMap.entrySet()) {entry.getValue().setService(this);entry.getValue().init();}
} 本章重点开启了一个 clientBeatCheckTask 异步任务。 Override
public void run() {try {// 本章重点// 获取全部临时实例ListInstance instances service.allIPs(true);for (Instance instance : instances) {// 当前时间 - instance中 lastBeat属性时间 15sif (System.currentTimeMillis() - instance.getLastBeat() instance.getInstanceHeartBeatTimeOut()) {if (!instance.isMarked()) {if (instance.isHealthy()) {// 如果这个 instance 实例还是健康状态就更改为 不健康状态instance.setHealthy(false);Loggers.EVT_LOG.info({POS} {IP-DISABLED} valid: {}:{}{}{}, region: {}, msg: client timeout after {}, last beat: {},instance.getIp(), instance.getPort(), instance.getClusterName(),service.getName(), UtilsAndCommons.LOCALHOST_SITE,instance.getInstanceHeartBeatTimeOut(), instance.getLastBeat());// 事件发布监听事件通过 upd 协议发送通知getPushService().serviceChanged(service);ApplicationUtils.publishEvent(new InstanceHeartbeatTimeoutEvent(this, instance));}}}}if (!getGlobalConfig().isExpireInstance()) {return;}// 这里还是遍历 临时实例for (Instance instance : instances) {if (instance.isMarked()) {continue;}// 当前时间 - instance中 lastBeat属性时间 30sif (System.currentTimeMillis() - instance.getLastBeat() instance.getIpDeleteTimeout()) {Loggers.SRV_LOG.info([AUTO-DELETE-IP] service: {}, ip: {}, service.getName(),JacksonUtils.toJson(instance));// 直接从注册表中删除当前 instancedeleteIp(instance);}}} catch (Exception e) {Loggers.SRV_LOG.warn(Exception while processing client beat time out., e);}}
小结 第一个循环的作用为了筛选出不健康的 Instance 实例并且把 Instance 中的 healthy 属性改为 false。那么怎么筛选出不健康的实例的 利用的就是 Instance 中的 lastBeat 属性。如果是健康的实例那么客户端就会每5s调一次实例心跳接口更新 lastBeat 属性为当前时间。如果是不健康的实例那么 Instance 实例 中的 lastBeat 属性是不会变化的一旦 lastBeat 跟当前时间比超过 15s就会被认定为不健康的实例。第二个循环的作用找出那些 Instance 是需要删除的如果 lastBeat 跟当前时间比超过 30sNacos 会把该 Instance 从注册表当中进行删除。 五、总结
总结 本章讲了Nacos怎么维护整个微服务实例健康状态的流程在客户端发起注册服务时会有心跳任务每5s给服务端发送一次心态服务端会把该 Instance 实例中的lastBeat 属性更新为当前时间。并且在服务端实例注册的时候会开启心跳健康检查任务把 lastBeat 跟当前时间比超过 15s就会被标识为不健康的实例把lastBeat 跟当前时间比超过 30sNacos 会把该 Instance 从注册表当中进行删除。 最后的最后别忘了把源码分析图补充完整
