Eureka客户端注册到服务端后执行自定义方法未触发问题求助

• 你使用的EurekaInstanceRegisteredEvent是客户端本地实例信息构造完成、发起注册请求之前触发的事件，并非注册到服务端成功后的回调事件，部分低版本Spring Cloud Netflix还存在该事件不触发的兼容性缺陷，因此无法满足需求。

方案1：监听心跳事件校验注册状态（推荐，适配绝大多数Spring Cloud版本） #

Eureka客户端首次心跳请求收到服务端成功响应时，代表实例已经完成服务端注册，我们通过单次执行标记保证自定义逻辑只跑一次：

@SpringBootApplication
@ComponentScan(basePackages = { "com.xxx.network.inventory.oss.staticcontent", "com.xxx.commons.rest*"},
excludeFilters={
          @ComponentScan.Filter(type=FilterType.ASSIGNABLE_TYPE, value=RestTemplateConfig.class)})
@EnableEurekaClient
public class OssUiApplication {
    // 标记位保证逻辑只执行一次
    private volatile boolean isRegistered = false;
    @Autowired
    private EurekaClient eurekaClient;

    public static void main(String[] args) {
        SpringApplication.run(OssUiApplication.class, args);
    }

    @EventListener(HeartbeatEvent.class)
    public void onEurekaRegistered(HeartbeatEvent event) {
        if (isRegistered) {
            return;
        }
        InstanceInfo instanceInfo = eurekaClient.getApplicationInfoManager().getInfo();
        // 校验当前实例是否在服务端注册列表中存在
        Application application = eurekaClient.getApplication(instanceInfo.getAppName());
        if (application != null && application.getByInstanceId(instanceInfo.getInstanceId()) != null) {
            isRegistered = true;
            // 这里写你要执行的自定义逻辑
            System.out.println("Got it... 实例已成功注册到Eureka服务端");
        }
    }
}

方案2：主动轮询状态（适合需要严格控制执行时机的场景） #

通过ApplicationRunner启动异步线程轮询注册状态，避免依赖事件机制的兼容性问题：

@SpringBootApplication
@ComponentScan(basePackages = { "com.xxx.network.inventory.oss.staticcontent", "com.xxx.commons.rest*"},
excludeFilters={
          @ComponentScan.Filter(type=FilterType.ASSIGNABLE_TYPE, value=RestTemplateConfig.class)})
@EnableEurekaClient
public class OssUiApplication implements ApplicationRunner {
    @Autowired
    private EurekaClient eurekaClient;

    public static void main(String[] args) {
        SpringApplication.run(OssUiApplication.class, args);
    }

    @Override
    public void run(ApplicationArguments args) throws Exception {
        // 启动异步线程轮询，避免阻塞主启动流程
        new Thread(() -> {
            InstanceInfo instanceInfo = eurekaClient.getApplicationInfoManager().getInfo();
            while (true) {
                try {
                    Application application = eurekaClient.getApplication(instanceInfo.getAppName());
                    if (application != null && application.getByInstanceId(instanceInfo.getInstanceId()) != null) {
                        // 这里写你要执行的自定义逻辑
                        System.out.println("Got it... 实例已成功注册到Eureka服务端");
                        break;
                    }
                    // 每隔1秒轮询一次，可根据需求调整间隔
                    Thread.sleep(1000);
                } catch (Exception e) {
                    // 忽略轮询异常，继续重试
                }
            }
        }).start();
    }
}

内容的提问来源于stack exchange，提问作者Surya