Dubbo基礎(chǔ)篇服務(wù)引用

完整流程圖

Dubbo基礎(chǔ)篇服務(wù)引用完整流程.png

一句話概括流程

具體可以概括為以下五點(diǎn)

兩種模式（餓漢式/懶漢式）
組裝URL并向注冊(cè)中心注冊(cè)
獲取服務(wù)提供者信息并根據(jù)協(xié)議（默認(rèn)Dubbo協(xié)議）開始Invoker的創(chuàng)建流程
通過Cluster包裝Invoker（默認(rèn)FailoverCluster）
返回代理類

服務(wù)引用的兩個(gè)時(shí)機(jī)

餓漢式：通過實(shí)現(xiàn)Spring的 IntitalizingBean 接口的 afterProperties 方法，容器通過調(diào)用 ReferenceBean 的 afterPropertiesSet 方法時(shí)引入服務(wù) (ReferenceBean實(shí)現(xiàn)了IntitalizingBean接口)
Bean實(shí)例化完成后填充屬性時(shí)引入服務(wù)拴魄，這里具體的Bean是Invoker的代理對(duì)象
懶漢式：只有當(dāng)這個(gè)服務(wù)被注入到其他類中時(shí)啟動(dòng)引入流程

注釋：我們創(chuàng)建出來的遠(yuǎn)程調(diào)用的代理對(duì)象清焕，實(shí)際上是ReferenceBean的一個(gè)成員變量（相當(dāng)于我們?cè)诖韺?duì)象上套了個(gè)殼，把這個(gè)殼作為一個(gè)bean注冊(cè)到spring容器中）
餓漢式：

public void afterPropertiesSet() throws Exception {

    // Initializes Dubbo's Config Beans before @Reference bean autowiring
    prepareDubboConfigBeans();

    // lazy init by default.
    if (init == null) {
        init = false;
    }

    // eager init if necessary.
    if (shouldInit()) {
        getObject();
    }
}

懶漢式：

@Override
public Object getObject() {
    return get();
}

public synchronized T get() {
    if (destroyed) {
        throw new IllegalStateException("The invoker of ReferenceConfig(" + url + ") has already destroyed!");
    }
    if (ref == null) {
        init();
    }
    return ref;
}

關(guān)于這點(diǎn)的解釋卧檐。如果 <dubbo:reference> 的init屬性開啟（餓漢式），創(chuàng)建完ReferenceBean 的時(shí)候焰宣，在afterProperties方法里面調(diào)用對(duì)應(yīng)的getObject方法霉囚，將對(duì)應(yīng)的Invoker的Bean創(chuàng)建出來并注冊(cè)到容器中。而懶漢式則是在其他的Bean去注入它的時(shí)候匕积，才會(huì)去進(jìn)行Invoker的創(chuàng)建流程
然后ContextRefreshedEvent事件那一步的處理會(huì)將我上面沒有去實(shí)例化的那些Invoker也實(shí)例化一次（個(gè)人猜測是那些懶加載沒有被其他Bean注入的Bean）
為什么要是用FactoryBean接口的方式去創(chuàng)建對(duì)應(yīng)的Bean盈罐。因?yàn)镕actoryBean本身的作用是為了能夠進(jìn)行復(fù)雜的Bean邏輯創(chuàng)建，而不通過Spring本身的三級(jí)緩存的方式創(chuàng)建Bean闪唆。而且此處的Invoker還涉及到動(dòng)態(tài)代理之類的情況盅粪，F(xiàn)actoryBean就很適合這種創(chuàng)建Bean場景
同樣的，例如SpringCloud的Feign之類的也是通過這樣的方式注入Bean

入口關(guān)鍵類 ReferenceConfig

