Comment on page
06 Spring Transactional 注解
事务管理是应用系统开发中必不可少的一部分。Spring 为事务管理提供了丰富的功能支持。
Spring 事务管理分为编码式和声明式的两种方式。编程式事务指的是通过编码方式实现事务；声明式事务基于 AOP，将具体业务逻辑与事务处理解耦。声明式事务管理使业务代码逻辑不受污染， 因此在实际使用中声明式事务用的比较多。声明式事务有两种方式，一种是在配置文件（xml）中做相关的事务规则声明，另一种是基于
@Transactional 注解的方式。使用
@Transactional 注解管理事务的实现步骤分为两步：@EnableTransactionManagement注解开启事务@Transactional注解添加到方法上
@Transactional 注解的属性信息：属性名 | 说明 |
|---|---|
name | 当在配置文件中有多个 TransactionManager，可以用该属性指定选择哪个事务管理器。 |
propagation | 事务的传播行为，默认值为 REQUIRED。 |
isolation | 事务的隔离度，默认值采用 DEFAULT。 |
timeout | 事务的超时时间，默认值为 -1。如果超过该时间限制但事务还没有完成，则自动回滚事务。 |
read-only | 指定事务是否为只读事务，默认值为 false；为了忽略那些不需要事务的方法，可以设置 read-only 为 true。 |
rollback-for | 用于指定能够触发事务回滚的异常类型，如果有多个异常类型需要指定，各类型之间可以通过逗号分隔。 |
no-rollback-for | 抛出 no-rollback-for 指定的异常类型，不回滚事务。 |
@Transactional 注解也可以添加到类级别上。当把 @Transactional 注解放在类级别时，表示所有该类的公共方法都配置相同的事务属性信息。当类和方法上同时配置了事务属性，则优先以方法级别的事务属性信息来管理事务。在应用系统调用声明
@Transactional 的目标方法时，Spring Framework 默认使用 AOP 代理，在代码运行时生成一个代理对象，根据 @Transactional 的属性配置信息，这个代理对象决定该声明 @Transactional 的目标方法是否由拦截器 TransactionInterceptor 来使用拦截，在 TransactionInterceptor 拦截时，会在在目标方法开始执行之前创建并加入事务，并执行目标方法的逻辑， 最后根据执行情况是否出现异常，利用抽象事务管理器 AbstractPlatformTransactionManager 操作数据源 DataSource 提交或回滚事务。
事务实现机制
需要注意下面三种 propagation 可以不启动事务。本来期望目标方法进行事务管理，但若是错误的配置这三种 propagation，事务将不会发生回滚。
TransactionDefinition.PROPAGATION_SUPPORTS：如果当前存在事务，则加入该事务；如果当前没有事务，则以非事务的方式继续运行。TransactionDefinition.PROPAGATION_NOT_SUPPORTED：以非事务方式运行，如果当前存在事务，则把当前事务挂起。TransactionDefinition.PROPAGATION_NEVER：以非事务方式运行，如果当前存在事务，则抛出异常。
默认情况下，如果在事务中抛出了未检查异常（继承自 RuntimeException 的异常）或者 Error，则 Spring 将回滚事务；除此之外，Spring 不会回滚事务。如果在事务中抛出其他类型的异常， 并期望 Spring 能够回滚事务，可以指定 rollbackFor。例：
@Transactional(propagation= Propagation.REQUIRED,rollbackFor= MyException.class)
此外，若在目标方法中抛出的异常是 rollbackFor 指定的异常的子类，事务同样会回滚。
** 只有
@Transactional 注解应用到 public 方法，才能进行事务管理。** 若不是 public，就不会获取 @Transactional 的属性配置信息，最终会造成不会用 TransactionInterceptor 来拦截该目标方法进行事务管理。在 Spring 的 AOP 代理下，只有目标方法由外部调用，目标方法才由 Spring 生成的代理对象来管理，这会造成自调用问题。若同一类中的其他没有
@Transactional 注解的方法内部调用有 @Transactional 注解的方法，有 @Transactional 注解的方法的事务被忽略，不会发生回滚。对声明式事务管理，Spring 提供了基于 Transactional 注解的实现方式，使用简单，减少了很多复杂的配置。但是，正因为它的简单，很多开发人员在使用的时候，随手就是一个@Transactional，以为这样就把事务的问题解决了，何不知这样的使用方式很可能留下了很大的性能隐患。
当下对数据库连接的使用基本上都用连接池技术，每个应用会根据环境和自身需求设置一些合适的连接池配置，如果每个连接都一直被长时间占用，会导致数据库连接数不够用、系统各项压力指标不断攀升、系统缓慢等问题，所以说连接池中的每一个连接都是很昂贵的。那么问题就来了，只要需要事务就需要占用一个数据库连接，如果在需要开启事务的方法里进行一些 IO 操作、网络通讯等需要长时间处理的操作，这个数据库连接就一直被占用着，直到方法执行结束后自动提交事务或执行过程中发生异常回滚事务，这个数据库连接才会被释放掉。这个过程中还有一个很可怕的问题，如果在需要开启事务的方法里进行了网络通讯操作，而这个操作没有设置网络超时时间，那这个数据库连接就会被一直占用着。上述问题，在流量很大的情况下简直就是灾难，会直接导致应用系统挂掉。
综上，正确的使用
@Transactional 注解要做到如下三点：- 1.不要在类上标注
Transactional注解，要在需要的方法上标注。即使类的每个方法都需要事务也不要在类上标注，因为有可能你或别人新添加的方法根本不需要事务。 - 2.标注了
Transactional注解的方法体中不要涉及耗时很久的操作，如 IO 操作、网络通信等。 - 3.根据业务需要设置合适的事务参数，如是否需要新事务、超时时间等。
在项目中，往往需要执行数据库操作后，发送消息或事件来异步调用其他组件执行相应的操作，例如：用户注册后发送激活码、配置修改后发送更新事件等。但是，数据库的操作如果还未完成，此时异步调用的方法查询数据库发现没有数据，这就会出现问题。例如下面这个可能存在问题的栗子：
void saveUser(User u) {
//保存用户信息
userDao.save(u);
//触发保存用户事件
applicationContext.publishEvent(new SaveUserEvent(u.getId()));
}
@EventListener
void onSaveUserEvent(SaveUserEvent event) {
//获取事件中的信息（用户id）
Integer id = event.getEventData();
//查询数据库，获取用户（此时如果用户还未插入数据库，则返回空）
User u = userDao.getUserById(id);
//这里可能报空指针异常！
String phone = u.getPhoneNumber();
MessageUtils.sendMessage(phone);
}
为了解决上述问题，Spring 为我们提供了两种方式：
- 1.
@TransactionalEventListener注解 - 2.事务同步管理器
TransactionSynchronizationManager
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
void onSaveUserEvent(SaveUserEvent event) {
Integer id = event.getEventData();
User u = userDao.getUserById(id);
String phone = u.getPhoneNumber();
MessageUtils.sendMessage(phone);
}
这样，只有当前事务提交之后，才会执行 事件监听器的方法。其中参数 phase 默认为
AFTER_COMMIT，共有四个枚举：BEFORE_COMMIT、AFTER_COMMIT、AFTER_ROLLBACK、AFTER_COMPLETION。@EventListener
void onSaveUserEvent(SaveUserEvent event) {
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
@Override
public void afterCommit() {
Integer id = event.getEventData();
User u = userDao.getUserById(id);
String phone = u.getPhoneNumber();
MessageUtils.sendMessage(phone);
}
});
}
最近更新 3mo ago