使用Spring事务 Spring事务介绍 Spring事务的特点: 1。多种事务API,Spring事务都可兼容; 2。程序接入简单; 3。与已有的Spring框架集成。 支持的事务API如下: Spring事务使用代码如下:TransactionalOverridepublicvoidtestTransactional(Integerid){demoDao。remove(id);} 此为Service实现类中的一个实现方法 Spring事务引入 那么Spring中使用事务,我们要做的是: 对要使用事务的类或者方法,添加注解Transactional。支持事务元数据设置,比如传播特性,回滚设置等,通过AOP将设置生效。 增加配置:EnableTransactionManagement,来开启Spring中注解驱动的事务管理能力。SpringBoot中默认开启,不需要加该注解。 一般是在Service层添加事务,然后其他层或者其他Service类来调用该事务类。 TransactionAPI:JDBC 一直使用的JDBCDriver来连接数据库。 开启Spring事务之前,先看事务作用于什么?是对于数据库层来说。 那么程序与数据库层发起一次事务如何来实现呢?首先来看Java程序与数据库的交互,是通过JDBC(Javadatabaseconnectivity)来展开。JDBC是API形式,定义了客户端如何访问数据库。 JDBCAPI的实现则有JDBCDriverManager。在pom文件中,有引入过此Jar包。使用过程中,有一个连接池,来管理可用的JDBCconnection。那么程序就可通过JDBCDriver来发起事务,其中事务与一个JDBCconnection相关联。 事务的过程实现代码类似于:importjava。sql。Connection;ConnectionconnectiondataSource。getConnection();(1)try(connection){connection。setAutoCommit(false);(2)executesomeSQLstatements。。。connection。commit();(3)}catch(SQLExceptione){connection。rollback();(4)} 可以看到事务的过程为,获取数据库连接,取消自动提交,执行SQL逻辑,然后控制正常提交,异常回滚。 Spring事务默认设置 默认的事务能力是:传播机制是REQUIRED,即当前无事务时新建一个事务,当前存在事务,则加入该事务中。隔离级别是DEFAULT,即使用数据库默认的隔离级别,那么数据库层默认的隔离级别是REPEATABLEREAD(可重复读)。transactionisreadwrite。服务于传播机制,相对应的readonly来表明只做只读操作。默认超时时间,跟随底层事务服务提供方,如果不支持超时逻辑则没有。我们使用的默认超时时间是50s。回滚机制适用于RuntimeException。checkedException不会触发。Spring事务实现 Transactional实现逻辑 Spring事务是对多种TransactionAPI的封装,那么基于JDBC实现的封装后,通过增加Transactional注解来实现,简化了用户的使用流程。 分析事务过程中,每次变化的是执行SQL的逻辑部分。分析如下: Spring提供Proxy层来实现,开启事务和关闭事务,中间过程再调用业务逻辑,即,RealUserService的userDao。save()部分。为什么说是Real? 在Spring中我们要对某个类或者方法添加事务时,可以直接在其上添加注解Transactional。 Spring内部的实现,则是依赖IoC和AOP特性。 对含有Transactional注解的类或者方法,提供一层Proxy实现。通过AOP实现了关联。 对于含有Transactional的bean,IoC容器会对该bean初始化一个代理类,也就是上面的UserServiceProxy。该proxy内部对实际的service调用,实现其业务逻辑。使用时因为IoC特性,调用相应的proxy类而不是实际service,对内部的代理逻辑我们无感知。 那么从程序侧,实现了对事务的开启和关闭的封装,而事务与数据库连接相关联,此处Spring对数据库连接则封装在TransactionManager中,常用的功能类是PlatformTransactionManager。此处的调用逻辑如下图: ReactiveTransactionManager是响应式功能类 Spring事务手动控制 在一些场景下,不可用注解Transactional来控制事务,需要引入手动控制逻辑时,Spring提供了封装类TransactionTemplate。也是对PlatformTransactionManager的封装,简化使用流程,类似于RedisTemplate等等。ServicepublicclassUserService{AutowiredprivateTransactionTemplatetemplate;publicLongregisterUser(Useruser){Longidtemplate。execute(status{executesomeSQLthate。g。insertstheuserintothedbandreturnstheautogeneratedidreturnid;});}} 不必自己打开或者关闭数据库连接,并且Spring会将SQLExceptions转换为RuntimeException。Spring事务封装类 Spring事务实现类 类结构如图: AOP执行类:TransactionAspectSupport,内部是调用TransactionManager来实现事务逻辑。 Spring对事务的封装逻辑,通过类PlatformTransactionManager,将指定DataSource的JDBCConnection绑定到当前线程。 当使用DataSource。getConnection()时,并不是Spring封装支持的形式,可以定义TransactionAwareDataSourceProxy代理目标DataSource,在DAO层中使用该proxy类,可实现Spring的事务管理。 LazyConnectionDataSourceProxy该代理类也实现了Spring的事务管理,它的优势是当要执行语句时,才从目标数据源获取连接。 Spring事务的不同封装层级 通过Spring封装对数据库的访问,我们可以正确创建、重用和清理持久性API资源(比如JDBC,Hibernate或JPA等),完成DataSourceTransactionManager到JDBCDataSource或者HibernateTransactionManager到HibernateSessionFactory的事务链接到相关资源,实现Spring管理的事务。 Spring提供了不同封装层级的数据访问操作类,使用其会支持Spring事务。如下图: Spring事务不生效原因基于上面的逻辑,梳理出常见的事务不生效的原因有:默认设置下,开启事务的方法必须是public。类内部自调用,AOP代理不生效。初始化时不生效,比如在PostConstruct中。依赖IoC逻辑将proxy完全初始化以提供能力。抛出的异常是否是RuntimeException。SpringBoot项目中使用多数据源切换时,TransactionManager类中加载的是否是当前数据源。Spring项目中,使用低层级的数据源访问方式时,检查数据源封装是否是Spring事务支持的代理类。