public <T> T get(ReferenceConfigBase<T> referenceConfig) {
    String key = generator.generateKey(referenceConfig);
    Class<?> type = referenceConfig.getInterfaceClass();

    proxies.computeIfAbsent(type, _t -> new ConcurrentHashMap<>());

    ConcurrentMap<String, Object> proxiesOfType = proxies.get(type);
    proxiesOfType.computeIfAbsent(key, _k -> {
        // 觸發(fā)的地方悄蕾，最終調(diào)用到init
        Object proxy = referenceConfig.get();
        referredReferences.put(key, referenceConfig);
        return proxy;
    });

    return (T) proxiesOfType.get(key);
}

public synchronized void init() {
    if (initialized) {
        return;
    }


    if (bootstrap == null) {
        bootstrap = DubboBootstrap.getInstance();
        bootstrap.initialize();
    }

    checkAndUpdateSubConfigs();

    checkStubAndLocal(interfaceClass);
    ConfigValidationUtils.checkMock(interfaceClass, this);

    Map<String, String> map = new HashMap<String, String>();
    map.put(SIDE_KEY, CONSUMER_SIDE);

    ReferenceConfigBase.appendRuntimeParameters(map);
    if (!ProtocolUtils.isGeneric(generic)) {
        String revision = Version.getVersion(interfaceClass, version);
        if (revision != null && revision.length() > 0) {
            map.put(REVISION_KEY, revision);
        }

        String[] methods = Wrapper.getWrapper(interfaceClass).getMethodNames();
        if (methods.length == 0) {
            logger.warn("No method found in service interface " + interfaceClass.getName());
            map.put(METHODS_KEY, ANY_VALUE);
        } else {
            map.put(METHODS_KEY, StringUtils.join(new HashSet<String>(Arrays.asList(methods)), COMMA_SEPARATOR));
        }
    }
    map.put(INTERFACE_KEY, interfaceName);
    AbstractConfig.appendParameters(map, getMetrics());
    AbstractConfig.appendParameters(map, getApplication());
    AbstractConfig.appendParameters(map, getModule());
    // remove 'default.' prefix for configs from ConsumerConfig
    // appendParameters(map, consumer, Constants.DEFAULT_KEY);
    AbstractConfig.appendParameters(map, consumer);
    AbstractConfig.appendParameters(map, this);
    MetadataReportConfig metadataReportConfig = getMetadataReportConfig();
    if (metadataReportConfig != null && metadataReportConfig.isValid()) {
        map.putIfAbsent(METADATA_KEY, REMOTE_METADATA_STORAGE_TYPE);
    }
    Map<String, AsyncMethodInfo> attributes = null;
    if (CollectionUtils.isNotEmpty(getMethods())) {
        attributes = new HashMap<>();
        for (MethodConfig methodConfig : getMethods()) {
            AbstractConfig.appendParameters(map, methodConfig, methodConfig.getName());
            String retryKey = methodConfig.getName() + ".retry";
            if (map.containsKey(retryKey)) {
                String retryValue = map.remove(retryKey);
                if ("false".equals(retryValue)) {
                    map.put(methodConfig.getName() + ".retries", "0");
                }
            }
            AsyncMethodInfo asyncMethodInfo = AbstractConfig.convertMethodConfig2AsyncInfo(methodConfig);
            if (asyncMethodInfo != null) {
//                    consumerModel.getMethodModel(methodConfig.getName()).addAttribute(ASYNC_KEY, asyncMethodInfo);
                attributes.put(methodConfig.getName(), asyncMethodInfo);
            }
        }
    }

    String hostToRegistry = ConfigUtils.getSystemProperty(DUBBO_IP_TO_REGISTRY);
    if (StringUtils.isEmpty(hostToRegistry)) {
        hostToRegistry = NetUtils.getLocalHost();
    } else if (isInvalidLocalHost(hostToRegistry)) {
        throw new IllegalArgumentException("Specified invalid registry ip from property:" + DUBBO_IP_TO_REGISTRY + ", value:" + hostToRegistry);
    }
    map.put(REGISTER_IP_KEY, hostToRegistry);

    serviceMetadata.getAttachments().putAll(map);

    // 創(chuàng)建代理 即生成invoker（代理中包括invoker）
    ref = createProxy(map);

    serviceMetadata.setTarget(ref);
    serviceMetadata.addAttribute(PROXY_CLASS_REF, ref);
    ConsumerModel consumerModel = repository.lookupReferredService(serviceMetadata.getServiceKey());
    consumerModel.setProxyObject(ref);
    consumerModel.init(attributes);

    initialized = true;

    checkInvokerAvailable();

    // dispatch a ReferenceConfigInitializedEvent since 2.7.4
    dispatch(new ReferenceConfigInitializedEvent(this, invoker));
}

