nacos源码分析==服务订阅-服务端推送被订阅者最新信息给订阅者

上一篇讲到客户端发送请求到服务端进行服务注册注册后服务端会发出两个事件第一个事件会触发另一个ServiceChangedEvent这个事件被com.alibaba.nacos.naming.push.v2.NamingSubscriberServiceV2Impl#onEvent

监听监听到后将该客户端最新的信息推送给订阅该客户端的其他客户端。

这个推送是怎么完成的

首先客户端必须告诉服务端它订阅了哪些客户端

试了下貌似是A首次调用B之后之后A中定时执行的UpdateTask才会去拉取被调用的B服务的信息意思是A调用一次B之后就认为订阅了这个服务。

比如我这里ruoyi system的定时拉取ruoyi file的信息

 

 

 此时ruoyi file的端口是3000

 此时如果我停掉ruoyi file 并更改下端口重启ruoyi system下次拉取到的应该会变但实际上是我一停止ruoyi file, ruoyi system就会收到来自服务端的通知收到通知后依然会有UpdateTask去拉取ruoyi file的信息

 ruoyi file的端口改成9301之后重启ruoyi system会再次收到来自服务端的推送

ruoyi system的下一次UpdateTask就会获取到ruoyi file新的端口 

 此时我如果再次将ruoyi file停掉服务端应该会产生一个ServiceChangedEvent并且被com.alibaba.nacos.naming.push.v2.NamingSubscriberServiceV2Impl#onEvent监听到

最终向订阅ruoyi file的其他客户端推送消息是在

com.alibaba.nacos.naming.push.v2.task.PushExecuteTask#run

    @Override
    public void run() {
        try {
            PushDataWrapper wrapper = generatePushData();
            ClientManager clientManager = delayTaskEngine.getClientManager();
//或者需要推送给哪些客户端
            for (String each : getTargetClientIds()) {
                Client client = clientManager.getClient(each);
                if (null == client) {
                    // means this client has disconnect
                    continue;
                }
                Subscriber subscriber = clientManager.getClient(each).getSubscriber(service);
//推送
                delayTaskEngine.getPushExecutor().doPushWithCallback(each, subscriber, wrapper,
                        new ServicePushCallback(each, subscriber, wrapper.getOriginalData(), delayTask.isPushToAll()));
            }
        } catch (Exception e) {
            Loggers.PUSH.error("Push task for service" + service.getGroupedServiceName() + " execute failed ", e);
            delayTaskEngine.addTask(service, new PushDelayTask(service, 1000L));
        }
    }

com.alibaba.nacos.naming.push.v2.executor.PushExecutorRpcImpl#doPushWithCallback

com.alibaba.nacos.core.remote.RpcPushService#pushWithCallback

可以发现不管被订阅者上线或者下线都会给订阅者推送区别就是request中的ServiceInfo的hosts中存的IP端口变了我这只有一个实例现在后hosts就是空的

 被订阅者上线通知订阅者hosts属性中带上了IP和端口

 

总结
服务端接收到服务注册请求后发布了ClientRegisterServiceEvent客户端注册事件
ClientRegisterServiceEvent事件被ClientServiceIndexesManager订阅后发布ServiceChangedEvent服务变更事件
ServiceChangedEvent被NamingSubscriberServiceV2Impl订阅并创建PushDelayTask并被PushExecuteTask执行负责向订阅该服务的客户端发起推送serviceInfo请求
推送的请求被NamingPushRequestHandler处理并发布InstancesChangeEvent最终回调AbstractEventListener
————————————————
版权声明本文为CSDN博主「宽仔的代码之路」的原创文章遵循CC 4.0 BY-SA版权协议转载请附上原文出处链接及本声明。
原文链接https://blog.csdn.net/guntun8987/article/details/125570748