Nacos和Apollo中的长轮询定时机制,太好用了
今天这篇文章来介绍一下Nacos配置中心的原理之一:长轮询机制的应用
为方便理解与表达,这里把 Nacos 控制台和 Nacos 注册中心称为 Nacos 服务器(就是 web 界面那个),我们编写的业务服务称为 Nacso 客户端;
Nacos 动态监听的长轮询机制原理图,本篇将围绕这张图剖析长轮询定时机制的原理:
ConfigService 是 Nacos 客户端提供的用于访问实现配置中心基本操作的类型,我们将从 ConfigService 的实例化开始长轮询定时机制的源码之旅; 1. 客户端的长轮询定时机制
我们从NacosPropertySourceLocator.locate()开始【断点步入】:
1.1 利用反射机制实例化 NacosConfigService 对象
客户端的长轮询定时任务是在 NacosFactory.createConfigService() 方法中,构建 ConfigService 对象是实例时启动的,我们接着 1.1 处的源码;
进入 NacosFactory.createConfigService(): public static ConfigService createConfigService(Properties properties) throws NacosException { //【断点步入】创建 ConfigService return ConfigFactory.createConfigService(properties); }
进入 ConfigFactory.createConfigService(),发现其使用反射机制实例化 NacosConfigService 对象;
1.2 NacosConfigService 的构造方法里启动长轮询定时任务
进入 NacosConfigService.NacosConfigService() 构造方法,里面设置了一些跟远程任务相关的属性;
1.2.1 初始化 HttpAgent
MetricsHttpAgent 类的设计如下:
ServerHttpAgent 类的设计如下:
1.2.2 初始化 ClientWorker
进入 ClientWorker.ClientWorker() 构造方法,主要是创建了两个定时调度的线程池,并启动一个定时任务;
进入 ClientWorker.checkConfigInfo(),每隔 10s 检查一次配置是否发生变化; cacheMap:是一个 AtomicReference