創(chuàng)建代理類

主要分為以下幾點(diǎn)

injvm：走jvm內(nèi)部調(diào)用（自己服務(wù)中的dubbo接口調(diào)用）
配置了URL：點(diǎn)對(duì)點(diǎn)
未配置URL票顾，從注冊(cè)中心獲取服務(wù)提供者信息

private T createProxy(Map<String, String> map) {
    if (shouldJvmRefer(map)) {
        // 本地調(diào)用的情況
        URL url = new URL(LOCAL_PROTOCOL, LOCALHOST_VALUE, 0, interfaceClass.getName()).addParameters(map);
        invoker = REF_PROTOCOL.refer(interfaceClass, url);
        if (logger.isInfoEnabled()) {
            logger.info("Using injvm service " + interfaceClass.getName());
        }
    } else {
        urls.clear();
        // 配置的url的情況 點(diǎn)對(duì)點(diǎn)/注冊(cè)中心地址
        if (url != null && url.length() > 0) { // user specified URL, could be peer-to-peer address, or register center's address.
            String[] us = SEMICOLON_SPLIT_PATTERN.split(url);
            if (us != null && us.length > 0) {
                for (String u : us) {
                    URL url = URL.valueOf(u);
                    if (StringUtils.isEmpty(url.getPath())) {
                        url = url.setPath(interfaceName);
                    }
                    if (UrlUtils.isRegistry(url)) {
                        // 如果是注冊(cè)中心础浮，將map轉(zhuǎn)換為查詢字符串，并作為refer參數(shù)的值添加到url中
                        urls.add(url.addParameterAndEncoded(REFER_KEY, StringUtils.toQueryString(map)));
                    } else {
                        // 點(diǎn)對(duì)點(diǎn)直連奠骄，合并url豆同，移除一些服務(wù)提供者的配置
                        urls.add(ClusterUtils.mergeUrl(url, map));
                    }
                }
            }
        } else { // assemble URL from register center's configuration
            // 未配置url的情況
            // if protocols not injvm checkRegistry
            if (!LOCAL_PROTOCOL.equalsIgnoreCase(getProtocol())) {
                checkRegistry();
                // 獲取注冊(cè)中心地址
                List<URL> us = ConfigValidationUtils.loadRegistries(this, false);
                if (CollectionUtils.isNotEmpty(us)) {
                    for (URL u : us) {
                        URL monitorUrl = ConfigValidationUtils.loadMonitor(this, u);
                        if (monitorUrl != null) {
                            map.put(MONITOR_KEY, URL.encode(monitorUrl.toFullString()));
                        }
                        urls.add(u.addParameterAndEncoded(REFER_KEY, StringUtils.toQueryString(map))); // registry://127.0.0.1:2181/org.apache.dubbo.registry.RegistryService?application=dubbo-demo-api-consumer&dubbo=2.0.2&pid=52327&refer=application=dubbo-demo-api-consumer&dubbo=2.0.2&generic=true&interface=org.apache.dubbo.demo.DemoService&pid=52327&register.ip=10.167.10.19&side=consumer&sticky=false&timestamp=1631087606024&registry=zookeeper&timestamp=1631087917015
                    }
                }
                if (urls.isEmpty()) {
                    throw new IllegalStateException("No such any registry to reference " + interfaceName + " on the consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion() + ", please config <dubbo:registry address=\"...\" /> to your spring config.");
                }
            }
        }

        //
        if (urls.size() == 1) {
            invoker = REF_PROTOCOL.refer(interfaceClass, urls.get(0));
        } else {
            List<Invoker<?>> invokers = new ArrayList<Invoker<?>>();
            URL registryURL = null;
            for (URL url : urls) {
                invokers.add(REF_PROTOCOL.refer(interfaceClass, url));
                if (UrlUtils.isRegistry(url)) {
                    registryURL = url; // use last registry url
                }
            }
            if (registryURL != null) { // registry url is available
                // for multi-subscription scenario, use 'zone-aware' policy by default
                String cluster = registryURL.getParameter(CLUSTER_KEY, ZoneAwareCluster.NAME);
                // The invoker wrap sequence would be: ZoneAwareClusterInvoker(StaticDirectory) -> FailoverClusterInvoker(RegistryDirectory, routing happens here) -> Invoker
                invoker = Cluster.getCluster(cluster, false).join(new StaticDirectory(registryURL, invokers));
            } else { // not a registry url, must be direct invoke.
                String cluster = CollectionUtils.isNotEmpty(invokers)
                        ? (invokers.get(0).getUrl() != null ? invokers.get(0).getUrl().getParameter(CLUSTER_KEY, ZoneAwareCluster.NAME) : Cluster.DEFAULT)
                        : Cluster.DEFAULT;
                invoker = Cluster.getCluster(cluster).join(new StaticDirectory(invokers));
            }
        }
    }

    if (logger.isInfoEnabled()) {
        logger.info("Refer dubbo service " + interfaceClass.getName() + " from url " + invoker.getUrl());
    }

    URL consumerURL = new URL(CONSUMER_PROTOCOL, map.remove(REGISTER_IP_KEY), 0, map.get(INTERFACE_KEY), map);
    MetadataUtils.publishServiceDefinition(consumerURL);

    // create service proxy 創(chuàng)建代理服務(wù)
    return (T) PROXY_FACTORY.getProxy(invoker, ProtocolUtils.isGeneric(generic));
}

