查看Service的service.processClientBeat(clientBeat);方法：

public void processClientBeat(final RsInfo rsInfo) {ClientBeatProcessor clientBeatProcessor = new ClientBeatProcessor();clientBeatProcessor.setService(this);clientBeatProcessor.setRsInfo(rsInfo);HealthCheckReactor.scheduleNow(clientBeatProcessor); }

可以看到心跳信息被封裝到了 ClientBeatProcessor類中，交給了HealthCheckReactor處理，HealthCheckReactor就是對線程池的封裝，不用過多查看。

關鍵的業務邏輯都在ClientBeatProcessor這個類中，它是一個Runnable，其中的run方法如下：

@Override public void run() {Service service = this.service;if (Loggers.EVT_LOG.isDebugEnabled()) {Loggers.EVT_LOG.debug("[CLIENT-BEAT] processing beat: {}", rsInfo.toString());}String ip = rsInfo.getIp();String clusterName = rsInfo.getCluster();int port = rsInfo.getPort();// 獲取集群信息Cluster cluster = service.getClusterMap().get(clusterName);// 獲取集群中的所有實例信息List<Instance> instances = cluster.allIPs(true);for (Instance instance : instances) {// 找到心跳的這個實例if (instance.getIp().equals(ip) && instance.getPort() == port) {if (Loggers.EVT_LOG.isDebugEnabled()) {Loggers.EVT_LOG.debug("[CLIENT-BEAT] refresh beat: {}", rsInfo.toString());}// 更新實例的最后一次心跳時間 lastBeatinstance.setLastBeat(System.currentTimeMillis());if (!instance.isMarked()) {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);}}}} }

處理心跳請求的核心就是更新心跳實例的最后一次心跳時間，lastBeat，這個會成為判斷實例心跳是否過期的關鍵指標！

總結

以上是生活随笔為你收集整理的Nacos源码处理心跳请求的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。