Eureka 注册、下线、续约事件的监听使用

青旅半醒 2023-10-01 12:26 23阅读 0赞

# 前言 #

看图：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_19_color_FFFFFF_t_70_g_se_x_16][]

现在开发节奏如此紧张，大多数人为了跟得上敏捷的节奏，也就无形中丢掉了对技术整合的更多的拓展学习。

那么，我选择 小白文科普。

不管这些东西是否简单还是复杂，只要存在有人为了解，那么我就发文，至少能让我的看客都知道还有一些有缘的看客知道。

# 正文 #

直接看源码：

InstanceRegistry.java

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16][]

ps： 还有很多人不会看源码 ，例如想找 InstanceRegistry 这个代码，idea 操作大致就是这样：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 1][]

回到刚才的内容，可以看到 InstanceRegistry里面很多方法，

cancel ： 下线 ，client项目 突然挂了或者没了，触发调用的方法  
  
renew ：续约， 收到client项目心跳，触发的续约方法

我们直接拿 register方法看 ，

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 2][]

handleRegistration ：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 3][]

再看一个cancel：  
![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 4][]

renew 也是 :

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 5][]

那么到这，其实我们如果了解spring的 事件发布 ，那么看到这里，你已经知道怎么玩这些事件了。

但是未免有的看客就是没了解，那么没关系 ，可以往下看，或者直接看我这篇 :

[SpringBoot 事件发布监听机制使用、分析、注意点 （一篇到位）\_默默不代表沉默-CSDN博客\_springboot 事件监听][SpringBoot _ _-CSDN_springboot]

那么我们直接上代码：  
  
MyStateListener.java

import com.netflix.appinfo.InstanceInfo;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.cloud.netflix.eureka.server.event.*;
    import org.springframework.context.event.EventListener;
    import org.springframework.stereotype.Component;
    
    /**
     * @Author JCccc
     * @Description
     * @Date 2020/09/10 9:22
     */
    @Component
    public class MyStateListener {
    
        private final static Logger log = LoggerFactory.getLogger(MyStateListener.class);
    
        @EventListener
        public void registerListen(EurekaInstanceRegisteredEvent event) {
            InstanceInfo instanceInfo = event.getInstanceInfo();
            log.info("服务名={}注册上来了", instanceInfo.getAppName());
            log.info("服务的host名={}",instanceInfo.getHostName());
            log.info("服务的ip地址={}",instanceInfo.getIPAddr());
            log.info("服务的端口={}",instanceInfo.getPort());
            log.info("做一些【注册】相关的业务逻辑......");
            log.info("做一些【注册】相关的业务逻辑......");
        }
    
        @EventListener
        public void canceledListen(EurekaInstanceCanceledEvent event) {
    
            log.info("服务名={}下线了", event.getAppName());
            log.info("server地址信息{}", event.getServerId());
            log.info("做一些【下线】相关的业务逻辑......");
            log.info("做一些【下线】相关的业务逻辑......");
        }
    
        @EventListener
        public void renewedListen(EurekaInstanceRenewedEvent event) {
            log.info("服务名={}进行续约", event.getServerId() +"  "+ event.getAppName());
            log.info("做一些【续约】相关的业务逻辑......");
            log.info("做一些【续约】相关的业务逻辑......");
        }
    
        @EventListener
        public void listen(EurekaRegistryAvailableEvent event) {
            log.info("注册中心启动,{}", System.currentTimeMillis());
        }
    
        @EventListener
        public void listen(EurekaServerStartedEvent event) {
            log.info("注册中心服务端启动,{}", System.currentTimeMillis());
        }
    
    }

代码简单的介绍：

其实也没什么也就一个 @EventListener 注解， 然后配合 我们需要监听的事件就行

EurekaInstanceRegisteredEvent  
EurekaInstanceCanceledEvent  
EurekaInstanceRenewedEvent

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_19_color_FFFFFF_t_70_g_se_x_16 1][]

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_17_color_FFFFFF_t_70_g_se_x_16][]

执行一下看看效果：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 6][]

续约：

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 7][]

下线：  
  
![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 8][]

大家可以居于这些事件做一些，运维短信提醒；做一些初始化数据；做一些 等等。

其实可以结合eureka的保护机制、心跳机制、剔除机制， 做些策略的监控业务。

该篇就到这吧。

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_19_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/8a96f90a69fb4c3f854d8f8333f121ef.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_19,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/c1b1953767234f0eb930ff0e8e00e144.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/a55cf244baf243f0ba7f8e09fc85a5fb.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 2]: https://img-blog.csdnimg.cn/9728f2435f9946f6960606e94e1c223e.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 3]: https://img-blog.csdnimg.cn/113957abfe73492d88019290137fcdfe.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 4]: https://img-blog.csdnimg.cn/dd1459d2ce0342509f0b05195f4e10ec.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 5]: https://img-blog.csdnimg.cn/bdbbf041beba46759f81b877b21adea3.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[SpringBoot _ _-CSDN_springboot]: https://blog.csdn.net/qq_35387940/article/details/121315114
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_19_color_FFFFFF_t_70_g_se_x_16 1]: https://img-blog.csdnimg.cn/5e159011caa4416c8bb7cc5a523d0de0.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_19,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_17_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/ac9ba5bb84a44eea999e568356f25e46.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_17,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 6]: https://img-blog.csdnimg.cn/8365e1356f644e1d8c3c92ea2a9d7892.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 7]: https://img-blog.csdnimg.cn/ea8d70445e124f60bc39d26a37b9319d.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16
[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0_size_20_color_FFFFFF_t_70_g_se_x_16 8]: https://img-blog.csdnimg.cn/05d29db09ee4478e995540248a20fca7.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA5bCP55uu5qCH6Z2S5bm0,size_20,color_FFFFFF,t_70,g_se,x_16