此處細(xì)講一下通過注冊(cè)中心創(chuàng)建Invoker的方式（多個(gè)服務(wù)提供者的情況）
遍歷注冊(cè)中心，將注冊(cè)中心所有的服務(wù)提供者信息（DynamicDirectory）匯集起來含鳞，創(chuàng)建出一個(gè)ClusterInvoker影锈，并將ClusterInvoker的代理對(duì)象T返回給調(diào)用點(diǎn)

List<Invoker<?>> invokers = new ArrayList<Invoker<?>>();
URL registryURL = null;
for (URL url : urls) {
        // 引用服務(wù)
    invokers.add(REF_PROTOCOL.refer(interfaceClass, url));
    if (UrlUtils.isRegistry(url)) {
        registryURL = url; // use last registry url
    }
}
if (registryURL != null) { // registry url is available
    // for multi-subscription scenario, use 'zone-aware' policy by default
    String cluster = registryURL.getParameter(CLUSTER_KEY, ZoneAwareCluster.NAME);
    // The invoker wrap sequence would be: ZoneAwareClusterInvoker(StaticDirectory) -> FailoverClusterInvoker(RegistryDirectory, routing happens here) -> Invoker
    invoker = Cluster.getCluster(cluster, false).join(new StaticDirectory(registryURL, invokers));
} else { // not a registry url, must be direct invoke.
    String cluster = CollectionUtils.isNotEmpty(invokers)
            ? (invokers.get(0).getUrl() != null ? invokers.get(0).getUrl().getParameter(CLUSTER_KEY, ZoneAwareCluster.NAME) : Cluster.DEFAULT)
            : Cluster.DEFAULT;
    invoker = Cluster.getCluster(cluster).join(new StaticDirectory(invokers));
}

引用

具體協(xié)議的引用方法，以RegisterProtocol#refer為例

