买空间送网站模板,前端机构培训,wordpress环保公司主题,宣传片设计制作公司✅作者简介#xff1a;大家好#xff0c;我是Leo#xff0c;热爱Java后端开发者#xff0c;一个想要与大家共同进步的男人#x1f609;#x1f609; #x1f34e;个人主页#xff1a;Leo的博客 #x1f49e;当前专栏#xff1a; Spring专栏 ✨特色专栏#xff1a; M…
✅作者简介大家好我是Leo热爱Java后端开发者一个想要与大家共同进步的男人 个人主页Leo的博客 当前专栏 Spring专栏 ✨特色专栏 MySQL学习 本文内容Spring5学习笔记—Spring事务处理 ️个人小站 个人博客欢迎大家访问 个人知识库 知识库欢迎大家访问
1. 什么是事务
事务是逻辑上的一组操作要么都执行要么都不执行。
相信大家应该都能背上面这句话了下面我结合我们日常的真实开发来谈一谈。
我们系统的每个业务方法可能包括了多个原子性的数据库操作比如下面的 save() 方法中就有两个原子性的数据库操作。这些原子性的数据库操作是有依赖的它们要么都执行要不就都不执行。 public void save() {personDao.save(student);personDetailDao.save(studentDetail);}另外需要格外注意的是事务能否生效数据库引擎是否支持事务是关键。比如常用的 MySQL 数据库默认使用支持事务的 innodb引擎。但是如果把数据库引擎变为 myisam那么程序也就不再支持事务了
事务是保证业务操作完整性的一种数据库机制。事务的4特点 A C I D
1. A(Atomicity) 原子性
2. C(Consistency) 一致性
3. I(Isolation) 隔离性
4. D(durability) 持久性原子性Atomicity事务是最小的执行单位不允许分割。事务的原子性确保动作要么全部完成要么完全不起作用一致性Consistency执行事务前后数据保持一致例如转账业务中无论事务是否成功转账者和收款人的总额应该是不变的隔离性Isolation并发访问数据库时一个用户的事务不被其他事务所干扰各并发事务之间数据库是独立的持久性Durability一个事务被提交之后。它对数据库中数据的改变是持久的即使数据库发生故障也不应该对其有任何影响。
只有保证了事务的持久性、原子性、隔离性之后一致性才能得到保障。也就是说 A、I、D 是手段C 是目的 2. Spring对事务的支持
Spring支持的两种事务管理
3.1 编程式事务管理
通过 TransactionTemplate或者TransactionManager手动管理事务实际应用中很少使用。
使用TransactionTemplate 进行编程式事务管理的示例代码如下
Autowired
private TransactionTemplate transactionTemplate;
public void testTransaction() {transactionTemplate.execute(new TransactionCallbackWithoutResult() {Overrideprotected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {try {// .... 业务代码} catch (Exception e){//回滚transactionStatus.setRollbackOnly();}}});
}使用 TransactionManager 进行编程式事务管理的示例代码如下
Autowired
private PlatformTransactionManager transactionManager;public void testTransaction() {TransactionStatus status transactionManager.getTransaction(new DefaultTransactionDefinition());try {// .... 业务代码transactionManager.commit(status);} catch (Exception e) {transactionManager.rollback(status);}
}3.2 声明式事务管理
这一种方式实际上比较推荐的实际是通过 AOP 实现基于Transactional 的全注解方式使用最多。
使用 Transactional注解进行事务管理的示例代码如下
public class Test {Transactional(propagation Propagation.REQUIRED)public void method() {/** 做业务**/MethodOne mb new MethodOne();MethodOne mc new MethodOne();mb.bMethod();mc.cMethod();}
}Spring主要通过以下三个接口对事务进行管理
PlatformTransactionManager平台事务管理器Spring 事务策略的核心。TransactionDefinition事务定义信息(事务隔离级别、传播行为、超时、只读、回滚规则)。TransactionStatus事务运行状态。
我们可以把 PlatformTransactionManager 接口可以被看作是事务上层的管理者而 TransactionDefinition 和 TransactionStatus 这两个接口可以看作是事务的描述。
PlatformTransactionManager 会根据 TransactionDefinition 的定义比如事务超时时间、隔离级别、传播行为等来进行事务管理 而 TransactionStatus 接口则提供了一些方法来获取事务相应的状态比如是否新事务、是否可以回滚等等。
1. PlatformTransactionManager
简称事务管理接口 PlatformTransactionManager接口中定义了三个方法
package org.springframework.transaction;import org.springframework.lang.Nullable;public interface PlatformTransactionManager {//获得事务TransactionStatus getTransaction(Nullable TransactionDefinition var1) throws TransactionException;//提交事务void commit(TransactionStatus var1) throws TransactionException;//回滚事务void rollback(TransactionStatus var1) throws TransactionException;
}2. TransactionDefinition
简称事务属性
事务管理器接口 PlatformTransactionManager 通过 getTransaction(TransactionDefinition definition) 方法来得到一个事务这个方法里面的参数是 TransactionDefinition 类 这个类就定义了一些基本的事务属性。
什么是事务属性呢 事务属性可以理解成事务的一些基本配置描述了事务策略如何应用到方法上。
事务属性包含了 5 个方面
隔离级别传播行为回滚规则是否只读事务超时
TransactionDefinition 接口中定义了 5 个方法以及一些表示事务属性的常量比如隔离级别、传播行为等等。
package org.springframework.transaction;import org.springframework.lang.Nullable;public interface TransactionDefinition {int PROPAGATION_REQUIRED 0;int PROPAGATION_SUPPORTS 1;int PROPAGATION_MANDATORY 2;int PROPAGATION_REQUIRES_NEW 3;int PROPAGATION_NOT_SUPPORTED 4;int PROPAGATION_NEVER 5;int PROPAGATION_NESTED 6;int ISOLATION_DEFAULT -1;int ISOLATION_READ_UNCOMMITTED 1;int ISOLATION_READ_COMMITTED 2;int ISOLATION_REPEATABLE_READ 4;int ISOLATION_SERIALIZABLE 8;int TIMEOUT_DEFAULT -1;// 返回事务的传播行为默认值为 REQUIRED。int getPropagationBehavior();//返回事务的隔离级别默认值是 DEFAULTint getIsolationLevel();// 返回事务的超时时间默认值为-1。如果超过该时间限制但事务还没有完成则自动回滚事务。int getTimeout();// 返回是否为只读事务默认值为 falseboolean isReadOnly();NullableString getName();
}3. TransactionStatus
简称事务状态
TransactionStatus接口用来记录事务的状态 该接口定义了一组方法,用来获取或判断事务的相应状态信息。
PlatformTransactionManager.getTransaction(…)方法返回一个 TransactionStatus 对象。
TransactionStatus 接口内容如下
public interface TransactionStatus{boolean isNewTransaction(); // 是否是新的事务boolean hasSavepoint(); // 是否有恢复点void setRollbackOnly(); // 设置为只回滚boolean isRollbackOnly(); // 是否为只回滚boolean isCompleted; // 是否已完成
}Spring对事务的支持 ⚠️ 再提醒一次你的程序是否支持事务首先取决于数据库 比如使用 MySQL 的话如果你选择的是 innodb 引擎那么恭喜你是可以支持事务的。但是如果你的 MySQL 数据库使用的是 myisam 引擎的话那不好意思从根上就是不支持事务的。 MySQL 怎么保证原子性的
我们知道如果想要保证事务的原子性就需要在异常发生时对已经执行的操作进行回滚在 MySQL 中恢复机制是通过 回滚日志undo log 实现的所有事务进行的修改都会先记录到这个回滚日志中然后再执行相关的操作。如果执行过程中遇到异常的话我们直接利用 回滚日志 中的信息将数据回滚到修改之前的样子即可并且回滚日志会先于数据持久化到磁盘上。这样就保证了即使遇到数据库突然宕机等情况当用户再次启动数据库的时候数据库还能够通过查询回滚日志来回滚之前未完成的事务。
Spring对事务控制 JDBC: Connection.setAutoCommit(false); Connection.commit(); Connection.rollback(); Mybatis Mybatis自动开启事务 sqlSession(Connection).commit(); sqlSession(Connection).rollback(); 结论控制事务的底层 都是Connection对象完成的。 3. Spring控制事务的开发步骤
Spring是通过AOP的方式进行事务的开发、
3.1 目标对象
public class XXXUserServiceImpl{private xxxDAO xxxDAOset get1. 原始对象 ---》 原始方法 ---》核心功能 (业务处理DAO调用)2. DAO作为Service的成员变量依赖注入的方式进行赋值
}3.2 额外功能
1. org.springframework.jdbc.datasource.DataSourceTransactionManager
2. 注入DataSource
1. MethodInterceptorpublic Object invoke(MethodInvocation invocation){//原理try{Connection.setAutoCommit(false);Object ret invocation.proceed();Connection.commit();}catch(Exception e){Connection.rollback();}return ret;}
2. AspectAround 3.3 切入点 Transactional 事务的额外功能加入给哪些业务方法。 类上类中所有的方法都会加入事务方法上这个方法会加入事务 3.4 组装切面
1. 切入点
2. 额外功能tx:annotation-driven transaction-manager/4. Spring控制事务的真实编码 搭建开发环境 dependencygroupIdorg.springframework/groupIdartifactIdspring-tx/artifactIdversion5.1.14.RELEASE/version
/dependency编码 !-- 原始对象 --
bean iduserService classcom.baizhiedu.service.UserServiceImplproperty nameuserDAO refuserDAO/
/bean!--DataSourceTransactionManager--
bean iddataSourceTransactionManager classorg.springframework.jdbc.datasource.DataSourceTransactionManager!-- 需要Connection 而Connection又在dataSource里 --property namedataSource refdataSource/
/beanTransactional
public class UserServiceImpl implements UserService {private UserDAO userDAO;
!-- 告诉Spring开启基于注解的事务管理 --
tx:annotation-driven transaction-managerdataSourceTransactionManager/细节 tx:annotation-driven transaction-managerdataSourceTransactionManager proxy-target-classtrue/
进行动态代理底层实现的切换 proxy-target-class默认 false JDKtrue Cglib 5. Spring的事务属性
事务属性简称 Transaction Attribute
5.1 什么是事务属性 属性描述物体特征的一系列值 性别 身高 体重 … 事务属性描述事务特征的一系列值 隔离属性传播属性只读属性超时属性异常属性 5.2 如何添加事务属性
Transactional(isloation,propagation,readOnly,timeout,rollbackFor,noRollbackFor,)5.3 事务属性详解
1. 隔离属性 (ISOLATION) 隔离属性的概念 概念他描述了事务解决并发问题的特征
1. 什么是并发多个事务(用户)在同一时间访问操作了相同的数据同一时间0.000几秒 微小前 微小后
2. 并发会产生那些问题1. 脏读2. 不可重复读3. 幻影读
3. 并发问题如何解决通过隔离属性解决隔离属性中设置不同的值解决并发处理过程中的问题。事务并发会产生的问题 脏读 一个事务读取了另一个事务中没有提交的数据。会在本事务中产生数据不一致的问题 解决方案 Transactional(isolationIsolation.READ_COMMITTED) 不可重复读 一个事务中多次读取相同的数据但是读取结果不一样。会在本事务中产生数据不一致的问题 注意1 不是脏读 2 一个事务中 解决方案 Transactional(isolationIsolation.REPEATABLE_READ) 本质 一把行锁 幻影读 一个事务中多次对整表进行查询统计但是结果不一样会在本事务中产生数据不一致的问题 解决方案 Transactional(isolationIsolation.SERIALIZABLE) 本质表锁 总结 并发安全 SERIALIZABLE REPEATABLE_READ READ_COMMITTED 运行效率 READ_COMMITTED REPEATABLE_READ SERIALIZABLE 数据库对于隔离属性的支持 隔离属性值MySQLOracleISOLATION_READ_COMMITTED✅✅IOSLATION_REPEATABLE_READ✅❎ISOLATION_SERIALIZABLE✅✅ Oracle不支持REPEATABLE_READ值 如何解决不可重复读? 采用的是多版本比对的方式 解决不可重复读的问题 默认隔离属性 ISOLATION_DEFAULT会调用不同数据库所设置的默认隔离属性 MySQL : REPEATABLE_READ Oracle: READ_COMMITTED 查看数据库默认隔离属性 MySQL select tx_isolation;Oracle SELECT s.sid, s.serial#,CASE BITAND(t.flag, POWER(2, 28))WHEN 0 THEN READ COMMITTEDELSE SERIALIZABLEEND AS isolation_levelFROM v$transaction t JOIN v$session s ON t.addr s.taddrAND s.sid sys_context(USERENV, SID);隔离属性在实战中的建议 推荐使用Spring指定的ISOLATION_DEFAULT MySQL repeatable_readOracle read_commited 未来实战中并发访问情况很少 如果真遇到并发问题乐观锁 Hibernate(JPA) Version MyBatis 通过拦截器自定义开发
2. 传播属性PROPAGATION 传播属性的概念 概念他描述了事务解决嵌套问题的特征 什么叫做事务的嵌套他指的是一个大的事务中包含了若干个小的事务 问题大事务中融入了很多小的事务他们彼此影响最终就会导致外部大的事务丧失了事务的原子性 传播属性的值极其用法 传播属性的值外部不存在事务外部存在事务用法备注REQUIRED开启新的事务融合到外部事务中Transactional(propagation Propagation.REQUIRED)增删改方法SUPPORTS不开启事务融合到外部事务中Transactional(propagation Propagation.SUPPORTS)查询方法REQUIRES_NEW开启新的事务挂起外部事务创建新的事务Transactional(propagation Propagation.REQUIRES_NEW)日志记录方法中NOT_SUPPORTED不开启事务挂起外部事务Transactional(propagation Propagation.NOT_SUPPORTED)及其不常用NEVER不开启事务抛出异常Transactional(propagation Propagation.NEVER)及其不常用MANDATORY抛出异常融合到外部事务中Transactional(propagation Propagation.MANDATORY)及其不常用 默认传播属性 Propagation.REQUIRED 推荐传播属性的使用方式 增删改 方法直接使用默认值REQUIRED 查询 操作显示指定传播属性的值为SUPPORTS
3. 只读属性(readOnly)
针对于只进行查询操作的业务方法可以加入只读属性提供运行效率
默认值false
4. 超时属性(timeout) 指定了事务等待的最长时间 为什么事务进行等待 当前事务访问数据时有可能访问的数据被别的事务进行加锁的处理那么此时本事务就必须进行等待。等待时间 秒如何应用 Transactional(timeout2)超时属性的默认值 -1 最终由对应的数据库来指定 5. 异常属性 Spring事务处理过程中 默认 对于RuntimeException及其子类 采用的是回滚的策略 默认 对于Exception及其子类 采用的是提交的策略 rollbackFor {java.lang.Exception,xxx,xxx} noRollbackFor {java.lang.RuntimeException,xxx,xx} Transactional(rollbackFor {java.lang.Exception.class},noRollbackFor {java.lang.RuntimeException.class}) 建议实战中使用RuntimeExceptin及其子类 使用事务异常属性的默认值 5.4 事务属性常见配置总结 隔离属性 默认值传播属性 Required(默认值) 增删改 Supports 查询操作只读属性 readOnly false 增删改 true 查询操作超时属性 默认值 -1异常属性 默认值 增删改操作 Transactional 查询操作 Transactional(propagationPropagation.SUPPORTS,readOnlytrue) 5.5 基于标签的事务配置方式(事务开发的第二种形式) 基于注解 Transaction的事务配置回顾 bean iduserService classcom.baizhiedu.service.UserServiceImplproperty nameuserDAO refuserDAO/
/bean!--DataSourceTransactionManager--
bean iddataSourceTransactionManager classorg.springframework.jdbc.datasource.DataSourceTransactionManagerproperty namedataSource refdataSource/
/beanTransactional(isolation,propagation,...)
public class UserServiceImpl implements UserService {private UserDAO userDAO;tx:annotation-driven transaction-managerdataSourceTransactionManager/基于标签的事务配置 bean iduserService classcom.baizhiedu.service.UserServiceImplproperty nameuserDAO refuserDAO/
/bean!--DataSourceTransactionManager--
bean iddataSourceTransactionManager classorg.springframework.jdbc.datasource.DataSourceTransactionManagerproperty namedataSource refdataSource/
/bean!-- 事务属性 --
tx:advice idtxAdvice transacation-managerdataSourceTransactionManagertx:attributestx:method nameregister isoloation,propagation/tx:methodtx:method namelogin ...../tx:method等效于 Transactional(isolation,propagation,)public void register(){}/tx:attributes
/tx:adviceaop:configaop:pointcut idpc expressionexecution(* com.baizhiedu.service.UserServiceImpl.register(..))/aop:pointcutaop:advisor advice-reftxAdvice pointcut-refpc/aop:advisor
/aop:config基于标签的事务配置在实战中的应用方式 bean iduserService classcom.baizhiedu.service.UserServiceImplproperty nameuserDAO refuserDAO/
/bean!--DataSourceTransactionManager--
bean iddataSourceTransactionManager classorg.springframework.jdbc.datasource.DataSourceTransactionManagerproperty namedataSource refdataSource/
/bean编程时候 service中负责进行增删改操作的方法 都以modify开头查询操作 命名无所谓
tx:advice idtxAdvice transacation-managerdataSourceTransactionManagertx:attributestx:method nameregister/tx:methodtx:method namemodify*/tx:methodtx:method name* propagationSUPPORTS read-onlytrue/tx:method/tx:attributes
/tx:advice应用的过程中service放置到service包中
aop:configaop:pointcut idpc expressionexecution(* com.baizhiedu.service..*.*(..))/aop:pointcutaop:advisor advice-reftxAdvice pointcut-refpc/aop:advisor
/aop:config查询操作 命名无所谓
tx:advice idtxAdvice transacation-managerdataSourceTransactionManagertx:attributestx:method nameregister/tx:methodtx:method namemodify*/tx:methodtx:method name* propagationSUPPORTS read-onlytrue/tx:method/tx:attributes
/tx:advice应用的过程中service放置到service包中
aop:configaop:pointcut idpc expressionexecution(* com.baizhiedu.service..*.*(..))/aop:pointcutaop:advisor advice-reftxAdvice pointcut-refpc/aop:advisor
/aop:config
