DataSource的注册容器和初始化--688IT编程网

DataSource的注册容器和初始化

⽰例配置

spring:

datasource:

druid:

driver-class-name: sql.cj.jdbc.Driver

url: jdbc:mysql://127.0.0.1:3306/test?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF-8&useSSL=false

username: root

password: xxxx

DruidDataSourceAutoConfigure的⾃动配置和loadBeanDefinitionsForBeanMethod处理

在druid-spring-boot-starter.jar包META-INF/spring.factories⽂件⽬录下有个⾃动装配的配置，如下。

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\

com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure

⽽DruidDataSourceAutoConfigure类被@Configuration注解，且内部有个@Bean修饰的⽅法，正是DataSource，所以会在DruidDataSourceAutoConfigure时，会调⽤loadBeanDefinitionsForBeanMethod将DataSource注册IOC容器。具体@Configuration源码分析可见前⽂，或根据下⾯附调⽤链debug

package com.alibaba.druid.spring.boot.autoconfigure;

import com.alibaba.druid.pool.DruidDataSource;

import com.alibaba.druid.spring.boot.autoconfigure.properties.DruidStatProperties;

import com.alibaba.druid.spring.boot.autoconfigure.stat.DruidFilterConfiguration;

import com.alibaba.druid.spring.boot.autoconfigure.stat.DruidSpringAopConfiguration;

import com.alibaba.druid.spring.boot.autoconfigure.stat.DruidStatViewServletConfiguration;

import com.alibaba.druid.spring.boot.autoconfigure.stat.DruidWebStatFilterConfiguration;

import javax.sql.DataSource;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.boot.autoconfigure.AutoConfigureBefore;

import org.springframework.dition.ConditionalOnClass;

import org.springframework.dition.ConditionalOnMissingBean;

import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;

import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;

import org.t.properties.EnableConfigurationProperties;

import t.annotation.Bean;

import t.annotation.Configuration;

import t.annotation.Import;

@Configuration

@ConditionalOnClass({DruidDataSource.class})

@AutoConfigureBefore({DataSourceAutoConfiguration.class})

@EnableConfigurationProperties({DruidStatProperties.class, DataSourceProperties.class})

@Import({DruidSpringAopConfiguration.class, DruidStatViewServletConfiguration.class, DruidWebStatFilterConfiguration.class, DruidFilterConfiguration.class})

