nacos 服务状态监听

有时候有些服务 须要去从 nacos 上监听 其余服务的高低线状态 等状况，nacos 提供了监听形式

1. 引入 nacos maven 依赖

第一步 创立 springboot 我的项目 而后引入 nacos 依赖

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
</dependency>

2. 注册监听器 监听服务变更

discoveryUrl 能够间接指定 你的 nacos，而后通过 NacosFactory.createNamingService 去获取 NamingService，通过它 subscribe 去监听某个服务

    @Value("${spring.cloud.nacos.discovery.server-addr}")
    private String discoveryUrl;


NamingService namingService = NacosFactory.createNamingService(discoveryUrl);

String serviceName = "xxx 服务"
 // 注册监听器
            namingService.subscribe(
                    serviceName,
                    // groupName,
                    (event) -> {if (event instanceof NamingEvent) {List<Instance> instances = ((NamingEvent) event).getInstances();                            
                 
                            NodeContextHolder.nodeMap = new ConcurrentHashMap<>(instances.size());
                            instances.forEach(
                                    instance -> {if (instance.isEnabled() && instance.isHealthy()) {

                                            NodeContextHolder.nodeMap.put(instance.getInstanceId(), instance);
                                            log.info("【instance nodeName: {}】",
                                                    instance.getMetadata().get("nodename"));
                                        }
                                    });
                            log.info("==============instances: {}================", instances);
                        }
                    });

留神

serviceName：示意你要去监听的 服务

groupName: nacos 的分组，这个被监听的服务它的分组，如果没有则不传，如果有肯定要传

List<Instance> instances = ((NamingEvent) event).getInstances(); 通过它就能获取到 实例信息了，后续本人去解决业务逻辑

总结

当须要 监听其余服务的时候 能够应用该形式去 自定义实现业务需要

欢送大家拜访 集体博客 Johnny 小屋