`
java虫
  • 浏览: 535726 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

(转)TransactionSynchronizationManager理解

阅读更多
发现
 protected void setUp() throws Exception
    {
      super.setUp();
      context = new FileSystemXmlApplicationContext(springConfigFile);
     if (bHoldSession)
    {
  sessionFactory = (SessionFactory) context.getBean("sessionFactory");
  Session session = SessionFactoryUtils.getSession(sessionFactory, true);
  TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(session));
    }
 }
对 TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(session));的理解如下:
在调用一个需要事务的组件的时候,管理器首先判断当前调用(即当前线程)有没有一个事务,如果没有事务则启动一个事务,并把事务与当前线程绑定。Spring使用TransactionSynchronizationManager的bindResource方法将当前线程与一个事务绑定,采用的方式就是ThreadLocal,这可以从TransactionSynchronizationManager类的代码看出。
public abstract class TransactionSynchronizationManager
{
 ……
 private static final ThreadLocal currentTransactionName = new ThreadLocal();
 private static final ThreadLocal currentTransactionReadOnly = new ThreadLocal();
 private static final ThreadLocal actualTransactionActive = new ThreadLocal(); ……
}
再看看方法SessionHolder的理解

先看一段代码:
    Connection conn = Conn.getConnection();
    conn.setAutoCommit(false);
    ……..
    ……...
    conn.rollback();
    conn.commit();

    数据库的事务是针对 Connection 的。

    接着再看一段代码:( spring 中事务的一段学习代码,这段代码是把 spring 和 hibernate 结合在一起的,增加了理解上的难度,因为我的出发点一开始不要 hibernate ,就光用 jdbc 来进行数据库事务,但是没有其他好的代码,就这样吧)

    public Long addLineItem(Long orderId, LineItem lineItem){

       log("OrderListDAOHibernate.addLineItem : Start...");

       OrderList orderList = (OrderList) getHibernateTemplate().load(OrderList.class, orderId);

       lineItem.setOrderList(orderList);

       getHibernateTemplate().saveOrUpdate(lineItem);

       getHibernateTemplate().saveOrUpdate(orderList);

       log("OrderListDAOHibernate.addLineItem : Ending...");

       return lineItem.getId();

    }

    在这个代码的配置文件中,把 addLineItem 做为一个切入点,进行事务,也就是说,在 addLineItem 的外面,再包上一层事务的外壳。

    但是这个时候,问题出来了,事务是针对 Connection 的,而上面的两个连续的 HibernateTemplate 执行的 saveOrUpdate 中的 Connection 必须是一致才能用事务, spring 怎么做到这一点的呢?(这个问题也就是在找 spring 的事务例子前,我想的 spring 中用 jdbc 来进行事务,怎么样让 Connection 保持一致呢?但是没有 jdbc 的例子,只有整合 hibernate 或者 ibatis 的例子,但是,我想,原理是一样的吧。)

    解决问题的思路: HibernateTemplate 中的 Connection 必定一致。那么就从 HibernateTemplate 入手。

    看 spring 的源代码,既然是 Hibernate ,那么,就没有 Connection 给你看,只有 Session ,由 Session 来管理 Connection ,那么用事务来控制的话,这个 Session 必定在所有该事务中是一致的。于是在 HibernateTemplate 中找到:
protected Session getSession() {

       if (isAlwaysUseNewSession()) {

return SessionFactoryUtils.getNewSession(getSessionFactory(), getEntityInterceptor());

       }

       else if (!isAllowCreate()) {

return SessionFactoryUtils.getSession(getSessionFactory(), false);

       }

       else {

return SessionFactoryUtils.getSession(

                  getSessionFactory(), getEntityInterceptor(), getJdbcExceptionTranslator());

       }

    }

 

看来在 SessionFactoryUtils 里面,接着在 SessionFactoryUtils.getSession 中找:

这个方法太长了,太复杂了,从简,发现了非常关键的一点:

SessionHolder sessionHolder = (SessionHolder) TransactionSynchronizationManager.getResource(sessionFactory);

假如 sessionHolder 不等于空,说明,在事务中有这样一个还没有 commit 的 session ,那么就返回这个 session ,假如等于空,新建一个 session ,并且在事务里加入这个 session 。这段代码的意思大概是这样,太繁杂了,只能猜,也肯定是如此。

 

再看 getHibernateTemplate() 方法来自继承 HibernateDaoSupport ,看了电子书《 spring-reference 》的第九章“ Dao 支持”, Dao 的支持类可以有好多,如: JdbcDaoSupport , HibernateDaoSupport , JdoDaoSupport 等等。

 

既然前面一开始就是从 jdbc 的 spring 事务控制引起的,那么看到了同样的 HibernateDaoSupport---JdbcDaoSupport ,那么 JdbcDaoSupport 也应该有 getJdbcTemplate() 这个方法,并且返回 JdbcTemplate 这个类。
果然如此。
于是剖析 JdbcTemplate 是不是和 HibernateTemplate 一样。果然一样。
注意到:

Connection con = DataSourceUtils.getConnection(getDataSource());

Connection 是从 DataSourceUtils.getConnection() 来的,继续跟踪 DataSourceUtils.getConnection() 。

找到:

ConnectionHolder conHolder = (ConnectionHolder) TransactionSynchronizationManager.getResource(dataSource);  

和 Hibernate 中的一模一样,因为没有了 session 的封装,条理在 jdbc 中更加清晰了。

分享到:
评论
3 楼 swanky_yao 2013-02-26  
拜读了 受益匪浅
2 楼 javaeyename 2008-04-11  
如果是用框架,不是自己bindResource的话?上面写掉了。呵呵
1 楼 javaeyename 2008-04-11  
TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(session));是在什么位置,什么时候做bindResource的?

相关推荐

    SpringBoot多数据源配置(方式二:在代码中动态切换需要使用哪个数据源).docx

    ### Spring Boot多数据源配置详解 #### 一、多数据源背景及应用场景 在实际的Spring Boot项目开发过程中,通常我们会为项目配置一个...希望本文能帮助开发者们更好地理解和掌握Spring Boot多数据源配置的相关知识。

    Atomikos jta事务框架改写历程

    ConnectionHolder conHolder = (ConnectionHolder) TransactionSynchronizationManager.getResource(dataSource); if ((!switchDb || !(dataSource instanceof AbstractRoutingDataSource)) && (conHolder != null...

    spring-transaction-synchronization:Spring事务同步示例

    Spring提供了TransactionSynchronization接口和TransactionSynchronizationManager类来支持事务的同步处理。 - **TransactionSynchronization接口**:定义了事务开始、提交、回滚、完成时需要执行的方法,如...

    springTranction

    11. **事务同步**:Spring的TransactionSynchronization接口和TransactionSynchronizationManager类允许开发者在事务的生命周期中插入自定义的行为,如清理资源或执行后置处理。 12. **Spring Boot中的事务管理**:...

    edb:春天的 jfinal

    DataSource 数据源对象和 jfinal 的配置类 com.jfinal.plugin.activerecord.Config和 spring事务相关的 DataSourceUtils.getConnection、ConnectionHolder、TransactionSynchronizationManager.getResource 类和方法...

    对应的文章 Springboot Mybatis 多数据源利用注解动态切换数据库

    首先,我们需要理解什么是多数据源。在Java应用中,数据源(DataSource)是用于存储数据库连接信息的对象,多数据源意味着系统中存在两个或更多的数据源,每个数据源对应一个独立的数据库。在Spring Boot中,我们...

    读写分离设计文档1

    判断当前方法是否处于Spring事务的关键在于`TransactionSynchronizationManager.isSynchronizationActive()`,这个方法返回true表示当前存在Spring事务,可以根据事务的readOnly属性决定数据源。 iBatis的`...

    javaweb 通过threadlocal 手动提交事务

    Spring框架也支持使用ThreadLocal进行事务管理,比如使用`TransactionSynchronizationManager`类,它可以管理和协调事务同步,提供更高级别的事务控制。 通过上述方式,开发者可以利用ThreadLocal在Java Web环境中...

    ThreadLocal原理及在多层架构中的应用.pdf

    例如,Spring框架中的TransactionSynchronizationManager、RequestContextHolder、AopContext、LocaleContextHolder等都是利用ThreadLocal来保证线程安全。 在多层架构的应用中,例如从请求接入到响应返回,整个...

    Spring高级之注解驱动开发视频教程

    视频详细讲解,需要的小伙伴自行百度网盘下载,链接见附件,永久有效。 1、课程简介 Spring框架是一系列应用框架的核心,也可以说是整合其他应用框架的基座。...n 源码分析-TransactionSynchronizationManager

    Struts2+Spring+hibernate中对action的单元测试环境搭建[总结].pdf

    TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(hibernateSession)); ``` 然后,在类中加入以下两个私有函数: ```java private SessionFactory lookupSessionFactory...

    Java 单例模式线程安全问题

    例如,RequestContextHolder、TransactionSynchronizationManager、LocaleContextHolder 等 Bean 都使用 ThreadLocal 来处理非线程安全的状态。 线程安全问题通常是由全局变量及静态变量引起的。若每个线程中对全局...

    SPRING API 2.0.CHM

    All Classes AbstractAdvisorAutoProxyCreator AbstractApplicationContext AbstractApplicationEventMulticaster AbstractAspectJAdvice AbstractAspectJAdvisorFactory AbstractAspectJAdvisorFactory....

    Spring(AbstractRoutingDataSource)实现动态数据源切换示例

    TransactionStatus status = TransactionSynchronizationManager.getCurrentTransactionStatus(); if (status != null) { return status.getTransaction().toString(); // 假设事务ID可以区分数据源 } return ...

Global site tag (gtag.js) - Google Analytics