nacos 服务状态监听

有时候有些服务 需要去从nacos 上监听 其他服务的上下线状态 等情况,nacos提供了监听方式

image-20210916112850638

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 instances = ((NamingEvent) event).getInstances(); 通过它就能获取到 实例信息了,后续自己去处理业务逻辑

image-20210916111644520

总结

当需要 监听其他服务的时候 可以使用该方式去 自定义实现业务需求

欢迎大家访问 个人博客 Johnny小屋

GitHub 加速计划 / na / nacos
29.83 K
12.75 K
下载
Nacos是由阿里巴巴开源的服务治理中间件,集成了动态服务发现、配置管理和服务元数据管理功能,广泛应用于微服务架构中,简化服务治理过程。
最近提交(Master分支:3 个月前 )
4334cd16 * Support custom client configuration timeout.(#12748) * Add UT.(#12748) 8 天前
b04d2266 13 天前
Logo

旨在为数千万中国开发者提供一个无缝且高效的云端环境,以支持学习、使用和贡献开源项目。

更多推荐