public class DruidDataSourceAutoConfigure {

private static final Logger LOGGER = Logger(DruidDataSourceAutoConfigure.class);

public DruidDataSourceAutoConfigure() {

}

@Bean(

initMethod = "init"

)

@ConditionalOnMissingBean

public DataSource dataSource() {

LOGGER.info("Init DruidDataSource");

return new DruidDataSourceWrapper();

}

DataSource注册IOC容器调⽤链

"main@1" prio=5 tid=0x1 nid=NA runnable

java.lang.Thread.State: RUNNABLE

at org.springframework.beans.factory.isterBeanDefinition(DefaultListableBeanFactory.java:982)

at t.annotation.ConfigurationClassBeanDefinitionReader.loadBeanDefinitionsForBeanMethod(ConfigurationClassBeanDefinitionReader.java:295)

at t.annotation.ConfigurationClassBeanDefinitionReader.loadBeanDefinitionsForConfigurationClass(ConfigurationClassBeanDefinitionReader.java:153) at t.annotation.ConfigurationClassBeanDefinitionReader.loadBeanDefinitions(ConfigurationClassBeanDefinitionReader.java:129)

at t.annotation.ConfigurationClassPostProcessor.processConfigBeanDefinitions(ConfigurationClassPostProcessor.java:348)

at t.annotation.ConfigurationClassPostProcessor.postProcessBeanDefinitionRegistry(ConfigurationClassPostProcessor.java:252)

at t.support.PostProcessorRegistrationDelegate.invokeBeanDefinitionRegistryPostProcessors(PostProcessorRegistrationDelegate.java:285)

at t.support.PostProcessorRegistrationDelegate.invokeBeanFactoryPostProcessors(PostProcessorRegistrationDelegate.java:99)

at t.support.AbstractApplicationContext.invokeBeanFactoryPostProcessors(AbstractApplicationContext.java:751)

at t.fresh(AbstractApplicationContext.java:569)

- locked <0x11ac> (a java.lang.Object)

at org.springframework.boot.fresh(ServletWebServerApplicationContext.java:144)

at org.springframework.fresh(SpringApplication.java:767)

at org.springframework.fresh(SpringApplication.java:759)

at org.springframework.freshContext(SpringApplication.java:426)

at org.springframework.boot.SpringApplication.run(SpringApplication.java:326)

at org.springframework.boot.SpringApplication.run(SpringApplication.java:1309)

at org.springframework.boot.SpringApplication.run(SpringApplication.java:1298)

at com.java.study.StudyApplication.main(StudyApplication.java:13)

DataSource初始化

初始化⼊⼝依然是AbstractAutowireCapableBeanFactory#initializeBean()，在前⾯可以看到创建DataSource的类型是DruidDataSourceWrapper.class，所以在invokeInitMethods⽅法中调⽤DruidDataSourceWrapper#afterPropertiesSet()，在此⽅法中set⽤户名密码，以及url和DriverClassName

protected void invokeInitMethods(String beanName, Object bean, @Nullable RootBeanDefinition mbd)

throws Throwable {

boolean isInitializingBean = (bean instanceof InitializingBean);

if (isInitializingBean && (mbd == null || !mbd.isExternallyManagedInitMethod("afterPropertiesSet"))) {

if (logger.isTraceEnabled()) {

}

if (SecurityManager() != null) {

try {

AccessController.doPrivileged((PrivilegedExceptionAction<Object>) () -> {

((InitializingBean) bean).afterPropertiesSet();

return null;

}, getAccessControlContext());

}

catch (PrivilegedActionException pae) {

Exception();

}

else {

((InitializingBean) bean).afterPropertiesSet();

}

主要在初始化时，进⾏初始化前的属性绑定，调⽤ConfigurationPropertiesBindingPostProcessor#postP

rocessBeforeInitialization()，后⾯就是属性绑定的过程

@Override

public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {

(this.applicationContext, bean, beanName));

return bean;

}

username、password、url和DriverClassName便是在DruidAbstractDataSource中进⾏设置。

public abstract class DruidAbstractDataSource extends WrapperAdapter implements DruidAbstractDataSourceMBean, DataSource, DataSourceProxy, Serializable {

public void setUsername(String username) {

if (StringUtils.equals(this.username, username)) {

return;

}

if (inited) {

throw new UnsupportedOperationException();

}

this.username = username;

}

public void setPassword(String password) {

if (StringUtils.equals(this.password, password)) {

return;

}

if (inited) {

LOG.info("password changed");

}

this.password = password;

}

public void setUrl(String jdbcUrl) {

if (StringUtils.equals(this.jdbcUrl, jdbcUrl)) {

return;

}

if (inited) {

throw new UnsupportedOperationException();

}

if (jdbcUrl != null) {

jdbcUrl = im();

}

this.jdbcUrl = jdbcUrl;

// if (jdbcUrl.startsWith(ConfigFilter.URL_PREFIX)) {

// this.filters.add(new ConfigFilter());

// }

}

public void setDriverClassName(String driverClass) {

if (driverClass != null && driverClass.length() > 256) {

throw new IllegalArgumentException("driverClassName length > 256.");

}

if (JdbcConstants.ORACLE_DRIVER2.equalsIgnoreCase(driverClass)) {

driverClass = "oracle.jdbc.OracleDriver";

LOG.warn("oracle.jdbc.driver.OracleDriver is deprecated.Having use oracle.jdbc.OracleDriver.");

}

spring framework jar包if (inited) {

if (StringUtils.equals(this.driverClass, driverClass)) {

return;

}

throw new UnsupportedOperationException();

}

this.driverClass = driverClass;

}

获取property

此时便要去看这些value值怎么从yaml⽂件中取出来进⾏绑定的。

先看JavaBeanBinder#bind()⽅法，最后set⽅法中value值，便是property.setValue(beanSupplier, bound)；中的bound，所以继续追踪propertyBinder.bindProperty()

private <T> boolean bind(BeanSupplier<T> beanSupplier, DataObjectPropertyBinder propertyBinder,

BeanProperty property) {

String propertyName = Name();

ResolvableType type = Type();

Supplier<Object> value = Value(beanSupplier);

Annotation[] annotations = Annotations();

Object bound = propertyBinder.bindProperty(propertyName,

Bindable.of(type).withSuppliedValue(value).withAnnotations(annotations));

if (bound == null) {

return false;

}

if (property.isSettable()) {

property.setValue(beanSupplier, bound);

}

else if (value == null || !bound.())) {

throw new IllegalStateException("No setter found for property: " + Name());

}

return true;

}

然后会调⽤Binder#bindProperty()，再调⽤到Binder#bindObject()⽅法时，会去调⽤findProperty(name, context)，属性值便是通过此⽅法查出来的private <T> Object bindObject(ConfigurationPropertyName name, Bindable<T> target, BindHandler handler,

Context context, boolean allowRecursiveBinding) {

ConfigurationProperty property = findProperty(name, context);

if (property == null && context.depth != 0 && Sources(), name)) {

return null;

}

AggregateBinder<?> aggregateBinder = getAggregateBinder(target, context);

if (aggregateBinder != null) {

return bindAggregate(name, target, handler, context, aggregateBinder);

}

if (property != null) {

try {

return bindProperty(target, context, property);

}

catch (ConverterNotFoundException ex) {

// We might still be able to bind it using the recursive binders

Object instance = bindDataObject(name, target, handler, context, allowRecursiveBinding);

if (instance != null) {

return instance;

}

throw ex;

}

return bindDataObject(name, target, handler, context, allowRecursiveBinding);

}

当source为OriginTrackedMapPropertySource时，获取yaml定义的属性

private ConfigurationProperty findProperty(ConfigurationPropertyName name, Context context) {

if (name.isEmpty()) {

return null;

}

for (ConfigurationPropertySource source : Sources()) {

ConfigurationProperty property = ConfigurationProperty(name);

if (property != null) {

return property;

}

return null;

}

property的初始化赋值

上⾯看到来怎么取property，但property在哪个过程开始赋值的呢？这就要去看application.yaml什么时候加载。（可参考前⽂《Springboot源码之application.yaml读取过程》

主要是ConfigDataEnvironmentContributors#withProcessedImports()中，传⼊resource和configData，然后到ofUnboundImport⽅法中进⾏绑定。ConfigDataEnvironmentContributors withProcessedImports(ConfigDataImporter importer,

ConfigDataActivationContext activationContext) {

while (true) {

ConfigDataEnvironmentContributor contributorAndChildren = contributor.withChildren(importPhase,

asContributors(imported));

}

static ConfigDataEnvironmentContributor ofUnboundImport(ConfigDataResource resource, ConfigData configData,

int propertySourceIndex) {

PropertySource<?> propertySource = PropertySources().get(propertySourceIndex);

ConfigurationPropertySource configurationPropertySource = ConfigurationPropertySource.from(propertySource);

boolean ignoreImports = Options().contains(ConfigData.Option.IGNORE_IMPORTS);

return new ConfigDataEnvironmentContributor(Kind.UNBOUND_IMPORT, resource, propertySource,

configurationPropertySource, null, ignoreImports, null);

}

最后在SpringConfigurationPropertySource#from()中对mapper进⾏赋值。

static SpringConfigurationPropertySource from(PropertySource<?> source) {

PropertyMapper[] mappers = getPropertyMappers(source);

if (isFullEnumerable(source)) {

return new SpringIterableConfigurationPropertySource((EnumerablePropertySource<?>) source, mappers);

}

return new SpringConfigurationPropertySource(source, mappers);

}

application.yaml的读取并存储property过程调⽤链：

"main@1" prio=5 tid=0x1 nid=NA runnable

java.lang.Thread.State: RUNNABLE

at org.t.properties.source.SpringConfigurationPropertySource.<init>(SpringConfigurationPropertySource.java:73)

at org.t.properties.source.SpringIterableConfigurationPropertySource.<ini

t>(SpringIterableConfigurationPropertySource.java:63)

at org.t.properties.source.SpringConfigurationPropertySource.from(SpringConfigurationPropertySource.java:148)

at org.t.properties.source.ConfigurationPropertySource.from(ConfigurationPropertySource.java:96)

at org.t.config.ConfigDataEnvironmentContributor.ofUnboundImport(ConfigDataEnvironmentContributor.java:286)

at org.t.config.ConfigDataEnvironmentContributors.lambda$asContributors$1(ConfigDataEnvironmentContributors.java:154)

at org.t.config.ConfigDataEnvironmentContributors$$Lambda$93.855700733.accept(Unknown Source:-1)

at java.util.LinkedHashMap.forEach(LinkedHashMap.java:684)

at java.util.Collections$UnmodifiableMap.forEach(Collections.java:1505)

at org.t.config.ConfigDataEnvironmentContributors.asContributors(ConfigDataEnvironmentContributors.java:152)

at org.t.config.ConfigDataEnvironmentContributors.withProcessedImports(ConfigDataEnvironmentContributors.java:123)

at org.t.config.ConfigDataEnvironment.processInitial(ConfigDataEnvironment.java:230)

at org.t.config.ConfigDataEnvironment.processAndApply(ConfigDataEnvironment.java:217)

at org.t.config.ConfigDataEnvironmentPostProcessor.postProcessEnvironment(ConfigDataEnvironmentPostProcessor.java:88)

at org.t.config.ConfigDataEnvironmentPostProcessor.postProcessEnvironment(ConfigDataEnvironmentPostProcessor.java:80)

at org.ApplicationEnvironmentPreparedEvent(EnvironmentPostProcessorApplicationListener.java:100)

at org.ApplicationEvent(EnvironmentPostProcessorApplicationListener.java:86)

at t.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:203)

at t.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:196)

at t.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:170)

