#Dubbo#
文章介绍
- Dubbo中propertie文件解析以及处理原理
- Dubbo中@Service注解解析以及处理原理
- Dubbo中@Reference注解解析以及处理原理
1.0 整体架构和流程
应用启动类与配置
public class Application {public static void main(String[] args) throws Exception {AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(ProviderConfiguration.class);context.start();System.in.read();}@Configuration@EnableDubbo(scanBasePackages = "org.apache.dubbo.demo.provider")@PropertySource("classpath:/spring/dubbo-provider.properties")static class ProviderConfiguration {}
}
应用配置类为ProviderConfiguration, 在配置上有两个比较重要的注解
- @PropertySource表示将dubbo-provider.properties中的配置项添加到Spring容器中,可以通过@Value的方式获取到配置项中的值
- @EnableDubbo(scanBasePackages = "org.apache.dubbo.demo.provider")表示对指定包下的类进行扫描,扫描@Service与@Reference注解,并且进行处理
@EnableDubbo
在EnableDubbo注解上,有另外两个注解,也是研究Dubbo最重要的两个注解
- @EnableDubboConfig
- @DubboComponentScan
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Inherited
@Documented
@Import(DubboConfigConfigurationRegistrar.class)
public @interface EnableDubboConfig {boolean multiple() default true;
}@Target(ElementType.TYPE)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import(DubboComponentScanRegistrar.class)
public @interface DubboComponentScan {String[] value() default {};String[] basePackages() default {};Class<?>[] basePackageClasses() default {};}
注意两个注解中对应的@Import注解所导入的类:
- DubboConfigConfigurationRegistrar
- DubboComponentScanRegistrar
Spring在启动时会解析这两个注解,并且执行对应的Registrar类中的registerBeanDefinitions方法(这是Spring中提供的扩展功能。)
DubboConfigConfigurationRegistrar
流程
Spring启动时,会调用DubboConfigConfigurationRegistrar的registerBeanDefinitions方法,该方法是利用Spring中的AnnotatedBeanDefinitionReader来读取:
- DubboConfigConfiguration.Single.class
- DubboConfigConfiguration.Multiple.class
这两个类上的注解。
@EnableDubboConfigBindings({@EnableDubboConfigBinding(prefix = "dubbo.application", type = ApplicationConfig.class),@EnableDubboConfigBinding(prefix = "dubbo.module", type = ModuleConfig.class),@EnableDubboConfigBinding(prefix = "dubbo.registry", type = RegistryConfig.class),@EnableDubboConfigBinding(prefix = "dubbo.protocol", type = ProtocolC