eureka在关闭自我保护情况下过期服务不及时下线问题跟踪

　　1、微服务中使用eureka注册中心的三种角色eureka server注册中心
　　注册中心作为存储服务，提供各种服务提供方注册的服务信息，eureka正常启动后可使用 http://localhost:8761/  查看已注册的服务信息及相关配置信息，http://localhost:8761/eureka/apps/feign-service  可查看某个服务的明细信息，其中feign-service  即服务的名称。eureka:   server:     enable-self-preservation: false     eviction-interval-timer-in-ms: 10000
　　参数 enable-self-preservation  为是否开启eureka自我保护参数，eviction-interval-timer-in-ms  为清除过期服务时间间隔，如设置成每10秒清除一次过期服务，启动eureka注册中心服务后每间隔10秒会有Running the evict task with compensationTime 3ms  日志；服务提供方
　　将服务信息注册到eureka注册中心，并可配置维持心跳检测（续期）时间((默认30秒)及过期时间(默认90秒)。 eureka:   client:     register-with-eureka: true     fetch-registry: true   instance:     lease-renewal-interval-in-seconds: 1     lease-expiration-duration-in-seconds: 10
　　register-with-eureka  表示是否将服务注册到eureka中，服务提供方应设置为true  ；fetch-registry  表示是否从注册中心获取配置，服务消费方应配置为true  ；lease-renewal-interval-in-seconds  表示续期时间间隔，即1秒心跳检测一次，为了演示方便调短时间；lease-expiration-duration-in-seconds  续期超时时间，即超过此时间后服务检测不到心跳即过期。服务消费方
　　从注册中心获取需要调用的服务提供方相关信息 2、跟踪失效服务的清除
　　将注册中心的清除时间间隔 eviction-interval-timer-in-ms  改为1000  ，即每秒钟触发一次清除过期服务；
　　将服务提供方心跳检测时间 lease-renewal-interval-in-seconds  改为1  ，每秒续一次时间，并将过期时间lease-expiration-duration-in-seconds  设置为10  ，即应该在10  秒后没有收到心跳即过期，启动服务后可在注册中心查看相关的参数是否生效http://localhost:8761/eureka/apps/feign-service  ，在instance->leaseInfo  中可看到以下配置；1 10
　　按照以上的设置，如果服务提供方在 6:00:00  的时间挂掉的话，按eureka每秒清除一次过期服务，且服务提供方的续期过期时间10秒  ，服务应该在6:00:11  左右的时间清除掉，而实际上服务却是在6:00:21  左右的时间点才清除；经过反复的测试验证没有按这个预期内的时间清除掉这个服务；
　　最后在源码中找到答案
　　查看类 com.netflix.eureka.registry.AbstractInstanceRegistry  中的public void evict(long additionalLeaseMs)  方法，因为演示中只注册了一个服务，所以省略掉其他非关键部分如下// We collect first all expired items, to evict them in random order. For large eviction sets, // if we do not that, we might wipe out whole apps before self preservation kicks in. By randomizing it, // the impact should be evenly distributed across all applications. List> expiredLeases = new ArrayList<>(); for (Entry>> groupEntry : registry.entrySet()) {     Map> leaseMap = groupEntry.getValue();     if (leaseMap != null) {         for (Entry> leaseEntry : leaseMap.entrySet()) {             Lease lease = leaseEntry.getValue();             if (lease.isExpired(additionalLeaseMs) && lease.getHolder() != null) {                 expiredLeases.add(lease);             }         }     } }
　　大概意思是收集到全部过期的服务，并随机清除，其中最关键的部分 isExpired  判断如下/**  * Checks if the lease of a given {@link com.netflix.appinfo.InstanceInfo} has expired or not.  *  * Note that due to renew() doing the ＂wrong＂ thing and setting lastUpdateTimestamp to +duration more than  * what it should be, the expiry will actually be 2 * duration. This is a minor bug and should only affect  * instances that ungracefully shutdown. Due to possible wide ranging impact to existing usage, this will  * not be fixed.  *  * @param additionalLeaseMs any additional lease time to add to the lease evaluation in ms.  */ public boolean isExpired(long additionalLeaseMs) {     return (evictionTimestamp > 0 || System.currentTimeMillis() > (lastUpdateTimestamp + duration + additionalLeaseMs)); }
　　这里解析了 renew()  这个方法做了错误的事情，使用lastUpdateTimestamp  加了duration  ，所以实际的过期是2  倍的duration  时间，接下来看看类com.netflix.eureka.lease.Lease  中的renew()  方法；/**  * Renew the lease, use renewal duration if it was specified by the  * associated {@link T} during registration, otherwise default duration is  * {@link #DEFAULT_DURATION_IN_SECS}.  */ public void renew() {     lastUpdateTimestamp = System.currentTimeMillis() + duration;  }
　　果然是在最后更新时间中增加了 duration  ，在演示中去掉这个duration  即符合预期了
　　通常情况下如果我们需要平滑升级服务，需要先将原来的微服务逐个标识成OUT_OF_SERVICE，curl -X PUT http://root:password@localhost:8761/eureka/apps/feign-service/localhost:feign-service:8888/status?value=OUT_OF_SERVICE，在下一个续约周期中将会更新服务提供方的实例信息，再将此服务下线，从而避免因服务的升级造成服务不可用。