责任链功…

动态代理功能生成一个Proxy代理类Proxy代理类实现了业务接口而通过调用Proxy代理类实现的业务接口实际上会触发代理类的invoke增强处理方法。

责任链功能可以动态地组合处理者增加或删除处理者而不需要修改客户端代码可以灵活地处理请求每个处理者可以选择处理请求或将请求传递给下一个处理者。

org.mybatis.spring.boot.autoconfigure.MybatisAutoConfigurationorg.springframework.context.annotation.Configuration

ConditionalOnClass({

ConditionalOnSingleCandidate(DataSource.class)

EnableConfigurationProperties(MybatisProperties.class)

AutoConfigureAfter({

DataSourceAutoConfiguration.class,

MybatisLanguageDriverAutoConfiguration.class

public

MybatisAutoConfiguration(MybatisProperties

properties,

interceptorsProvider,ObjectProviderTypeHandler[]

languageDriversProvider,ResourceLoader

resourceLoader,

ObjectProviderDatabaseIdProvider

databaseIdProvider,ObjectProviderListConfigurationCustomizer

configurationCustomizersProvider)

{this.properties

interceptorsProvider.getIfAvailable();......}BeanConditionalOnMissingBeanpublic

SqlSessionFactory

SqlSessionFactoryBean();factory.setDataSource(dataSource);factory.setVfs(SpringBootVFS.class);if

(StringUtils.hasText(this.properties.getConfigLocation()))

{factory.setConfigLocation(this.resourceLoader.getResource(this.properties.getConfigLocation()));}applyConfiguration(factory);if

(this.properties.getConfigurationProperties()

null)

{factory.setConfigurationProperties(this.properties.getConfigurationProperties());}//

【2】if

(!ObjectUtils.isEmpty(this.interceptors))

{factory.setPlugins(this.interceptors);}......return

代码分析

【1】interceptorsProvider.getIfAvailable();获取Interceptor接口的所有的bean并加载到内存interceptors里

【2】构造SqlSessionFactoryBean会用到内存的interceptors填充拦截器bean到SqlSessionFactoryBean里面。

SqlSessionFactoryBean#afterPropertiesSet初始化完成后执行

因为SqlSessionFactoryBean实现了InitializingBean接口必然有一个afterPropertiesSet()的实现方法

public

ApplicationListenerApplicationEvent

{Overridepublic

required);notNull(sqlSessionFactoryBuilder,

Property

【3】这里会构造一个sqlSessionFactory并调用了buildSqlSessionFactory()

SqlSessionFactoryBean#buildSqlSessionFactory构造SqlSessionFactory

里面通过遍历SqlSessionFactoryBean的interceptors逐个把拦截器加载到SqlSessionFactory的interceptorChain里面。

protected

{Stream.of(this.plugins).forEach(plugin

{targetConfiguration.addInterceptor(plugin);LOGGER.debug(()

Registered

this.sqlSessionFactoryBuilder.build(targetConfiguration);

代码分析

【4】逐个把拦截器加载到targetConfiguration对象的interceptorChain里面也就是拦截器责任链了。

【5】最终通过sqlSessionFactoryBuilder建造者模式完成一个对象创建new

DefaultSqlSessionFactory(config)

public

DefaultSqlSessionFactory(Configuration

configuration)

到此完成Mybatis的插件bean的类加载和插件责任链的初始化。

上述的实现逻辑拆分到了只包含部分逻辑的、功能单一的Handler处理类里开发人员可以按照业务需求将多个Handler对象组合成一条责任链实现请求的处理。

那么Mybatis插件什么时候发挥作用呢

自然是每个sqlSession创建时在返回Executor对象前会对执行器进行一个pluginAll的插件处理。

我们发起一次请求最终会映射打开一个session会话http://localhost:8891/user_select?id2

DefaultSqlSessionFactory#openSessionFromDataSource

最终debug到org.apache.ibatis.session.defaults.DefaultSqlSessionFactory#openSessionFromDataSource

public

openSessionFromDataSource(ExecutorType

execType,

configuration.getEnvironment();final

TransactionFactory

getTransactionFactoryFromEnvironment(environment);//

【2】tx

transactionFactory.newTransaction(environment.getDataSource(),

level,

DefaultSqlSession(configuration,

executor,

ExceptionFactory.wrapException(Error

opening

{ErrorContext.instance().reset();}}

源码分析

【1】获取环境变量【2】创建新事务【3】创建一个新的Executor执行器非常关键【4】返回新构造的DefaultSqlSession

public

CachingExecutor(executor);}executor

(Executor)

interceptorChain.pluginAll(executor);return

executor;}

interceptorChain.pluginAll(executor)

public

interceptor.plugin(target);}return

target;}}

是一个静态方法本质是对插件进行动态代理最终返回的是一个动态代理了Plugin类的自动生产对象。

org.apache.ibatis.plugin.Plugin#wrap

org.apache.ibatis.plugin.Plugin#wrappublic

static

getSignatureMap(interceptor);Class?

type

Proxy.newProxyInstance(type.getClassLoader(),interfaces,new

Plugin(target,

targetExecutor执行器Interceptor拦截器signatureMap拦截签名new

了一个Plugin类构造对Plugin类的动态代理会自动生成一个代理类A#Plugin最终执行的还是Plugin类的invoke方法于是wrap最终返回的是一个动态代理了Plugin类的自动生产对象。

代理器是Plugin被代理类是targetExecutor或Handler

org.mybatis.spring.SqlSessionTemplate.SqlSessionInterceptor#invoke

最终执行的逻辑是调用sqlSession去接args参数这个反射执行的方法是

SqlSession.selectOne(java.lang.String,java.lang.Object)

DefaultSqlSession#selectList(java.lang.String,

java.lang.Object,

org.apache.ibatis.session.RowBounds)

Override

configuration.getMappedStatement(statement);return

executor.query(ms,

ExceptionFactory.wrapException(Error

querying

{ErrorContext.instance().reset();}

源码分析

executor.query是最终的Executor执行器query方法逻辑。

还记得上面一个步骤吗自动生成一个代理类A#Plugin它实现了对Executor的增强处理这块增强处理逻辑要回到Plugin#invoke方法

Override

signatureMap.get(method.getDeclaringClass());if

(methods

ExceptionUtil.unwrapThrowable(e);}

这里会根据signatureMap的调用点来判断是否执行interceptor的拦截逻辑。

而这里的拦截逻辑就是我们实现好的Interceptor拦截器类的intercept方法啦。

new好的Invocation实际就是调用点。

通过InterceptorChain拦截器链对Executor进行增强

从图中可以知道Mybatis的拦截器链运用了动态代理和责任链模式

其实就是代理对象再次生成代理对象特殊的是代理对象的target属性另外配合Invocation类中的proceed方法形成责任链路的调用这样就可以在我们执行sql的前后做一些特殊的自定义的事情了。