客户端处理服务端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
刷新本地客户端缓存信息