nacos 服务状态监听 java

nacos 服务状态监听

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

【nacos 服务状态监听】

文章图片

1.引入nacos maven依赖

第一步创建 springboot项目然后引入 nacos 依赖

com.alibaba.cloud spring-cloud-starter-alibaba-nacos-discovery

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