dubboservice注解用法_dubbo系列之springboot核心配置读取（三）

&＃64;Configuration
&＃64;ConditionalOnProperty(prefix &＃61; DUBBO_PREFIX, name &＃61; "enabled", matchIfMissing &＃61; true, havingValue &＃61; "true")
&＃64;ConditionalOnClass(AbstractConfig.class)
public class DubboAutoConfiguration {// 单个dubbo配置绑定bean &＃xff0c; 默认就是单个&＃64;EnableDubboConfigprotected static class SingleDubboConfigConfiguration {}/*** 多个dubbo配置绑定bean , 默认不使用。**/&＃64;ConditionalOnProperty(name &＃61; MULTIPLE_CONFIG_PROPERTY_NAME, havingValue &＃61; "true")&＃64;EnableDubboConfig(multiple &＃61; true)protected static class MultipleDubboConfigConfiguration {}/*** service类&＃xff0c;服务提供者的BeanDefinitionRegistryPostProcessor类&＃xff0c;用来解析* &＃64;Service注解&＃xff0c;生成Service的BeanDefinition类&＃xff0c;放入spring容器&＃xff0c;供spring容器生成Bean**/&＃64;ConditionalOnProperty(name &＃61; BASE_PACKAGES_PROPERTY_NAME)&＃64;ConditionalOnClass(RelaxedPropertyResolver.class)&＃64;Beanpublic ServiceAnnotationBeanPostProcessor serviceAnnotationBeanPostProcessor(Environment environment) {RelaxedPropertyResolver resolver &＃61; new RelaxedPropertyResolver(environment);Set packagesToScan &＃61; resolver.getProperty(BASE_PACKAGES_PROPERTY_NAME, Set.class, emptySet());return new ServiceAnnotationBeanPostProcessor(packagesToScan);}// springboot dataBinder 机制的扩展&＃xff0c;用来将具体的属性设置到相应的实体类里面去。&＃64;ConditionalOnClass(RelaxedDataBinder.class)&＃64;Bean&＃64;Scope(scopeName &＃61; SCOPE_PROTOTYPE)public RelaxedDubboConfigBinder relaxedDubboConfigBinder() {return new RelaxedDubboConfigBinder();}/*** 用来解析&＃64;Reference 注解&＃xff0c;消费者引用哪些服务&＃xff0c;通过这个注解来进行引用* 给标注这个&＃64;Reference注解的属性赋值&＃xff0c; 和&＃64;autowired的做法类似。* */&＃64;ConditionalOnMissingBean&＃64;Bean(name &＃61; ReferenceAnnotationBeanPostProcessor.BEAN_NAME)public ReferenceAnnotationBeanPostProcessor referenceAnnotationBeanPostProcessor() {return new ReferenceAnnotationBeanPostProcessor();}}

// 配置如下
dubbo.application
dubbo.module
dubbo.registry
dubbo.protocol
dubbo.monitor
dubbo.provider
dubbo.consumer

// 配置如下
dubbo.applications
dubbo.modules
dubbo.registries
dubbo.protocols
dubbo.monitors
dubbo.providers
dubbo.consumers

&＃64;Target({ElementType.TYPE})
&＃64;Retention(RetentionPolicy.RUNTIME)
&＃64;Inherited
&＃64;Documented
&＃64;Import(DubboConfigConfigurationSelector.class) // 主要作用是这个
public &＃64;interface EnableDubboConfig {/*** It indicates whether binding to multiple Spring Beans.** &＃64;return the default value is false* &＃64;revised 2.5.9*/boolean multiple() default false;}

public class DubboConfigConfigurationSelector implements ImportSelector, Ordered {&＃64;Overridepublic String[] selectImports(AnnotationMetadata importingClassMetadata) {// 获取注解上的属性&＃xff0c;这个是通过&＃64;EnableDubboConfig导入的&＃xff0c;所以AnnotationMetadata里面就包含了这个注解的值AnnotationAttributes attributes &＃61; AnnotationAttributes.fromMap(importingClassMetadata.getAnnotationAttributes(EnableDubboConfig.class.getName()));// 是否是多配置&＃xff0c;默认为falseboolean multiple &＃61; attributes.getBoolean("multiple");if (multiple) {return of(DubboConfigConfiguration.Multiple.class.getName());} else {// 这里就直接讲解单配置的。return of(DubboConfigConfiguration.Single.class.getName());}}private static T[] of(T... values) {return values;}&＃64;Overridepublic int getOrder() {return HIGHEST_PRECEDENCE;}}

&＃64;EnableDubboConfigBindings({&＃64;EnableDubboConfigBinding(prefix &＃61; "dubbo.application", type &＃61; ApplicationConfig.class),&＃64;EnableDubboConfigBinding(prefix &＃61; "dubbo.module", type &＃61; ModuleConfig.class),&＃64;EnableDubboConfigBinding(prefix &＃61; "dubbo.registry", type &＃61; RegistryConfig.class),&＃64;EnableDubboConfigBinding(prefix &＃61; "dubbo.protocol", type &＃61; ProtocolConfig.class),&＃64;EnableDubboConfigBinding(prefix &＃61; "dubbo.monitor", type &＃61; MonitorConfig.class),&＃64;EnableDubboConfigBinding(prefix &＃61; "dubbo.provider", type &＃61; ProviderConfig.class),&＃64;EnableDubboConfigBinding(prefix &＃61; "dubbo.consumer", type &＃61; ConsumerConfig.class)})public static class Single {}

&＃64;Target({ElementType.TYPE})
&＃64;Retention(RetentionPolicy.RUNTIME)
&＃64;Documented
&＃64;Import(DubboConfigBindingsRegistrar.class) // 导入了这个类。
public &＃64;interface EnableDubboConfigBindings {/*** The value of {&＃64;link EnableDubboConfigBindings}** &＃64;return non-null*/EnableDubboConfigBinding[] value();}

public class DubboConfigBindingsRegistrar implements ImportBeanDefinitionRegistrar, EnvironmentAware {private ConfigurableEnvironment environment;&＃64;Overridepublic void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {// 获取导入此类的注解信息&＃xff0c;&＃64;EnableDubboConfigBindingsAnnotationAttributes attributes &＃61; AnnotationAttributes.fromMap(importingClassMetadata.getAnnotationAttributes(EnableDubboConfigBindings.class.getName()));// 获取&＃64;EnableDubboConfigBinding 子注解AnnotationAttributes[] annotationAttributes &＃61; attributes.getAnnotationArray("value");// 初始化DubboConfigBindingRegistrar类&＃xff0c;该类的主要作用就是为了解析单个的&＃64;EnableDubboConfigBinding注解DubboConfigBindingRegistrar registrar &＃61; new DubboConfigBindingRegistrar();registrar.setEnvironment(environment);for (AnnotationAttributes element : annotationAttributes) {// 循环注册&＃xff0c;通过注解里面的信息&＃xff0c;生成Dubbo配置的BeanDefinition&＃xff0c;最后放入spring容器中&＃xff0c;供spring容器实例化。registrar.registerBeanDefinitions(element, registry);}}&＃64;Overridepublic void setEnvironment(Environment environment) {Assert.isInstanceOf(ConfigurableEnvironment.class, environment);this.environment &＃61; (ConfigurableEnvironment) environment;}}

protected void registerBeanDefinitions(AnnotationAttributes attributes, BeanDefinitionRegistry registry) {//1. 从环境 中取出 响应的属性名 String prefix &＃61; environment.resolvePlaceholders(attributes.getString("prefix"));// 2. 获取dubbo的配置类的classClass configClass &＃61; attributes.getClass("type");// 3. 获取是否是多个dubbo的配置boolean multiple &＃61; attributes.getBoolean("multiple");// 注册dubbo的配置beanregisterDubboConfigBeans(prefix, configClass, multiple, registry);}

private void registerDubboConfigBeans(String prefix,Class configClass,boolean multiple,BeanDefinitionRegistry registry) {// 根据属性名&＃xff0c;如&＃xff1a;dubbo.application 获取具体的属性值Map properties &＃61; getSubProperties(environment.getPropertySources(), prefix);if (CollectionUtils.isEmpty(properties)) {// 如果没有配置&＃xff0c;则没有必要生成对应的dubbo配置bean了if (log.isDebugEnabled()) {log.debug("There is no property for binding to dubbo config class [" &＃43; configClass.getName()&＃43; "] within prefix [" &＃43; prefix &＃43; "]");}return;}// BeanNameSet beanNames &＃61; multiple ? resolveMultipleBeanNames(properties) :Collections.singleton(resolveSingleBeanName(properties, configClass, registry));for (String beanName : beanNames) {// 生成benaregisterDubboConfigBean(beanName, configClass, registry);// 注册dubbo的DubboConfigBindingBeanPostProcessorregisterDubboConfigBindingBeanPostProcessor(prefix, beanName, multiple, registry);}}private void registerDubboConfigBean(String beanName, Class configClass,BeanDefinitionRegistry registry) {// 生成BeanDefinitionBuilderBeanDefinitionBuilder builder &＃61; rootBeanDefinition(configClass);AbstractBeanDefinition beanDefinition &＃61; builder.getBeanDefinition();// 通过BeanDefinitionRegistry注册dubbo的配置beanregistry.registerBeanDefinition(beanName, beanDefinition);if (log.isInfoEnabled()) {log.info("The dubbo config bean definition [name : " &＃43; beanName &＃43; ", class : " &＃43; configClass.getName() &＃43;"] has been registered.");}}

public DubboConfigBindingBeanPostProcessor(String prefix, String beanName) {Assert.notNull(prefix, "The prefix of Configuration Properties must not be null");Assert.notNull(beanName, "The name of bean must not be null");this.prefix &＃61; prefix; // 属性前缀this.beanName &＃61; beanName; // dubbo的配置类名}
&＃64;Override
public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {// 会在每一个bean实例化之后、初始化&＃xff08;如afterPropertiesSet方法&＃xff09;之前被调用。if (beanName.equals(this.beanName) && bean instanceof AbstractConfig) {AbstractConfig dubboConfig &＃61; (AbstractConfig) bean;// 将属性和配置进行绑定dubboConfigBinder.bind(prefix, dubboConfig);if (log.isInfoEnabled()) {log.info("The properties of bean [name : " &＃43; beanName &＃43; "] have been binding by prefix of " &＃43;"configuration properties : " &＃43; prefix);}}return bean;}&＃64;Override
public void afterPropertiesSet() throws Exception {// DubboConfigBindingBeanPostProcessor 初始化之后就会执行if (dubboConfigBinder &＃61;&＃61; null) {try {// 从容器中获取DubboConfigBinder &＃xff0c; DubboConfigBinder的作用范围是prototype &＃xff0c; 每次调用getbean都会新创建一个dubboConfigBinder &＃61; applicationContext.getBean(DubboConfigBinder.class);} catch (BeansException ignored) {if (log.isDebugEnabled()) {log.debug("DubboConfigBinder Bean can&＃39;t be found in ApplicationContext.");}// Use Default implementationdubboConfigBinder &＃61; createDubboConfigBinder(applicationContext.getEnvironment());}}dubboConfigBinder.setIgnoreUnknownFields(ignoreUnknownFields);dubboConfigBinder.setIgnoreInvalidFields(ignoreInvalidFields);}

public class RelaxedDubboConfigBinder extends AbstractDubboConfigBinder {&＃64;Overridepublic void bind(String prefix, C dubboConfig) {RelaxedDataBinder relaxedDataBinder &＃61; new RelaxedDataBinder(dubboConfig);// Set ignored*relaxedDataBinder.setIgnoreInvalidFields(isIgnoreInvalidFields());relaxedDataBinder.setIgnoreUnknownFields(isIgnoreUnknownFields());//从Environment中获取属性Map properties &＃61; getSubProperties(getPropertySources(), prefix);// 将属性MAP转换为MutablePropertyValuesMutablePropertyValues propertyValues &＃61; new MutablePropertyValues(properties);// 绑定relaxedDataBinder.bind(propertyValues);}
}