@Override
@SuppressWarnings("unchecked")
public <T> Invoker<T> refer(Class<T> type, URL url) throws RpcException {
    url = getRegistryUrl(url);
        // 獲取注冊(cè)中心
    Registry registry = registryFactory.getRegistry(url);
    if (RegistryService.class.equals(type)) {
        return proxyFactory.getInvoker((T) registry, type, url);
    }

    // group="a,b" or group="*"
    Map<String, String> qs = StringUtils.parseQueryString(url.getParameterAndDecoded(REFER_KEY));
    String group = qs.get(GROUP_KEY);
    if (group != null && group.length() > 0) {
        if ((COMMA_SPLIT_PATTERN.split(group)).length > 1 || "*".equals(group)) {
            return doRefer(Cluster.getCluster(MergeableCluster.NAME), registry, type, url);
        }
    }

    Cluster cluster = Cluster.getCluster(qs.get(CLUSTER_KEY));
        // 引用具體的服務(wù)
    return doRefer(cluster, registry, type, url);
}

protected <T> Invoker<T> doRefer(Cluster cluster, Registry registry, Class<T> type, URL url) {
    return interceptInvoker(getInvoker(cluster, registry, type, url), url);
}

protected <T> ClusterInvoker<T> getInvoker(Cluster cluster, Registry registry, Class<T> type, URL url) {
    // 封裝成一個(gè)directory （invoker的集合）
    DynamicDirectory<T> directory = createDirectory(type, url);
    directory.setRegistry(registry);
    directory.setProtocol(protocol);
    // all attributes of REFER_KEY
    Map<String, String> parameters = new HashMap<String, String>(directory.getConsumerUrl().getParameters());
    URL urlToRegistry = new URL(CONSUMER_PROTOCOL, parameters.remove(REGISTER_IP_KEY), 0, type.getName(), parameters);
    if (directory.isShouldRegister()) {
        directory.setRegisteredConsumerUrl(urlToRegistry);
        registry.register(directory.getRegisteredConsumerUrl());
    }
    // 建立路由規(guī)則鏈
    directory.buildRouterChain(urlToRegistry);
    // 訂閱provider
    directory.subscribe(toSubscribeUrl(urlToRegistry));

    // 包裝集群容錯(cuò)策略到invoker
    return (ClusterInvoker<T>) cluster.join(directory);
}

代理類

return (T) PROXY_FACTORY.getProxy(invoker, ProtocolUtils.isGeneric(generic));

// 以Javassist動(dòng)態(tài)代理為例
public <T> T getProxy(Invoker<T> invoker, Class<?>[] interfaces) {
    return (T) Proxy.getProxy(interfaces).newInstance(new InvokerInvocationHandler(invoker));
}

此處創(chuàng)建的代理類蝉绷，會(huì)有一個(gè)成員變量鸭廷，InvocationHandler
當(dāng)進(jìn)行Dubbo遠(yuǎn)程調(diào)用的時(shí)候，就會(huì)被對(duì)應(yīng)的InvokerInvocationHandler進(jìn)行方法攔截處理熔吗，把看似本地調(diào)用的方法變?yōu)檫h(yuǎn)程調(diào)用

最后編輯于：2022.08.02 22:26:52

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者

