实时监听nacos中的服务上下线
nacos
Nacos是由阿里巴巴开源的服务治理中间件,集成了动态服务发现、配置管理和服务元数据管理功能,广泛应用于微服务架构中,简化服务治理过程。
项目地址:https://gitcode.com/gh_mirrors/na/nacos
免费下载资源
·
1.背景
在使用spring cloud gateway时,服务的上下线可能会没那么及时,这样就会导致在进行业务服重启时会出现部分用户请求接口出现503,服务不可用的情况。
nacos-client版本:
1.4.1
spring-cloud-starter-alibaba-nacos-discovery版本:
2.2.5
2.实现
在spring-cloud-starter-alibaba-nacos-discovery中并未找到获取服务注册时进行会发布的事件,所以去nacos-client中找到了InstancesChangeEvent
事件,并且发现了事件的发布订阅关系
在 com.alibaba.nacos.client.naming.core.HostReactor 类中
this.notifier = new InstancesChangeNotifier();
NotifyCenter.registerToPublisher(InstancesChangeEvent.class, 16384);
NotifyCenter.registerSubscriber(notifier);
至此,我们找到了实现方案:
模仿InstancesChangeNotifier进行自己服务实例变化处理
@Component
@Slf4j
public class NacosServiceInstanceChangeNotifier extends Subscriber<InstancesChangeEvent>{
@PostConstruct
public void registerToNotifyCenter(){
NotifyCenter.registerSubscriber(this);
}
@Override
public void onEvent(InstancesChangeEvent instancesChangeEvent) {
log.info("监听nacos的服务实例变化情况:{}", JSON.toJSONString(instancesChangeEvent));
}
@Override
public Class<? extends Event> subscribeType() {
return InstancesChangeEvent.class;
}
}
当服务上下线时:
服务上线:
监听nacos的服务实例变化情况:{"clusters":"","groupName":"DEFAULT_GROUP","hosts":[{"clusterName":"DEFAULT","enabled":true,"ephemeral":true,"healthy":true,"instanceHeartBeatInterval":5000,"instanceHeartBeatTimeOut":15000,"instanceId":"192.168.0.188#15061#DEFAULT#DEFAULT_GROUP@@client-api-service","ip":"192.168.0.188","ipDeleteTimeout":30000,"metadata":{"preserved.register.source":"SPRING_CLOUD","server.startup-time":"1680507089247"},"port":15061,"serviceName":"DEFAULT_GROUP@@client-api-service","weight":1.0}],"serviceName":"DEFAULT_GROUP@@client-api-service"}
服务下线:
监听nacos的服务实例变化情况:{"clusters":"","groupName":"DEFAULT_GROUP","hosts":[],"serviceName":"DEFAULT_GROUP@@client-api-service"}
3. 未完待续
- 如何刷新负载均衡器的缓存
- 动态路由如何刷新
GitHub 加速计划 / na / nacos
29.83 K
12.75 K
下载
Nacos是由阿里巴巴开源的服务治理中间件,集成了动态服务发现、配置管理和服务元数据管理功能,广泛应用于微服务架构中,简化服务治理过程。
最近提交(Master分支:3 个月前 )
4334cd16
* Support custom client configuration timeout.(#12748)
* Add UT.(#12748) 19 天前
b04d2266
23 天前
更多推荐
已为社区贡献1条内容
所有评论(0)