C2 服务列表本地缓存
2023-09-08 14:26:47 0 举报
服务列表本地缓存
作者其他创作
大纲/内容
客户端处理服务端grpc更新订阅客户端变更请求
将服务更新请求发送给客户端
通知客户端
Service service = pushDelayTask.getService();
PushDelayTask pushDelayTask = (PushDelayTask) task;
ProcessRunnable#run
NamingSubscriberServiceV2Impl#onEvent
NacosTaskProcessor processor = getProcessor(taskKey)
processor.process(task)
NamingPushRequestHandler#requestReply
发布ServiceChangedEvent事件，用于推送消息给对应的订阅者
创建PushExecuteTask线程任务
processTasks()
延迟队列线程池添加PushDelayTask
Service service = serviceChangedEvent.getService()
PushExecutorRpcImpl#doPushWithCallback
NacosDelayTaskExecuteEngine#addTask
PushDelayTaskExecuteEngine#PushDelayTaskProcessor#process
刷新本地客户端缓存信息
0 条评论
回复 删除
下一页
