2. 程式人生 > >dubbo系列之@Service註解解析原理（四）

dubbo系列之@Service註解解析原理（四）

阿新 • • 發佈：2019-01-08

前言

前面幾篇文章，講的是除錯環境搭建，配置解析讀取，本文講的是dubbo如何解析@service註解的，瞭解這些東西對於真正使用dubbo來說，沒有直接的東西，但是這個是我後面要寫的dubbo核心功能原始碼解析的前提，前後連貫，這樣才能瞭解的更加清晰一點。

解析入口

@service註解解析入口有兩個地方，二者是二選一的

第一種

DubboAutoConfiguration 這個自動配置類中

@ConditionalOnMissingBean
@Bean(name = ReferenceAnnotationBeanPostProcessor.BEAN_NAME)
public ReferenceAnnotationBeanPostProcessor referenceAnnotationBeanPostProcessor
 
() {
  return new ReferenceAnnotationBeanPostProcessor();
}
@ConditionalOnProperty(name = BASE_PACKAGES_PROPERTY_NAME)
@ConditionalOnClass(RelaxedPropertyResolver.class)
@Bean
public ServiceAnnotationBeanPostProcessor serviceAnnotationBeanPostProcessor(Environment environment) {
  RelaxedPropertyResolver resolver =
 
 new RelaxedPropertyResolver(environment);
  Set<String> packagesToScan = resolver.getProperty(BASE_PACKAGES_PROPERTY_NAME, Set.class, emptySet());
  return new ServiceAnnotationBeanPostProcessor(packagesToScan);
}

上面兩個配置的作用，在上文中已經講解過，此處不再贅述

第二種

@SpringBootApplication
@DubboComponentScan("com.dubbo.consumer.service"
 
)
public class ConsumerApplication {


    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class);
    }

}

請求頭上使用了@DubboComponentScan 註解，該註解是匯入一個DubboComponentScanRegistrar這個類。

@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(DubboComponentScanRegistrar.class)
public @interface DubboComponentScan {

    String[] value() default {};

    String[] basePackages() default {};

    Class<?>[] basePackageClasses() default {};

}

DubboComponentScanRegistrar是一個實現了ImportBeanDefinitionRegistrar 介面的類，主要看registerBeanDefinitions 方法，該方法會例項化一些BeanDefinition進入spring容器

Override
  public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
  // 獲取掃描包路徑
  Set<String> packagesToScan = getPackagesToScan(importingClassMetadata);
  // 註冊@service解析的類
  registerServiceAnnotationBeanPostProcessor(packagesToScan, registry);
  // 註冊解析@Reference註解的bean
  registerReferenceAnnotationBeanPostProcessor(registry);

}

在我們的除錯例子中，使用的是在啟動類中添加註解進行@DubboComponentScan 啟動的，所以這裡就按照這個方式來，其實第一種和第二種的方式是差不多的，最終都是通過初始化ServiceAnnotationBeanPostProcessor 這個類來達到解析@Service 並生成bean的目的。 接著上面的程式碼講，註冊解析@@service的方法是

registerServiceAnnotationBeanPostProcessor , 下面看一下這個方法。

private void registerServiceAnnotationBeanPostProcessor(Set<String> packagesToScan, BeanDefinitionRegistry registry) {
		// 構建ServiceAnnotationBeanPostProcessor的 BeanDefinitionBuilder
        BeanDefinitionBuilder builder = rootBeanDefinition(ServiceAnnotationBeanPostProcessor.class);
        builder.addConstructorArgValue(packagesToScan); // 掃描的包
        builder.setRole(BeanDefinition.ROLE_INFRASTRUCTURE); 
        AbstractBeanDefinition beanDefinition = builder.getBeanDefinition(); 
  		// 建立BeanDefinition並註冊到容器中。
        BeanDefinitionReaderUtils.registerWithGeneratedName(beanDefinition, registry);

}

這個方法就是這麼簡單，有些朋友可能覺得，就這幾行程式碼，就能夠解析@Service註解了？ 完全沒有看到解析的邏輯程式碼呢。其實主要的在於ServiceAnnotationBeanPostProcessor 這個類。

ServiceAnnotationBeanPostProcessor

