3.Dubbo源码分析----Dubbo的Service注解分析

 前面已经对Dubbo跟Spring Boot的结合原理的分析了[https://www.jianshu.com/p/7048774803d5](Dubbo源码分析----Dubbo在Spring Boot启动时如何运行的),现在就是对前面几个注册的Bean进行分析
 ServiceAnnotationBeanPostProcessor这个类用来处理Service标签的类。前面对于这个类有简单的介绍,这个类实现了spring的BeanDefinitionRegistryPostProcessor类,在Spring中这个类的是可以用来拓展的,当用户需要自定义注册bean的时候可以是实现这个接口的postProcessBeanDefinitionRegistry方法。这个接口的方法可以在BeanFactoryPostProcessor检测开始之前注册其他bean定义。查看ServiceAnnotationBeanPostProcessor的postProcessBeanDefinitionRegistry方法

    @Override
    public void postProcessBeanDefinitionRegistry(BeanDefinitionRegistry registry) throws BeansException {
        //packagesToScan(需要扫描的包参数)在创建这个Bean的时候当作参数传入了,这里会对参数进行去空格,并把配置文件中的配置的扫描参数也放到一起处理
        Set<String> resolvedPackagesToScan = resolvePackagesToScan(packagesToScan);
        //判断扫描列表是不是空
        if (!CollectionUtils.isEmpty(resolvedPackagesToScan)) {
            //注册包里面的Bean
            registerServiceBeans(resolvedPackagesToScan, registry);
        } else {
            if (logger.isWarnEnabled()) {
                logger.warn("packagesToScan is empty , ServiceBean registry will be ignored!");
            }
        }
    }

 主要的逻辑集中在registerServiceBeans方法中,这个方法就是查找需要扫面包里面的类贴有Service标签的类并注册成Bean。

    private void registerServiceBeans(Set<String> packagesToScan, BeanDefinitionRegistry registry) {
        // 定义扫描对象,该类继承了ClassPathBeanDefinitionScanner类,继承的原因主要是将ClassPathBeanDefinitionScanner中的protect类型的方法变成public级别的
        //ClassPathBeanDefinitionScanner的作用就是扫面类路径中的Bean候选者
        DubboClassPathBeanDefinitionScanner scanner =
                new DubboClassPathBeanDefinitionScanner(registry, environment, resourceLoader);
        //获取beanNameGenerator(用于为bean定义生成bean名称的策略接口)
        BeanNameGenerator beanNameGenerator = resolveBeanNameGenerator(registry);
        //设置BeanNameGenerator以用于检测到的scanner,这里可以理解为为注册的Bean生成BeanName用
        scanner.setBeanNameGenerator(beanNameGenerator);
        //将包含类型过滤器添加到包含列表的,就是一个过滤器,用来过滤贴了Service注解的对象。
        scanner.addIncludeFilter(new AnnotationTypeFilter(Service.class));
        //遍历包
        for (String packageToScan : packagesToScan) {
            // Registers @Service Bean first
            //注册指定包路径下的贴有Service的Bean
            scanner.scan(packageToScan);
            //查找@Service的所有BeanDefinitionHolders,无论@ComponentScan是否扫描。
            Set<BeanDefinitionHolder> beanDefinitionHolders =
                    findServiceBeanDefinitionHolders(scanner, packageToScan, registry, beanNameGenerator);
            //如果BeanDefinitionHolder不为空,对于BeanDefinitionHolder这个对象不知道可以去看看前面的文章
            if (!CollectionUtils.isEmpty(beanDefinitionHolders)) {
                //遍历然后注册Bean
                for (BeanDefinitionHolder beanDefinitionHolder : beanDefinitionHolders) {
                    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标签的类,并会把生成的Bean相关信息封装到BeanDefinitionHolder中,然后对BeanDefinitionHolder集合进行遍历,进行自定义的注册,接下来就是分析自定义注册的部分registerServiceBean方法。

    private void registerServiceBean(BeanDefinitionHolder beanDefinitionHolder, BeanDefinitionRegistry registry,
                                     DubboClassPathBeanDefinitionScanner scanner) {
        //获取beanDefinitionHolder中的BeanClass
        Class<?> beanClass = resolveClass(beanDefinitionHolder);
        //beanClass中的Service注解
        Service service = findAnnotation(beanClass, Service.class);
        //从service注解中获取用户定义的interfaceClass如果没有定义则用beanClass的接口类中的第一个
        Class<?> interfaceClass = resolveServiceInterfaceClass(beanClass, service);
        //获取BeanName
        String annotatedServiceBeanName = beanDefinitionHolder.getBeanName();
        //使用BeanDefinitionBuilder创建Bean,bean的类型是ServiceBean,这里面会添加一些信息到Bean中比如ref,provider,monitor等信息
        AbstractBeanDefinition serviceBeanDefinition =
                buildServiceBeanDefinition(service, interfaceClass, annotatedServiceBeanName);
        // 生成beanName
        String beanName = generateServiceBeanName(service, interfaceClass, annotatedServiceBeanName);
        //检查是否已经创建了相同名称跟类型的bean,没有就进行注册
        if (scanner.checkCandidate(beanName, serviceBeanDefinition)) {
            //注册Bean,这里可以参考前面的spring的源码分析
            registry.registerBeanDefinition(beanName, serviceBeanDefinition);
            if (logger.isInfoEnabled()) {
                logger.info("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?");
            }
        }
    }
//------------创建Bean 的buildServiceBeanDefinition方法
    private AbstractBeanDefinition buildServiceBeanDefinition(Service service, Class<?> interfaceClass,
                                                              String annotatedServiceBeanName) {
        //注册Bean 的Class为ServiceBean.class
        BeanDefinitionBuilder builder = rootBeanDefinition(ServiceBean.class);
        //获取AbstractBeanDefinition,是为了后面添加属性
        AbstractBeanDefinition beanDefinition = builder.getBeanDefinition();
        //从AbstractBeanDefinition中获取MutablePropertyValues对象(允许对属性进行简单操作,并提供构造函数以支持Map中的深层复制和构造)
        MutablePropertyValues propertyValues = beanDefinition.getPropertyValues();
        String[] ignoreAttributeNames = of("provider", "monitor", "application", "module", "registry", "protocol",
                "interface", "interfaceName");
        //添加自己的属性适配器
        propertyValues.addPropertyValues(new AnnotationPropertyValuesAdapter(service, environment, ignoreAttributeNames));
        //将“ref”属性引用到带注释的@Service Bean
        // References "ref" property to annotated-@Service Bean
        addPropertyReference(builder, "ref", annotatedServiceBeanName);
        // Set interface
        builder.addPropertyValue("interface", interfaceClass.getName());
        //设置标签中配置的providerName到provider属性,后面基本都是这种操作
        String providerConfigBeanName = service.provider();
        if (StringUtils.hasText(providerConfigBeanName)) {
            addPropertyReference(builder, "provider", providerConfigBeanName);
        }
        ........
}

 这样上面的Service标签的处理就已经结束了,注意上面最后创建的Bean的是ServiceBean,这个类很重要。接下来就是对Reference标签的处理分析。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,445评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,889评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,047评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,760评论 1 276
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,745评论 5 367
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,638评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,011评论 3 398
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,669评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,923评论 1 299
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,655评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,740评论 1 330
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,406评论 4 320
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,995评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,961评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,197评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,023评论 2 350
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,483评论 2 342

推荐阅读更多精彩内容