at t.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:148)

at org.t.vironmentPrepared(EventPublishingRunListener.java:82)

at org.springframework.boot.SpringApplicationRunListeners.lambda$environmentPrepared$2(SpringApplicationRunListeners.java:63)

at org.springframework.boot.SpringApplicationRunListeners$$Lambda$41.586358252.accept(Unknown Source:-1)

at java.util.ArrayList.forEach(ArrayList.java:1257)

at org.springframework.boot.SpringApplicationRunListeners.doWithListeners(SpringApplicationRunListeners.java:117)

at org.springframework.boot.SpringApplicationRunListeners.doWithListeners(SpringApplicationRunListeners.java:111)

at org.springframework.vironmentPrepared(SpringApplicationRunListeners.java:62)

at org.springframework.boot.SpringApplication.prepareEnvironment(SpringApplication.java:362)

at org.springframework.boot.SpringApplication.run(SpringApplication.java:320)

at org.springframework.boot.SpringApplication.run(SpringApplication.java:1309)

at org.springframework.boot.SpringApplication.run(SpringApplication.java:1298)

at com.java.study.StudyApplication.main(StudyApplication.java:13)

具体值填充的调⽤链：

"main@1" prio=5 tid=0x1 nid=NA runnable

java.lang.Thread.State: RUNNABLE

