dubbo服務(wù)發(fā)布二之zookeeper注冊(cè)

Hegel_Gu 發(fā)布于2019-08-15 15:44 / 3309人閱讀

摘要：都是持久化節(jié)點(diǎn)，服務(wù)信息是零時(shí)節(jié)點(diǎn)，主要是為了監(jiān)聽(tīng)服務(wù)提供方的是否斷開(kāi)連接，做出相應(yīng)處理。訂閱節(jié)點(diǎn)紅框框里面主要做的時(shí)候就是創(chuàng)建服務(wù)對(duì)應(yīng)的節(jié)點(diǎn)創(chuàng)建節(jié)點(diǎn)持久型節(jié)點(diǎn)并監(jiān)聽(tīng)如下節(jié)點(diǎn)創(chuàng)建一個(gè)的監(jiān)聽(tīng)器對(duì)服務(wù)提供者的節(jié)點(diǎn)配置監(jiān)聽(tīng)器。

接著上一篇繼續(xù)看。
上一篇服務(wù)暴露已經(jīng)講完RegistryProtocol#doLocalExport的方法了。下面將服務(wù)是如何被寫(xiě)到zookeeper上的。

1、注冊(cè)zookeeper節(jié)點(diǎn)，/dubbo/*/providers

RegistryProtocol#getRegistry方法中，從最原始的Invoker里面拿到url，拿到配置的“zookeeper”注冊(cè)協(xié)議，重新構(gòu)造了一個(gè)zookeeper協(xié)議的registryUrl,并從registryFactory【一個(gè)Adaptive類】中拿到一個(gè)ZookeeperRegistryFactory實(shí)例。
.]

RegistryFactory$Adpative代碼【獲取方法：把日志級(jí)別調(diào)測(cè)DEBUG，然后從控制臺(tái)里面找到該端代碼】

package com.alibaba.dubbo.registry;

import com.alibaba.dubbo.common.extension.ExtensionLoader;

public class RegistryFactory$Adpative implements com.alibaba.dubbo.registry.RegistryFactory {
    public com.alibaba.dubbo.registry.Registry getRegistry(com.alibaba.dubbo.common.URL arg0) {
        if (arg0 == null) throw new IllegalArgumentException("url == null");
        com.alibaba.dubbo.common.URL url = arg0;
        String extName = (url.getProtocol() == null ? "dubbo" : url.getProtocol());
        if (extName == null)
            throw new IllegalStateException("Fail to get extension(com.alibaba.dubbo.registry.RegistryFactory) name from url(" + url.toString() + ") use keys([protocol])");
        com.alibaba.dubbo.registry.RegistryFactory extension = (com.alibaba.dubbo.registry.RegistryFactory) ExtensionLoader.getExtensionLoader(com.alibaba.dubbo.registry.RegistryFactory.class).getExtension(extName);
        return extension.getRegistry(arg0);
    }
}

執(zhí)行ZookeeperRegistryFactory#getRegistry【模板設(shè)計(jì)模式，對(duì)不對(duì)？！】方法，并調(diào)用ZookeeperRegistryFactory#createRegistry，在ZookeeperRegistryFactory已經(jīng)利用dubbo的IOC原理，注入了一個(gè)ZookeeperTransporter，該對(duì)象利用Adaptive機(jī)制獲得一個(gè)zookeeper客戶端的實(shí)例，默認(rèn)使用zkClinet的實(shí)現(xiàn)方式。

拿到ZookeeperRegistry實(shí)例之后，執(zhí)行抽象類方法AbstractRegistryFactory.getRegistry

ZookeeperRegistry#doRegistry方法，將服務(wù)信息，寫(xiě)到zk接口上。

/dubbo/com.alibaba.dubbo.demo.DemoService/providers都是持久化節(jié)點(diǎn)，服務(wù)信息是零時(shí)節(jié)點(diǎn)，主要是為了監(jiān)聽(tīng)服務(wù)提供方的是否斷開(kāi)連接，做出相應(yīng)處理。

此時(shí)該服務(wù)的providers節(jié)點(diǎn)已經(jīng)寫(xiě)完了。

2、訂閱/dubbo/*/configrators節(jié)點(diǎn)

紅框框里面主要做的時(shí)候就是

2.1、創(chuàng)建服務(wù)對(duì)應(yīng)的/dubbo/*/configrators節(jié)點(diǎn)

創(chuàng)建zk節(jié)點(diǎn)【持久型節(jié)點(diǎn)】、并監(jiān)聽(tīng)如下節(jié)點(diǎn)
/dubbo
----/com.alibaba.dubbo.demo.DemoService
--------/configurators

2.2、創(chuàng)建一個(gè)OverrideListener的監(jiān)聽(tīng)器

對(duì)服務(wù)提供者的configurators節(jié)點(diǎn)配置監(jiān)聽(tīng)器。
會(huì)觸發(fā)AbstractRegistry#notify(URL url, NotifyListener listener, List urls)去寫(xiě)緩存文件，這個(gè)以后會(huì)多帶帶弄講。

2.3、訂閱/dubbo/*/configrators節(jié)點(diǎn)，當(dāng)有變化時(shí)，觸發(fā)OverrideListener監(jiān)聽(tīng)器，重新執(zhí)行OverrideListener#notify方法，

首先在服務(wù)提供者的節(jié)點(diǎn)樹(shù)中創(chuàng)建configurators節(jié)點(diǎn)，然后配置監(jiān)聽(tīng)器OverrideListener，若通過(guò)Dubbo管理系統(tǒng)為服務(wù)設(shè)置動(dòng)態(tài)參數(shù)，則動(dòng)態(tài)配置的參數(shù)放在configurators節(jié)點(diǎn)目錄下，并通知服務(wù)端的OverrideListener監(jiān)聽(tīng)器，根據(jù)動(dòng)態(tài)參數(shù)重新生成服務(wù)提供者URL，若URL有變化則重新暴露服務(wù)

3、返回Exporter