nacos 服务状态监听
nacos
Nacos是由阿里巴巴开源的服务治理中间件,集成了动态服务发现、配置管理和服务元数据管理功能,广泛应用于微服务架构中,简化服务治理过程。
项目地址:https://gitcode.com/gh_mirrors/na/nacos
免费下载资源
·
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 instances = ((NamingEvent) event).getInstances(); 通过它就能获取到 实例信息了,后续自己去处理业务逻辑
总结
当需要 监听其他服务的时候 可以使用该方式去 自定义实现业务需求
欢迎大家访问 个人博客 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 天前
更多推荐
已为社区贡献1条内容
所有评论(0)