Spring 将 JDBC 的 Connection、Hibernate 的 Session 等访问数据库的连接或者会话对象统称为资源,这些资源在同一时刻是不能多线程共享的 。 为了让 DAO 或 Service 类可以实现单例模式, Spring 的事务同步管理类 org.springframework.transaction.support.TransactionSynchronizationManager 利用 ThreadLocal 为不同的事务线程提供了独立的资源副本,并同时维护这些事务的配置属性和运行状态信息 。
Spring 框架为不同的持久化技术提供了一套从 TransactionSynchronizationManager 中获取对应线程绑定资源的工具类,这些工具类都提供了可以获取绑定当前线程资源的静态方法:
持久化技术 | 线程绑定资源获取工具 | 静态方法 |
---|---|---|
Spring JDBC 或 MyBatis | org.springframework.jdbc.datasource.DataSourceUtils | public static Connection getConnection(DataSource dataSource) |
HibernateX.0 | org.springframework.orm.hibernateC.SessionFactoryUtils | public static Session getSession(SessionFactory sessionFactory, boolean allowCreate) |
JPA | org.springframework.orm.jpa.EntityManagerFactoryUtils | public static EntityManager getTransactionalEntityManager(EntityManagerFactory emf) |
JDO | org.springframework.orm.jdo.PersistenceManagerFactoryUtils | public static PersistenceManager getPersistenceManager(PersistenceManagerFactory pmf, boolean allowCreate) |
某些场景下,可能无法使用 Spring 提供的模板类。这时,就必须通过操作底层持久化技术所提供的原生 API ,而这就需要通过这些工具类来获取线程绑定的资源。如果直接从 DataSource 或 SessionFactory 中获取资源,那么就无法让数据操作参与到与本线程相关的事务环境,因为这些对象不能获取和当前线程相关的资源。
TransactionSynchronizationManager 源码如下:
public abstract class TransactionSynchronizationManager {private static final Log logger = LogFactory.getLog(TransactionSynchronizationManager.class);private static final ThreadLocal<Map<Object, Object>> resources =new NamedThreadLocal<Map<Object, Object>>("Transactional resources");private static final ThreadLocal<Set<TransactionSynchronization>> synchronizations =new NamedThreadLocal<Set<TransactionSynchronization>>("Transaction synchronizations");private static final ThreadLocal<String> currentTransactionName =new NamedThreadLocal<String>("Current transaction name");private static final ThreadLocal<Boolean> currentTransactionReadOnly =new NamedThreadLocal<Boolean>("Current transaction read-only status");private static final ThreadLocal<Integer> currentTransactionIsolationLevel =new NamedThreadLocal<Integer>("Current transaction isolation level");private static final ThreadLocal<Boolean> actualTransactionActive =new NamedThreadLocal<Boolean>("Actual transaction active");...
}
复制代码
事务线程成员变量 | 说明 |
---|---|
resources | Connection 或 Session 等资源 |
currentTransactionName | 事务名称 |
currentTransactionReadOnly | 事务只读状态 |
currentTransactionIsolationLevel | 事务隔离级别 |
actualTransactionActive | 事务激活状态 |
TransactionSynchronizationManager 将 Dao、Service 类中影响线程安全的所有 “ 状态 ” 都统一抽取到该类中,并用 ThreadLocal 进行封装,这样一来, Dao (基于模板类或资源获取工具类创建的 Dao )和 Service (采用 Spring 事务管理机制)就变成线程安全的对象啦 O(∩_∩)O~