Eureka源码11-Server端定时清除过期Client，方法入口及核心方法openForTraffic()

2024-01-14 03:31:02

引言

Eureka是一个广泛使用的服务发现框架，它为Spring Cloud微服务架构提供了服务注册和发现的功能。Eureka Server端负责存储和管理服务实例信息，并提供查询接口供客户端使用。为了确保服务实例信息的准确性和可靠性，Eureka Server端需要定期清除过期的客户端注册信息。本文将介绍Eureka源码中Server端定时清除过期Client的实现，包括方法入口和核心方法openForTraffic()的解析。

Eureka Server端的定时清除任务

Eureka Server端使用定时任务来清除过期的客户端注册信息。定时任务的执行周期由eureka.server.eviction-interval-timer-in-ms属性控制，默认值为30秒。当定时任务执行时，Eureka Server端会扫描所有注册的客户端，并检查它们的最后一次心跳时间。如果某个客户端的最后一次心跳时间超过了eureka.server.renewal-threshold-in-secs属性指定的阈值（默认值为60秒），则该客户端会被标记为已过期，并从注册中心中清除。

`openForTraffic()`方法解析

openForTraffic()方法是Eureka Server端用于清除过期Client的核心方法。该方法首先获取所有注册的客户端，然后遍历每个客户端，检查它们的最后一次心跳时间。如果某个客户端的最后一次心跳时间超过了eureka.server.renewal-threshold-in-secs属性指定的阈值，则该客户端会被标记为已过期，并从注册中心中清除。

protected void openForTraffic(StatusUpdate statusUpdate) {
        logger.info("Traffic flow is being allowed for instance: " + statusUpdate);
        getApplication().getApplications().setStatus(statusUpdate.getApplicationName(), statusUpdate.getInstanceId(), InstanceStatus.UP);
        registry.renew(statusUpdate, false);
    }

openForTraffic()方法的具体实现如下：

首先，该方法获取所有注册的客户端，并遍历每个客户端。
然后，该方法检查每个客户端的最后一次心跳时间。如果某个客户端的最后一次心跳时间超过了eureka.server.renewal-threshold-in-secs属性指定的阈值，则该客户端会被标记为已过期，并从注册中心中清除。
最后，该方法将所有过期的客户端从注册中心中清除。