Spring事务源码解读.doc

Spring 事务源码解读

 一、Spring 事务使用

 1.通过 maven 方式引入 jar 包

 

 

  com.alibaba

  druid

  1.2.8

 

  org.springframework

  spring-tx

  5.2.20.RELEASE

 

 

  org.springframework

  spring-jdbc

  5.2.20.RELEASE

 

 

 import org.springframework.context.annotation.ComponentScan;

 import org.springframework.context.annotation.Configuration;

 import org.springframework.jdbc.core.JdbcTemplate;

 import org.springframework.jdbc.datasource.DataSourceTransactionManager;

 import org.springframework.transaction.PlatformTransactionManager;

 import org.springframework.transaction.annotation.EnableTransactionManagement;

 

 import javax.sql.DataSource;

 

 @Configuration

  DruidDataSource data = new DruidDataSource();

  data.setDriverClassName(“com.mysql.cj.jdbc.Driver”);

 

data.setUrl(“jdbc:mysql://localhost:3306/xxx?useUnicode=true&characterEncoding=UTF-8&serv

erTimezone=GMT%2B8”);

  data.setUsername(“xxx”);

  data.setPassword(“xxx”);

  return data;

  }

 

  public PlatformTransactionManager transactionManager(DataSource dataSource) {

  return new DataSourceTransactionManager(dataSource);

  }

 }

 

 

 3.使用@Transactional 注解，代码如下：

 

 package com.ybe.transaction.service;

 

 @Service

 public class BookService {

  @Autowired

  BookDao bookDao;

 

  public BookDao getBookDao() {

  return bookDao;

  }

 

  /**

  * 结账：传入哪个用户买了哪本书

  * @param id

  */

  @Transactional(propagation = Propagation.REQUIRED)

  public void checkout(int id){

  bookDao.updateStock(id);

  }

 

 import org.springframework.jdbc.core.JdbcTemplate;

 import org.springframework.stereotype.Repository;

 import org.springframework.transaction.annotation.Propagation;

 import org.springframework.transaction.annotation.Transactional;

 

 @Repository

 public class BookDao {

  @Autowired

  JdbcTemplate jdbcTemplate;

 

  }

 

  /**

  * @param id

  */

  @Transactional(propagation = Propagation.REQUIRES_NEW)

  public void updateStock(int id){

  }

 }

 

 

 

  AnnotationConfigApplicationContext configApplicationContext = new

AnnotationConfigApplicationContext(TransactionConfig.class);

  BookService bean = configApplicationContext.getBean(BookService.class);

  bean.checkout(1);

TransactionManagementConfigurationSelector 类 。 该 类 中 实 现 了 ImportSelector 接 口 的

selectImports 方 法 。 在 创 建 AnnoteationConfigApplicationContext 的 构 造 函 数 中 会 调 用

refresh() 方 法 。 在 invokeBeanFactoryPostProcessors() 中 会 调 用

TransactionManagementConfigurationSelector 类 的 selectImports 方 法 ， 会 生 成

AutoProxyRegistrar 的 对 象 和 ProxyTransactionManagementConfiguration 对 象 。

AutoProxyRegistrar 会 调 用 该 类 的 registerBeanDefinitions 方 法 注 册 类 型 为

InfrastructureAdvisorAutoProxyCreator 的 RootBeanDefinition 。

ProxyTransactionManagementConfiguration 中 注 入 了

BeanFactoryTransactionAttributeSourceAdvisor 类型的 Bean，即事务通知类，该类继承了

Advisor 。 在 finishBeanFactoryInitialization() 过 程 中 第 一 次 调 用

getAdvicesAndAdvisorsForBean 的 时 候 ， 会 先 进 行 Advisors 的 创 建 ， 再 获 取 候 选 的

务通知方法和 BeanPostProcessor 的实现类 BeanFactoryTransactionAttributeSourceAdvisor。

 

 整体代码流程图如下：