public class ServiceAnnotationBeanPostProcessor implements BeanDefinitionRegistryPostProcessor, EnvironmentAware,
        ResourceLoaderAware, BeanClassLoaderAware {
  // 程式碼省略
}

首先我們看一下這個類他實現的介面，實現了BeanDefinitionRegistryPostProcessor, EnvironmentAware, ResourceLoaderAware, BeanClassLoaderAware這四個介面， 主要看BeanDefinitionRegistryPostProcessor這個介面，看一下下面的官方解釋

**官方解釋 **

允許在正常的BeanFactoryPostProcessor檢測開始之前註冊更多的自定義bean。特別是，BeanDefinitionRegistryPostProcessor
可以註冊更多的bean定義，然後定義BeanFactoryPostProcessor例項。也就是說可以藉此方法實現自定義的bean，通過重寫postProcessBeanDefinitionRegistry方法來自定義bean

通過看上面的解釋，我們直接找到postProcessBeanDefinitionRegistry方法

@Override
public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException {

  // 獲取掃描包，掃描包可以是多個，所以這裡使用了Set集合
  Set<String> resolvedPackagesToScan = resolvePackagesToScan(packagesToScan);
  // 判斷需要掃描的包是否為空
  if (!CollectionUtils.isEmpty(resolvedPackagesToScan)) {
    // 不為空則呼叫方法進行解析
    registerServiceBeans(resolvedPackagesToScan, registry);
  } else {
    if (logger.isWarnEnabled()) {
      logger.warn("packagesToScan is empty , ServiceBean registry will be ignored!");
    }
  }

}

registerServiceBeans

private void registerServiceBeans(Set<String> packagesToScan, BeanDefinitionRegistry registry) {
		// 定義掃描物件，該類繼承了ClassPathBeanDefinitionScanner類
        DubboClassPathBeanDefinitionScanner scanner =
                new DubboClassPathBeanDefinitionScanner(registry, environment, resourceLoader);
		// beanName解析器
        BeanNameGenerator beanNameGenerator = resolveBeanNameGenerator(registry);

        scanner.setBeanNameGenerator(beanNameGenerator);
		// 這行程式碼很重要，添加了過濾器， 一個註解過濾器，用來過濾出來寫了@Service註解的物件
        scanner.addIncludeFilter(new AnnotationTypeFilter(Service.class));
		// 掃描正式開始，遍歷包
        for (String packageToScan : packagesToScan) {

            // Registers @Service Bean first
            scanner.scan(packageToScan);

            // 開始查詢添加了@Service註解的類
            Set<BeanDefinitionHolder> beanDefinitionHolders =
                    findServiceBeanDefinitionHolders(scanner, packageToScan, registry, beanNameGenerator);
			// 找到了則不為空
            if (!CollectionUtils.isEmpty(beanDefinitionHolders)) {
				// 迴圈。
                for (BeanDefinitionHolder beanDefinitionHolder : beanDefinitionHolders) {
                    // 註冊serviceBean
                    registerServiceBean(beanDefinitionHolder, registry, scanner);
                }

                if (logger.isInfoEnabled()) {
                    logger.info(beanDefinitionHolders.size() + " annotated Dubbo's @Service Components { " +
                            beanDefinitionHolders +
                            " } were scanned under package[" + packageToScan + "]");
                }

            } else {

                if (logger.isWarnEnabled()) {
                    logger.warn("No Spring Bean annotating Dubbo's @Service was found under package["
                            + packageToScan + "]");
                }

            }

        }

    }

上面的程式碼，主要作用就是通過掃描過濾器，掃描包中添加了@Service註解的類。最後得到BeanDefinitionHolder物件，呼叫registerServiceBean來註冊ServiceBean