at com.alibaba.druid.pool.DruidAbstractDataSource.setUsername(DruidAbstractDataSource.java:1078)

flect.NativeMethodAccessorImpl.invoke0(NativeMethodAccessorImpl.java:-1)

flect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

flect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at flect.Method.invoke(Method.java:498)

at org.t.properties.bind.JavaBeanBinder$BeanProperty.setValue(JavaBeanBinder.java:354)

at org.t.properties.bind.JavaBeanBinder.bind(JavaBeanBinder.java:98)

at org.t.properties.bind.JavaBeanBinder.bind(JavaBeanBinder.java:80)

at org.t.properties.bind.JavaBeanBinder.bind(JavaBeanBinder.java:56)

at org.t.properties.bind.Binder.lambda$bindDataObject$5(Binder.java:451)

at org.t.properties.bind.Binder$$Lambda$(Unknown Source:-1)

at org.t.properties.bind.Binder$Context.withIncreasedDepth(Binder.java:571)

at org.t.properties.bind.Binder$Context.withDataObject(Binder.java:557)

at org.t.properties.bind.Binder$Context.access$300(Binder.java:512)

at org.t.properties.bind.Binder.bindDataObject(Binder.java:449)

at org.t.properties.bind.Binder.bindObject(Binder.java:390)

at org.t.properties.bind.Binder.bind(Binder.java:319)

at org.t.properties.bind.Binder.bind(Binder.java:308)

at org.t.properties.bind.Binder.bind(Binder.java:238)

at org.t.properties.bind.Binder.bind(Binder.java:225)

at org.t.properties.ConfigurationPropertiesBinder.bind(ConfigurationPropertiesBinder.java:91)

at org.t.properties.ConfigurationPropertiesBindingPostProcessor.bind(ConfigurationPropertiesBindingPostProcessor.java:89)

at org.t.properties.ConfigurationPropertiesBindingPostProcessor.postProcessBeforeInitialization(ConfigurationPropertiesBindingPostProcessor.java:78)

at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.applyBeanPostProcessorsBeforeInitialization(AbstractAutowireCapableBeanFactory.java:429) at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1780)

at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:609)

at org.springframework.beans.factory.ateBean(AbstractAutowireCapableBeanFactory.java:531)

at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:335)

at org.springframework.beans.factory.support.AbstractBeanFactory$$Lambda$Object(Unknown Source:-1)

at org.springframework.beans.factory.Singleton(DefaultSingletonBeanRegistry.java:234)

- locked <0x16ed> (a urrent.ConcurrentHashMap)

at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:333)

at org.springframework.beans.factory.Bean(AbstractBeanFactory.java:208)

at org.springframework.solveCandidate(DependencyDescriptor.java:276)

at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1367)

at org.springframework.beans.factory.solveDependency(DefaultListableBeanFactory.java:1287)

at org.springframework.beans.factory.solveAutowiredArgument(ConstructorResolver.java:885)

at org.springframework.beans.factory.ateArgumentArray(ConstructorResolver.java:789)

at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:539)

at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1336)

at org.springframework.beans.factory.ateBeanInstance(AbstractAutowireCapableBeanFactory.java:1179)

at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:571)