从存放长轮询连接任务队列中获取变更配置的ClientLongPolling
客户端发起数据监听的接口 处理长轮询连接
MD5Util.compareMd5
clientSub.sendResponse(Arrays.asList(groupKey))
AsyncNotifyService通知集群其它节点同步配置
NotifyCenter
是响应客户端
/v1/configs/listener配置监听接口
创建调度任务 29.5s后执行
changedGroups.size() > 0
获取客户端需要监听的可能发生变化的配置 并计算期MD5值
调用集群其它节点的http接口
queue.offer(event)
ConfigExecutor.executeLongPolling(new DataChangeTask
将ClientLongPolling放入队列
sendResponse(null)
onEvent
iter.remove()
处理长轮询连接
@ServiceLongPollingService
发布一个事件ConfigDataChangeEvent
触发监听器事件的回调方法
/v1/cs/communication/dataChange
如果发生变化则直接返回给客户端
inner.doPollingConfig
ConfigChangePublisher.notifyConfigChange
是定时任务将在30秒后开始执行
allSubs = new ConcurrentLinkedQueue初始化存放客户端长轮询连接任务的 阻塞队列
触发回调
ConfigController.publishConfig
persistService.insertOrUpdate
isFixedPolling()
先做持久化保存到mysql
和服务端的数据进行MD5对比
receiveEvent(event)
ConfigExecutor.executeAsyncNotify(new AsyncTask
clientMd5Map = MD5Util.getClientMd5Map(probeModify)
将自身从队列中移除
否 默认29.5秒后开始执行
ConfigExecutor.executeLongPollingnew ClientLongPolling执行长连接任务
ConcurrentHashSet放入集合
publish(Event event)
循环从队列中获取事件
先移除
获取服务端中保存的对应客户端请求的groupKeys判断是否变更
openEventHandler
ConfigExecutor.scheduleLongPolling
LongPollingService.addLongPollingClient
ClientLongPolling.run
nacos控制台
通知订阅者
直接和当前配置做比较 返回有变更的配置给客户端
for (; ; )queue.take()
publisher.addSubscriber(consumer
LongPollingService
allSubs.remove(ClientLongPolling.this)
回调方法
allSubs队列该队列中维持的是所有客户端的请求任务找到与当前发生变更的配置项的groupKey相等的ClientLongPolling任务
NotifyCenter.publishEvent(event)
先判断客户端冬请求的header中是否设置长轮询
sendResponse(changedGroups)
start启动线程
遍历订阅者结合
Servlet 3.0的异步处理支持特性，使用AsyncContext的时候，对于客户端来说，他们是同步在等待服务端的响应结果，但是对于服务器端来说，处理此请求的线程并没有卡在那里等待，则是把当前的处理转为线程池处理了，当线程池处理完请求后才响应给客户端。它的优点是在接收到请求之后，Servlet 线程可以将耗时的操作委派给另一个线~程来完成，自己在不生成响应的情况下返回至容器。针对业务处理较耗时的情况，这将大大减少服务器资源的占用，并且提高并发处理速度
DataChangeTask.run
否短连接
AsyncContext asyncContext = req.startAsync()
NotifyCenter.registerSubscriber
JVM加载类时执行static静态代码块初始化事件发布器
是处理长轮询
获取客户端的请求超时时间 默认30s，服务端会提前500ms返回响应，为了避免客户端超时
isSupportLongPolling(request)
DefaultPublisher
响应空结果
把事件放入阻塞队列
post请求 修改配置
allSubs.add(this)
交给线程池执行
构造方法初始化
将发生变更的groupKey通过该ClientLongPolling写入到响应对象中即完成一次数据变更的推送操作
注册订阅者
判断是否为 混合连接
无变化