private void registerServiceBean(BeanDefinitionHolder beanDefinitionHolder, BeanDefinitionRegistry registry,
                                     DubboClassPathBeanDefinitionScanner scanner) {

  		// 服務介面類物件
        Class<?> beanClass = resolveClass(beanDefinitionHolder);
		// 找到@service註解
        Service service = findAnnotation(beanClass, Service.class);
		// 介面服務的實現類物件
        Class<?> interfaceClass = resolveServiceInterfaceClass(beanClass, service);
		// 得到bean的名稱
        String annotatedServiceBeanName = beanDefinitionHolder.getBeanName();
		// 構建ServiceBean物件的BeanDefinition,通過Service註解物件，以及介面服務的實現類生成ServiceBean
        AbstractBeanDefinition serviceBeanDefinition =
                buildServiceBeanDefinition(service, interfaceClass, annotatedServiceBeanName);

        // 構建ServuceBean的名稱
        String beanName = generateServiceBeanName(service, interfaceClass, annotatedServiceBeanName);
		
  		// 校驗Bean是否重複
        if (scanner.checkCandidate(beanName, serviceBeanDefinition)) { // check duplicated candidate bean
          	// 呼叫BeanDefinitionRegistry註冊。
            registry.registerBeanDefinition(beanName, serviceBeanDefinition); 

            if (logger.isInfoEnabled()) {
                logger.warn("The BeanDefinition[" + serviceBeanDefinition +
                        "] of ServiceBean has been registered with name : " + beanName);
            }

        } else {

            if (logger.isWarnEnabled()) {
                logger.warn("The Duplicated BeanDefinition[" + serviceBeanDefinition +
                        "] of ServiceBean[ bean name : " + beanName +
                        "] was be found , Did @DubboComponentScan scan to same package in many times?");
            }

        }

    }

buildServiceBeanDefinition這個方法用來構建ServiceBean物件，每個暴露出的服務，最終都會構建成一個ServiceBean,

private AbstractBeanDefinition buildServiceBeanDefinition(Service service, Class<?> interfaceClass,
                                                              String annotatedServiceBeanName) {
		// 生成ServiceBean物件BeanDefinitionBuilder
        BeanDefinitionBuilder builder = rootBeanDefinition(ServiceBean.class);
		// 獲取beanDefinition
        AbstractBeanDefinition beanDefinition = builder.getBeanDefinition();
		// 屬性集合
        MutablePropertyValues propertyValues = beanDefinition.getPropertyValues();
		// 忽略的屬性,指的是AnnotationPropertyValuesAdapter中，不把以下屬性放到PropertyValues中去
        String[] ignoreAttributeNames = of("provider", "monitor", "application", "module", "registry", "protocol", "interface");
		// 
        propertyValues.addPropertyValues(new AnnotationPropertyValuesAdapter(service, environment, ignoreAttributeNames));

        // 設定ref屬性
        addPropertyReference(builder, "ref", annotatedServiceBeanName);
        // 服務的介面
        builder.addPropertyValue("interface", interfaceClass.getName());

        /**
         * 獲取註解中的provider屬性
         */
        String providerConfigBeanName = service.provider();
        if (StringUtils.hasText(providerConfigBeanName)) {
            addPropertyReference(builder, "provider", providerConfigBeanName);
        }

        /**
         * 獲取註解中的monitor屬性
         */
        String monitorConfigBeanName = service.monitor();
        if (StringUtils.hasText(monitorConfigBeanName)) {
            addPropertyReference(builder, "monitor", monitorConfigBeanName);
        }

        /**
         * 獲取註解中的application屬性
         */
        String applicationConfigBeanName = service.application();
        if (StringUtils.hasText(applicationConfigBeanName)) {
            addPropertyReference(builder, "application", applicationConfigBeanName);
        }

        /**
         * 獲取註解中的模組屬性
         */
        String moduleConfigBeanName = service.module();
        if (StringUtils.hasText(moduleConfigBeanName)) {
            addPropertyReference(builder, "module", moduleConfigBeanName);
        }


        /**
         * 獲取註解中的註冊中心屬性
         */
        String[] registryConfigBeanNames = service.registry();

        List<RuntimeBeanReference> registryRuntimeBeanReferences = toRuntimeBeanReferences(registryConfigBeanNames);

        if (!registryRuntimeBeanReferences.isEmpty()) {
            builder.addPropertyValue("registries", registryRuntimeBeanReferences);
        }

        /**
         * 獲取註解中的協議屬性
         */
        String[] protocolConfigBeanNames = service.protocol();

        List<RuntimeBeanReference> protocolRuntimeBeanReferences = toRuntimeBeanReferences(protocolConfigBeanNames);

        if (!protocolRuntimeBeanReferences.isEmpty()) {
            builder.addPropertyValue("protocols", protocolRuntimeBeanReferences);
        }

        return builder.getBeanDefinition();

    }

