銆婂甫鐫€闂鐪嬫簮鐮併€婦ubbo鏈嶅姟娉ㄥ唽

Posted 2021-04-05 闃挎彁璇磋

Dubbo鏄€庝箞涓€涓祦绋嬪皢鏈嶅姟娉ㄥ唽鍒版敞鍐屼腑蹇冪殑鍛紵

Dubbo 閲囩敤鍏?Spring 閰嶇疆鏂瑰紡锛屼細鐩戝惉Spring鏄惁鍚姩瀹屾瘯锛屽惎鍔ㄥ畬鍚庡紑濮嬪垵濮嬪寲Dubbo瀹瑰櫒銆?/p>

馃憞涓嬮潰鏄互Zookeeper涓烘敞鍐屼腑蹇冪殑Dubbo鏈嶅姟娉ㄥ唽鏃跺簭鍥?br class="mq-4">

璐翠竴涓嬩富瑕佺殑鍑犲浠ｇ爜,璇︾粏璇存槑鍙互瑙佸畼鏂规枃妗?/span>
http://dubbo.apache.org/zh-cn/docs/source_code_guide/export-service.html

RegistryProtocol.java

@Override
    public <T> Exporter<T> export(final Invoker<T> originInvoker) throws RpcException {
        // 鏆撮湶鏈嶅姟
        // export invoker
        final ExporterChangeableWrapper<T> exporter = doLocalExport(originInvoker);

        // 鑾峰緱娉ㄥ唽涓績 URL
        URL registryUrl = getRegistryUrl(originInvoker);

        // 鑾峰緱娉ㄥ唽涓績瀵硅薄
        // registry provider
        final Registry registry = getRegistry(originInvoker);

        // 鑾峰緱鏈嶅姟鎻愪緵鑰?nbsp;URL
        final URL registedProviderUrl = getRegistedProviderUrl(originInvoker);

        //to judge to delay publish whether or not
        boolean register = registedProviderUrl.getParameter("register", true);

        // 鍚戞敞鍐屼腑蹇冭闃呮湇鍔℃秷璐硅€?/span>
        ProviderConsumerRegTable.registerProvider(originInvoker, registryUrl, registedProviderUrl);

        // 鍚戞敞鍐屼腑蹇冩敞鍐屾湇鍔℃彁渚涜€咃紙鑷繁锛?/span>
        if (register) {
            register(registryUrl, registedProviderUrl);
            ProviderConsumerRegTable.getProviderWrapper(originInvoker).setReg(true); // // 鏍囪鍚戞湰鍦版敞鍐岃〃鐨勬敞鍐屾湇鍔℃彁渚涜€咃紝宸茬粡娉ㄥ唽
        }

        // 浣跨敤 OverrideListener 瀵硅薄锛岃闃呴厤缃鍒?/span>
        // Subscribe the override data
        // FIXME When the provider subscribes, it will affect the scene : a certain JVM exposes the service and call the same service. Because the subscribed is cached key with the name of the service, it causes the subscription information to cover.
        // 鍒涘缓璁㈤槄閰嶇疆瑙勫垯鐨?nbsp;URL
        final URL overrideSubscribeUrl = getSubscribedOverrideUrl(registedProviderUrl);
        // 鍒涘缓 OverrideListener 瀵硅薄锛屽苟娣诲姞鍒?nbsp;`overrideListeners` 涓?/span>
        final OverrideListener overrideSubscribeListener = new OverrideListener(overrideSubscribeUrl, originInvoker);
        overrideListeners.put(overrideSubscribeUrl, overrideSubscribeListener);
        // 鍚戞敞鍐屼腑蹇冿紝鍙戣捣璁㈤槄
        registry.subscribe(overrideSubscribeUrl, overrideSubscribeListener);
        //Ensure that a new exporter instance is returned every time export
        return new DestroyableExporter<T>(exporter, originInvoker, overrideSubscribeUrl, registedProviderUrl);
    }

    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);
        }
    }