人面猴
序言：七十年代末靴姿，一起剝皮案震驚了整個(gè)濱河市，隨后出現(xiàn)的幾起案子磁滚，更是在濱河造成了極大的恐慌佛吓，老刑警劉巖，帶你破解...
沈念sama閱讀 211,123評(píng)論 6贊 490
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件垂攘，死亡現(xiàn)場離奇詭異维雇，居然都是意外死亡，警方通過查閱死者的電腦和手機(jī)晒他，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 90,031評(píng)論 2贊 384
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門吱型，熙熙樓的掌柜王于貴愁眉苦臉地迎上來，“玉大人陨仅，你說我怎么就攤上這事津滞。” “怎么了灼伤？”我有些...
開封第一講書人閱讀 156,723評(píng)論 0贊 345
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵触徐，是天一觀的道長。經(jīng)常有香客問我狐赡，道長撞鹉，這世上最難降的妖魔是什么？我笑而不...
開封第一講書人閱讀 56,357評(píng)論 1贊 283
?港島之戀（遺憾婚禮）
正文為了忘掉前任颖侄，我火速辦了婚禮鸟雏，結(jié)果婚禮上，老公的妹妹穿的比我還像新娘览祖。我一直安慰自己孝鹊，他們只是感情好，可當(dāng)我...
茶點(diǎn)故事閱讀 65,412評(píng)論 5贊 384
惡毒庶女頂嫁案：這布局不是一般人想出來的
文/花漫我一把揭開白布展蒂。她就那樣靜靜地躺著又活，像睡著了一般苔咪。火紅的嫁衣襯著肌膚如雪。梳的紋絲不亂的頭發(fā)上皇钞，一...
開封第一講書人閱讀 49,760評(píng)論 1贊 289
城市分裂傳說
那天悼泌，我揣著相機(jī)與錄音松捉，去河邊找鬼夹界。笑死，一個(gè)胖子當(dāng)著我的面吹牛隘世，可吹牛的內(nèi)容都是我干的可柿。我是一名探鬼主播，決...
沈念sama閱讀 38,904評(píng)論 3贊 405
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼丙者，長吁一口氣：“原來是場噩夢啊……” “哼复斥！你這毒婦竟也來了？” 一聲冷哼從身側(cè)響起械媒，我...
開封第一講書人閱讀 37,672評(píng)論 0贊 266
萬榮殺人案實(shí)錄
序言：老撾萬榮一對(duì)情侶失蹤目锭，失蹤者是張志新（化名）和其女友劉穎，沒想到半個(gè)月后纷捞，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體痢虹，經(jīng)...
沈念sama閱讀 44,118評(píng)論 1贊 303
?護(hù)林員之死
正文獨(dú)居荒郊野嶺守林人離奇死亡，尸身上長有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點(diǎn)故事閱讀 36,456評(píng)論 2贊 325
?白月光啟示錄
正文我和宋清朗相戀三年主儡，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了奖唯。大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
茶點(diǎn)故事閱讀 38,599評(píng)論 1贊 340
活死人
序言：一個(gè)原本活蹦亂跳的男人離奇死亡糜值，死狀恐怖丰捷，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情寂汇，我是刑警寧澤病往，帶...
沈念sama閱讀 34,264評(píng)論 4贊 328
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布，位于F島的核電站骄瓣，受9級(jí)特大地震影響荣恐，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜累贤，卻給世界環(huán)境...
茶點(diǎn)故事閱讀 39,857評(píng)論 3贊 312
男人毒藥：我在死后第九天來索命
文/蒙蒙一叠穆、第九天我趴在偏房一處隱蔽的房頂上張望。院中可真熱鬧臼膏，春花似錦硼被、人聲如沸。這莊子的主人今日做“春日...
開封第一講書人閱讀 30,731評(píng)論 0贊 21
一樁弒父案嚷硫，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽检访。三九已至，卻和暖如春仔掸，著一層夾襖步出監(jiān)牢的瞬間脆贵，已是汗流浹背。一陣腳步聲響...
開封第一講書人閱讀 31,956評(píng)論 1贊 264
情欲美人皮
我被黑心中介騙來泰國打工起暮，沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留卖氨，地道東北人。一個(gè)月前我還...
沈念sama閱讀 46,286評(píng)論 2贊 360
代替公主和親
正文我出身青樓负懦，卻偏偏與公主長得像筒捺，于是被迫代替她去往敵國和親。傳聞我的和親對(duì)象是個(gè)殘疾皇子纸厉，可洞房花燭夜當(dāng)晚...
茶點(diǎn)故事閱讀 43,465評(píng)論 2贊 348

Dubbo基礎(chǔ)篇 服務(wù)引用