最終dubbo解析出了ServiceBean物件的beandefinition放入了spring的容器。ServiceBean對於每個暴露的服務來說很重要，每個暴露的服務都擁有一個ServiceBean，這個類裡面包含了服務釋出，服務下線等操作，算是一個很核心的類，後面會講到。

在這裡插入圖片描述

相關推薦

dubbo系列之@Service註解解析原理（四）

前言 前面幾篇文章，講的是除錯環境搭建，配置解析讀取，本文講的是dubbo如何解析@service註解的，瞭解這些東西對於真正使用dubbo來說，沒有直接的東西，但是這個是我後面要寫的dubbo核心功能原始碼解析的前提，前後連貫，這樣才能瞭解的更加清晰一點。 解

dubbo系列之springboot 除錯環境搭建（一）

前言 本文是dubbo系列的第一篇，在正式講解dubbo的原始碼之前，需要搭建一套dubbo的樣例，用於我們閱讀原始碼以及理解dubbo的核心功能，本文是以springboot為基礎的，其他的通過xml配置的太麻煩了。 版本說明 springboot start

一篇就夠了系列之Service全解析

前言： 一篇就夠了系列之Activity全解析中詳細介紹了Activity的相關知識點，感興趣的同學可以看看。本篇文章主要介紹下Service的一些學習感悟，希望能對大家有所幫助。 下面從以下四個部分開展： Service基礎 Service兩種啟動方式

深入理解系列之JAVA多執行緒（2）——synchronized同步原理

多執行緒中為了解決執行緒安全問題，一個重要的手段就是同步！所謂同步其實就是使得原本各個執行緒交叉執行（非同步），變成排隊執行（同步）。同步策略使得不同執行緒操作共享資料遵循“先來後到“，從而避免某個執行緒沒有處理完資料就被另一執行緒搶佔操作出現資料被覆蓋或

硬件系列之超聲波模塊介紹（一）

返回 精度 就是 包括 發送 平時 自動 距離 c-s HC-SR04模塊可提供2cm-40cm的非接觸式距離感測功能，測距精度可達3mm： 模塊包括超聲波發生器，接收器與控制器，檢測角度30度。 控制方式： 采用IO口TRIG觸發測距，給最少10us的高電平信號 模塊自動

定時調度系列之Quartz.Net詳解（轉）

mys quic win 代碼 但是 提醒 tps 官網 etc 出處：https://www.cnblogs.com/yaopengfei/p/9216229.html 一. 背景 　　我們在日常開發中，可能你會遇到這樣的需求："每個月的3號給用戶發信息，提醒用戶XX

計算機組成原理（四）之儲存器

6.1儲存器及半導體儲存器的分類 儲存器是計算機用來儲存資訊的部件。 6.1.1  儲存器的分類 按存取速度和用途可把儲存器分為兩大類：記憶體儲器和外儲存器。 記憶體：把通過系統匯流排直接與CPU相連的儲存器稱為記憶體儲器，簡稱

spring原始碼學習之路---IOC實現原理（二）

上一章我們已經初步認識了BeanFactory和BeanDefinition，一個是IOC的核心工廠介面，一個是IOC的bean定義介面，上章提到說我們無法讓BeanFactory持有一個Map package org.springframework.beans.factory.supp

View的工作原理之Measure過程原始碼學習（四）

       上一篇文章，學習了ViewGroup和View的measure流程。文章最後講到，本文將會學習ViewGroup和普通View的onMeasure方法的工作。        因為ViewGroup是

Android Broadcast原理分析之Android新版本限制（四）

目錄 概述 官方文件介紹 原始碼解析 適配 1. 概述 隨著Android版本不斷迭代，Android對後臺的管控越來越嚴格，對於APP而言，通常來講後臺活躍的主要是廣播以及service，而Google對於後臺的管控也著重就在這兩個元件上，本篇文章主要介紹

