zoukankan      html  css  js  c++  java
  • Nacos 服务状态监听四种写发

    监听服务的四种实现方式,以监听 Nacos 服务为例

    1. 传统方式

    public void subscribe() {
        try {
    
                NamingService namingService = NamingFactory.createNamingService("127.0.0.1:8848"); 
                namingService.subscribe("serverName","groupName",new EventListener() {
                    @Override
                    public void onEvent(Event event) {
                       if (event instanceof NamingEvent) {
                            System.out.println("服务名:"+((NamingEvent)event).getServiceName());
                            System.out.println("实例:"+((NamingEvent)event).getInstances());
                        }
                    }
                });
    
        } catch (NacosException e) {
            logger.error(e.getMessage(), e);
        }
    } 

    2. 简写方式

    public void subscribe() {
        try {
    
                NamingService namingService = NamingFactory.createNamingService("127.0.0.1:8848"); 
                namingService.subscribe("serverName","groupName", event -> {
                    if (event instanceof NamingEvent) {
                        System.out.println("服务名:"+((NamingEvent)event).getServiceName());
                        System.out.println("实例:"+((NamingEvent)event).getInstances());
                    }
                });
    
        } catch (NacosException e) {
            logger.error(e.getMessage(), e);
        }
    } 

    3. 独立方法

    public void subscribe() {
        try {
    
                NamingService namingService = NamingFactory.createNamingService("127.0.0.1:8848"); 
                namingService.subscribe("serverName","groupName", serviceListener);
    
        } catch (NacosException e) {
            logger.error(e.getMessage(), e);
        }
    } 
    
    
    
    EventListener serviceListener = (event) ->
    {
        if (event instanceof NamingEvent) {
            System.out.println("服务名:"+((NamingEvent)event).getServiceName());
            System.out.println("实例:"+((NamingEvent)event).getInstances());
        }
    };

    4. 独立文件

    public void subscribe() {
        try {
    
                NamingService namingService = NamingFactory.createNamingService("127.0.0.1:8848"); 
                namingService.subscribe("serverName","groupName", new NacosListener());
    
        } catch (NacosException e) {
            logger.error(e.getMessage(), e);
        }
    } 
    
    //单独Class类
    public class NacosListener implements EventListener {
        @Override
        public void onEvent(Event event) {
            if (event instanceof NamingEvent) {
                System.out.println(((NamingEvent)event).getServiceName());
                System.out.println(((NamingEvent)event).getInstances());
            }
        }
    }
  • 相关阅读:
    接口自动化1-基础知识
    pytest-fixture之conftest.py
    测试人员一定要懂的ADB操作,赶紧来看一看~
    必看!利用装饰器,帮你自动处理异常并优雅实现重跑case
    最全Airtest接口功能介绍和示例总结,新手同学千万不能错过呀!(二)
    总结一波 Redis 面试题,收藏起来!
    IntelliJ IDEA 2020.2.4款 神级超级牛逼插件推荐
    华为 Java 开发编程军规,谁违反谁走
    CTO:再写if-else,逮着罚款1000!
    VSCode 上竟然也能约会,谈对象了???
  • 原文地址:https://www.cnblogs.com/vipsoft/p/14875112.html
Copyright © 2011-2022 走看看