我也是醉了，Eureka 延迟注册还有这个坑！

2023-02-28

方法 info 发现

Eureka有个延迟注册的功能，也就是在服务启动成功之后不立刻注册到EurekaServer，而是延迟一段时间再去注册，这样做的主要目的是因为虽然服务启动成功了，可能还有一些框架或者业务的代码没有初始化完成，可能会导致调用的报错，所以需要延迟注册。但是发现，然并卵啊，好像这个延迟注册并没有生效，也是

Eureka 有个延迟注册的功能，也就是在服务启动成功之后不立刻注册到 Eureka Server，而是延迟一段时间再去注册，这样做的主要目的是因为虽然服务启动成功了，可能还有一些框架或者业务的代码没有初始化完成，可能会导致调用的报错，所以需要延迟注册。

但是发现，然并卵啊，好像这个延迟注册并没有生效，也是开始了排查之路。

延迟注册

首先，延迟注册的功能主要依赖这两个参数，eureka.client.initial-instance-info-replication-interval-seconds代表第一次初始化延迟注册的时间间隔，eureka.client.instance-info-replication-interval-seconds则代表后续同步注册的时间间隔。

eureka.client.initial-instance-info-replication-interval-seconds=40 //默认40秒
eureka.client.instance-info-replication-interval-seconds=30 //默认30秒1.
2.

我们从源码先来看是怎么做到延迟注册的，先看 DiscoveryClient 的 initScheduledTasks ，这里创建了同步注册到 Eureka Server 的定时任务。

之后调用 start 方法创建定时任务，并且延迟 40 秒执行，也就是我们达到的延迟注册的效果。

默认的第一次注册，也就是延迟注册的时间是 40 秒，之后每 30 秒会同步注册信息。

但是，即便我们配置了这俩属性，发现好像没什么卵用，接下来我们要排查下到底是为啥捏？

第一个问题

我发现在 InstanceInfoReplica 中存在这样一段终止当前线程池任务，并且直接调用 run 方法的存在，猜测失效就是他直接调用导致延迟任务没有生效，因为这个方法的直接调用导致延迟注册压根就没效果嘛。

看起来他存在两个调用，第一个是registerHealthCheck，当存在这个健康检查什么玩意儿的时候就会去调用onDemandUpdate。

经过排查我们发现，只要配置了eureka.client.healthcheck.enabled=true，就会创建 HealthCheckHandler的实例出来，默认情况下他是false的，所以应该是对我们没有影响的。

这里需要特别说明一下 eureka.client.healthcheck.enabled 的作用，默认 Eureka 根据心跳来决定应用的状态，如果是这个属性配置成 true的话，则是会根据 Spring Boot Actuator 来决定，而不是心跳了。

比如我们可以实现 HealthIndicator接口，自己写一个Controller来动态改变服务的状态

@RestController
public class ControllerTest {
    @Autowired
    private HealthChecker healthChecker;

    @RequestMapping("/change")
    public String test(Boolean flag) {
        healthChecker.setUp(new AtomicBoolean(flag));
        return "success";
    }

}1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.

实现HealthChecker，这样会发现启动、下线服务 Eureka Server 的状态不会变成 Down，只有通过调用接口手动改变应用状态 Server 的状态才会发生改变，大家可以自行测试。

@Component
public class HealthChecker extends EurekaHealthIndicator implements HealthIndicator {
    private AtomicBoolean up = new AtomicBoolean(true);

    public HealthChecker(EurekaClient eurekaClient, EurekaInstanceConfig instanceConfig, EurekaClientConfig clientConfig) {
        super(eurekaClient, instanceConfig, clientConfig);
    }

    @Override
    public Health health() {
        if(up.get()){
            return Health.up().build();
        }else{
            return Health.down().build();
        }
    }1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.

第二个问题

第一个问题我们找到了，发现他不是导致我们问题的根因，于是继续排查。

发现第二个调用，在DiscoveryClient注册了状态事件变更的监听，如果状态发生变更，也会去调用 onDemandUpdate ，影响延迟注册的效果。

这里存在一个配置项onDemandUpdateStatusChange，默认是true，所以应该是他没错了。

进入StatusChangeListener，找到了一个调用。

就是通过setInstanceStatus方法触发的事件通知。

这里存在 6 个调用，一一排查，通过源码找啊找，最终定位到服务启动自动装配的地方，在这里去修改服务状态为 UP，然后触发事件通知，启动 start 方法调用register方法。

继续调用，修改应用为上线UP状态。

由此我们知道，只要服务启动成功，就会触发事件通知，所以这个基本上是启动成功立刻就会去注册到 Eureka Server，这就会导致延迟注册的失效，从启动日志也能直观的看到这个效果。

验证

为了验证我的猜想，我把这两个配置同时配置成false，并且把延迟注册的时间调整到非常大。

eureka.client.healthcheck.enabled=false
eureka.client.onDemandUpdateStatusChange=false
eureka.client.initial-instance-info-replication-interval-seconds=9999999 //默认40秒
eureka.client.instance-info-replication-interval-seconds=999999 //默认30秒1.
2.
3.
4.