查看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就是對(duì)線程池的封裝，不用過多查看。

關(guān)鍵的業(yè)務(wù)邏輯都在ClientBeatProcessor這個(gè)類中，它是一個(gè)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);// 獲取集群中的所有實(shí)例信息List<Instance> instances = cluster.allIPs(true);for (Instance instance : instances) {// 找到心跳的這個(gè)實(shí)例if (instance.getIp().equals(ip) && instance.getPort() == port) {if (Loggers.EVT_LOG.isDebugEnabled()) {Loggers.EVT_LOG.debug("[CLIENT-BEAT] refresh beat: {}", rsInfo.toString());}// 更新實(shí)例的最后一次心跳時(shí)間 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);}}}} }

處理心跳請(qǐng)求的核心就是更新心跳實(shí)例的最后一次心跳時(shí)間，lastBeat，這個(gè)會(huì)成為判斷實(shí)例心跳是否過期的關(guān)鍵指標(biāo)！

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。