说说 Spring 的事务同步管理器

作者 : 开心源码 本文共2386个字,预计阅读时间需要6分钟 发布时间: 2022-05-12 共109人阅读

Spring 将 JDBC 的 Connection、Hibernate 的 Session 等访问数据库的连接或者者会话对象统称为资源,这些资源在同一时刻是不能多线程共享的 。 为了让 DAO 或者 Service 类可以实现单例模式, Spring 的事务同步管理类 org.springframework.transaction.support.TransactionSynchronizationManager 利用 ThreadLocal 为不同的事务线程提供了独立的资源副本,并同时维护这些事务的配置属性和运行状态信息 。

Spring 框架为不同的持久化技术提供了一套从 TransactionSynchronizationManager 中获取对应线程绑定资源的工具类,这些工具类都提供了可以获取绑定当前线程资源的静态方法:

持久化技术线程绑定资源获取工具静态方法
Spring JDBC 或者 MyBatisorg.springframework.jdbc.datasource.DataSourceUtilspublic static Connection getConnection(DataSource dataSource)
HibernateX.0org.springframework.orm.hibernateC.SessionFactoryUtilspublic static Session getSession(SessionFactory sessionFactory, boolean allowCreate)
JPAorg.springframework.orm.jpa.EntityManagerFactoryUtilspublic static EntityManager getTransactionalEntityManager(EntityManagerFactory emf)
JDOorg.springframework.orm.jdo.PersistenceManagerFactoryUtilspublic 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");...}
事务线程成员变量说明
resourcesConnection 或者 Session 等资源
currentTransactionName事务名称
currentTransactionReadOnly事务只读状态
currentTransactionIsolationLevel事务隔离级别
actualTransactionActive事务激活状态

TransactionSynchronizationManager 将 Dao、Service 类中影响线程安全的所有 “ 状态 ” 都统一抽取到该类中,并用 ThreadLocal 进行封装,这样一来, Dao (基于模板类或者资源获取工具类创立的 Dao )和 Service (采用 Spring 事务管理机制)就变成线程安全的对象啦 O(∩_∩)O~

说明
1. 本站所有资源来源于用户上传和网络,如有侵权请邮件联系站长!
2. 分享目的仅供大家学习和交流,您必须在下载后24小时内删除!
3. 不得使用于非法商业用途,不得违反国家法律。否则后果自负!
4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!
5. 如有链接无法下载、失效或广告,请联系管理员处理!
6. 本站资源售价只是摆设,本站源码仅提供给会员学习使用!
7. 如遇到加密压缩包,请使用360解压,如遇到无法解压的请联系管理员
开心源码网 » 说说 Spring 的事务同步管理器

发表回复