dubbo技术内幕十五 ReferenceBean refer向

上一章的中有讲到ServiceBean在export的过程中向zk写入的信息，这一章看下ReferenceBean在refer的过程中，向zk写的数据，已经监听了哪些变更。
我们直接的拉到ReferenceBean的getObject方法，如下

 public Object getObject() throws Exception {
        return get();
    }

直接的跟到ReferenceConfig类的init方法里面的最重要的一句

 ref = createProxy(map);

而在createProxy方法里面，最重要的一句，如下

 invoker = refprotocol.refer(interfaceClass, urls.get(0));

我们直接的跟到RegistryProtocol的refer方法里面的最后一句，如下

return doRefer(cluster, registry, type, url);

而在doRefer里面摘取重要的语句如下

  //构造url
  URL subscribeUrl = new URL(Constants.CONSUMER_PROTOCOL, parameters.remove(Constants.REGISTER_IP_KEY), 0, type.getName(), parameters);
        if (!Constants.ANY_VALUE.equals(url.getServiceInterface())
                && url.getParameter(Constants.REGISTER_KEY, true)) {
            URL registeredConsumerUrl = getRegisteredConsumerUrl(subscribeUrl, url);
            //注册消费者信息
            registry.register(registeredConsumerUrl);
            directory.setRegisteredConsumerUrl(registeredConsumerUrl);
        }
        //订阅指定zk目录的信息
        directory.subscribe(subscribeUrl.addParameter(Constants.CATEGORY_KEY,
                Constants.PROVIDERS_CATEGORY
                        + "," + Constants.CONFIGURATORS_CATEGORY
                        + "," + Constants.ROUTERS_CATEGORY));

其中

 registry.register(registeredConsumerUrl);

会调用到ZookeeperRegistry的doRegister方法，如下

    protected void doRegister(URL url) {
        try {
            zkClient.create(toUrlPath(url), url.getParameter(Constants.DYNAMIC_KEY, true));
        } catch (Throwable e) {
            throw new RpcException("Failed to register " + url + " to zookeeper " + getUrl() + ", cause: " + e.getMessage(), e);
        }
    }

其中toUrlPath(url)返回如下

image.png

等于说我们在/dubbo/com.starunion.transport.service.TransportService/consumers目录下添加了该dubbo服务的消费者信息。
而

directory.subscribe(subscribeUrl.addParameter(Constants.CATEGORY_KEY,
                Constants.PROVIDERS_CATEGORY
                        + "," + Constants.CONFIGURATORS_CATEGORY
                        + "," + Constants.ROUTERS_CATEGORY));

一直跟到ZookeeperRegistry的doSubscribe方法，核心代码如下

 for (String path : toCategoriesPath(url)) {
                    ConcurrentMap<NotifyListener, ChildListener> listeners = zkListeners.get(url);
                    if (listeners == null) {
                        zkListeners.putIfAbsent(url, new ConcurrentHashMap<NotifyListener, ChildListener>());
                        listeners = zkListeners.get(url);
                    }
                    ChildListener zkListener = listeners.get(listener);
                    if (zkListener == null) {
                        listeners.putIfAbsent(listener, new ChildListener() {
                            @Override
                            public void childChanged(String parentPath, List<String> currentChilds) {
                                ZookeeperRegistry.this.notify(url, listener, toUrlsWithEmpty(url, parentPath, currentChilds));
                            }
                        });
                        zkListener = listeners.get(listener);
                    }
                    zkClient.create(path, false);
                    List<String> children = zkClient.addChildListener(path, zkListener);
                    if (children != null) {
                        urls.addAll(toUrlsWithEmpty(url, path, children));
                    }
                }
                notify(url, listener, urls);
            }

其中 toCategoriesPath(url)返回如下

image.png

所以消费端订阅的zk节点为 providers（实时的监听providers的变化），
configurators（实时的监听配置变化），routers（实时的监听路由配置的变化）

如果打开dubbo的后台页面的话，ReferenceBean关注的功能如下

image.png