前言
事务作用:在数据层保障一系列的数据库操作同成功同失败。
Spring
事务作用:在数据层或业务层保障一系列的数据库操作同成功同失败。
Spring事务
关于事务的使用通过在案例中来讲解比较直观全面。
本文以案例的方式来详解Spring
事务。
案例:模拟银行账户之间的转账业务。
需求:实现两个账户(A,B)之间的转账操作。
业务分析:
- 数据层提供基础操作,指定账户减钱(outMoney),指定账户加钱(inMoney)。
- 业务层提供转账操作(transfer),调动减钱与加钱的操作。
- 提供2个账号和操作金额执行转账操作。
- 基于Spring整合MyBatis环境搭建上述操作。
结果分析:
- 程序正常执行时,账户金额A减B加,没有问题。
- 程序出现异常后,转账失败,但是异常之前操作成功,异常之后操作失败,整体业务失败。
1. 快速实现
1.1 在业务层接口上添加Spring事务管理
public interface AccountService {
@Transactional
void transfer(String out, String in, Double money);
}
注意:
Spring
注解式事务通常添加在业务层接口中而不会添加到业务层实现类中,降低耦合。
注解式事务可以添加到业务方法上表示当前方法开启事务,也可以添加到接口上表示当前接口所有方法开启事务。
1.2 设置事务管理器
@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource) {
DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
transactionManager.setDataSource(dataSource);
return transactionManager;
}
注意:
事务管理器要根据实现技术进行选择
MyBatis
框架使用的是JDBC
事务
1.3 开启注解式事务驱动
在Spring
配置类中使用注解@EnableTransactionManagement
开启事务驱动
@Configuration
@ComponentScan({"com.hao.service", "com.hao.dao", "com.hao.aop"})
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class, MyBatisConfig.class})
@EnableTransactionManagement
public class SpringConfig {
}
2. Spring事务角色
2.1 事务管理员
发起事务方,在Spring
中通常指代业务层开启事务的方法。
如这里AccountService
中的transfer
方法是事务管理员。该方法执行时会开启一个事务。
@Transactional
public void transfer(String out, String in, Double money) {
accountDao.outMoney(out, money);
accountDao.inMoney(in, money);
}
2.1 事务协调员
加入事务方,在Spring
中通常指代数据层方法,也可以是业务层方法 。
由于AccountDao
在AccountService
中的transfer
方法中被调用,而且transfer
开启了事务,所以这里AccountDao
中的inMoney
和outMoney
方法都是事务协调员。这两个方法也会开启相应的事务并加入事务管理员的事务,这样来保证整体业务的同成功同失败。
public interface AccountDao {
@Update("update tb_account set money = money + #{money} where name = #{name}")
void inMoney(@Param("name") String name, @Param("money") Double money);
@Update("update tb_account set money = money - #{money} where name = #{name}")
void outMoney(@Param("name") String name, @Param("money") Double money);
}
3. 事务相关配置
在@Transactional
注解中的属性及作用如下图:
这里主要是属性rollbackFor
会常用到,因为Spring
事务并不是对于所有异常都会回滚,通过这个属性可以设置必须回滚的异常。比如可以进行如下设置:
public interface AccountService {
@Transactional(rollbackFor = {IOException.class, NullPointerException.class})
void transfer(String out, String in, Double money);
}
4. 事务传播行为
上边我们通过事务回滚达到了业务同成功同失败的需求。但是开发中可能也会遇到不需要事务管理员中的所有协调员都进行回滚。
比如在transfer
中增加一个日志打印的业务,要求无论transfer
是否执行成功,都进行日志打印。
public interface LogService {
void log(String out, String in, Double money);
}
@Service
public class AccountServiceImpl implements AccountService {
@Autowired
private AccountDao accountDao;
@Autowired
private LogService logService;
@Override
public void transfer(String out, String in, Double money) {
try {
accountDao.outMoney(out, money);
int i = 10 / 0;
accountDao.inMoney(in, money);
} finally {
logService.log(out, in, money);
}
}
}
这么写看起来没什么问题,但是当出现异常进行回滚时,LogService
也会进行回滚,这样就无法记录当次操作。
这就要用到事务传播行为,即事务协调员对事务管理员所携带事务的处理态度。
需要在LogService
的log
方法上增加事务注解并设置propagation = Propagation.REQUIRES_NEW
,如下:
@Service
public class LogServiceImpl implements LogService {
@Autowired
private LogDao logDao;
@Override
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void log(String out, String in, Double money) {
logDao.log("转账操作由" + out + "到" + in + ",金额:" + money);
}
}
该设置意思是LogService
的log
方法会开启新的事务,不加入事务管理员。这样无论事务管理员的事务如何回滚,都不会影响LogService
的log
方法的执行。
关于事务传播行为属性有如下类型:
可以根据需求进行相应的设置。
总结
以上就是关于Spring
事务的全部内容。
如果有什么问题,我们可以一起交流讨论解决。
最后,希望可以帮助到有需要的码友。