各種音視訊編解碼學習詳解之 編解碼學習筆記（四）：Mpeg系列——Mpeg 4

   最近在研究音視訊編解碼這一塊兒，看到@bitbit大神寫的【各種音視訊編解碼學習詳解】這篇文章，非常感謝，佩服的五體投地。奈何大神這邊文章太長，在這裡我把它分解成很多小的篇幅，方便閱讀。大神部落格傳送門：https://www.cnblogs.com/skyofbitbit

java多執行緒併發系列之閉鎖(Latch)和柵欄（CyclicBarrier）

-閉鎖（Latch） 閉鎖（Latch）：一種同步方法，可以延遲執行緒的進度直到執行緒到達某個終點狀態。通俗的講就是，一個閉鎖相當於一扇大門，在大門開啟之前所有執行緒都被阻斷，一旦大門開啟所有執行緒都將通過，但是一旦大門開啟，所有執行緒都通過了，那麼這個閉鎖的狀態就失效了，門

Android-PickerView系列之介紹與使用篇（一）

宣告：本文為博主原創文章，轉載請註明出處：小嵩的部落格 一、介紹 Android-PickerView是一款仿iOS的PickerView控制元件，並封裝了時間選擇和選項選擇這兩種選擇器，詳細特性如下： WheelView —— 基礎控制元件

IE安全系列之——IE中的ActiveX（II）

0x00 使用Fuzz工具 ActiveX的Fuzzer相當之多，本次我們暫時使用一個老牌但是效能較弱的開源Fuzzer：COMRaider。選擇它的原因是它是一個圖形化的Fuzzer，介面元素簡單。但是說弱則是因為它的測試用例實在太少，而且比較陳舊（但是你可以手動新增

Spring原始碼學習之IOC容器實現原理（一）-DefaultListableBeanFactory

從這個繼承體系結構圖來看，我們可以發現DefaultListableBeanFactory是第一個非抽象類，非介面類。實際IOC容器。所以這篇部落格以DefaultListableBeanFactoryIOC容器為基準進行IOC原理解析。 一.兩個重要介面 前面已經分析了BeanFactor，它的三個直接子

公司真題系列之滴滴_餐館問題（貪心）

1、題目描述某餐館有n張桌子，每張桌子有一個引數：a 可容納的最大人數； 有m批客人，每批客人有兩個引數:b人數，c預計消費金額。 在不允許拼桌的情況下，請實現一個演算法選擇其中一部分客人，使得總預計消費金額最大輸入描述:輸入包括m+2行。 第一行兩個整數n(1 <=

caffe 學習系列之生成txt 和lmdb（2）

    在上個筆記中，已經學會了如何使用Caffe利用作者給的指令碼訓練CIFAR-10資料集，得到訓練好的CNN模型。但是在上個筆記中，使用的都是作者提供好的指令碼檔案，完全就是按照教程跑了一下提供的demo。對於自己手裡的一些圖片資料集，如何轉換圖片格式、如何計算圖片資料的均值、如何編寫protot

[算法系列之二十]字典樹（Trie）

一 概述 又稱單詞查詢樹，Trie樹，是一種樹形結構，是一種雜湊樹的變種。典型應用是用於統計，排序和儲存大量的字串（但不僅限於字串），所以經常被搜尋引擎系統用於文字詞頻統計。 二 優點 利用字串的公共字首來減少查詢時間，最大限度地減少無謂的字串比較，查詢效

Angular系列之使用者增刪的demo（五）

本篇將使用angular中的$scope,ng-repeat,ng-click,ng-modal知識點編寫一個使用者增刪的demo，也就是對前面幾篇中所提到的這些知識點做一個綜合使用。廢話不多說，直接看程式碼： （稍微使用了es6語法的一點點只是，如果不懂es6語法的，建議

Extjs6.2系列之動態設定主頁面（MainView）

在做qq登入時遇到一個情況，使用者在qq的第三方的登入介面授權成功後，qq賬號服務框架會開啟你設定的回撥頁面，並將授權資訊儲存在hash中，由於Extjs只有一個index.html頁面，其所有的檢視都由js程式碼在index.html上動態創建出來，這樣就不可避免的遇到這