天天看点

Springboot注解事务使用总结,有资金业务的项目必备回滚功能@Transactional 开启事务管理事务注解详解指定事务管理器问题1:问题2:

在使用Springboot的注解事务的时候,需要考虑到事务的传播行为、遇到什么类型的异常时,事务才起作用、事务方法之间的嵌套调用时,怎么样才生效等等诸多问题。

 开启事务管理

@EnableTransactionManagement // 启注解事务管理,等同于xml配置方式的 <tx:annotation-driven />
           

事务注解详解

默认遇到throw new RuntimeException("…");会回滚

需要捕获的throw new Exception("…");不会回滚

指定回滚

@Transactional(rollbackFor=Exception.class) 
           

指定不回滚

@Transactional(noRollbackFor=Exception.class)
           

 加入事务

@Transactional(propagation=Propagation.REQUIRED) 
           

不为这个方法开启事务

@Transactional(propagation=Propagation.NOT_SUPPORTED)
           

不管是否存在事务,都创建一个新的事务,原来的挂起,新的执行完毕,继续执行老的事务

@Transactional(propagation=Propagation.REQUIRES_NEW) 
           

 必须在一个已有的事务中执行,否则抛出异常

@Transactional(propagation=Propagation.MANDATORY)
           

必须在一个没有的事务中执行,否则抛出异常(与Propagation.MANDATORY相反)

@Transactional(propagation=Propagation.NEVER) 
           

如果其他bean调用这个方法,在其他bean中声明事务,那就用事务.如果其他bean没有声明事务,那就不用事务

@Transactional(propagation=Propagation.SUPPORTS) 
           

readOnly=true只读,不能更新,删除

@Transactional (propagation = Propagation.REQUIRED,readOnly=true)
           

设置超时时间

@Transactional (propagation = Propagation.REQUIRED,timeout=30)
           

设置数据库隔离级别

@Transactional (propagation = Propagation.REQUIRED,isolation=Isolation.DEFAULT)
           

指定事务管理器

Springboot使用事务非常简单,首先使用注解 @EnableTransactionManagement 开启事务支持后,然后在访问数据库的Service方法上添加注解 @Transactional 便可。

关于事务管理器,不管是JPA还是JDBC等都实现自接口 PlatformTransactionManager 如果你添加的是 spring-boot-starter-jdbc 依赖,框架会默认注入 DataSourceTransactionManager 实例。如果你添加的是 spring-boot-starter-data-jpa 依赖,框架会默认注入 JpaTransactionManager 实例。

如果项目做的比较大,添加的持久化依赖比较多,需要人为的指定使用哪个事务管理器。

指定事务管理器

@EnableTransactionManagement
@SpringBootApplication
public class ProfiledemoApplication {

    // 其中 dataSource 框架会自动为我们注入
    @Bean
    public PlatformTransactionManager txManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean
    public Object testBean(PlatformTransactionManager platformTransactionManager) {
        System.out.println(">>>>>>>>>>" + platformTransactionManager.getClass().getName());
        return new Object();
    }

    public static void main(String[] args) {
        SpringApplication.run(ProfiledemoApplication.class, args);
    }
}

           

在Spring容器中,我们手工注解@Bean 将被优先加载,框架不会重新实例化其他的 PlatformTransactionManager 实现类。

然后在Service中,被 @Transactional 注解的方法,将支持事务。如果注解在类上,则整个类的所有方法都默认支持事务。

对于同一个工程中存在多个事务管理器要怎么处理,请看下面的实例,具体说明请看代码中的注释。

使用指定事务管理器

@EnableTransactionManagement // 开启注解事务管理,等同于xml配置文件中的 <tx:annotation-driven />
@SpringBootApplication
public class ProfiledemoApplication implements TransactionManagementConfigurer {

    @Resource(name="txManager2")
    private PlatformTransactionManager txManager2;

    // 创建事务管理器1
    @Bean(name = "txManager1")
    public PlatformTransactionManager txManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    // 创建事务管理器2
    @Bean(name = "txManager2")
    public PlatformTransactionManager txManager2(EntityManagerFactory factory) {
        return new JpaTransactionManager(factory);
    }

    // 实现接口 TransactionManagementConfigurer 方法,其返回值代表在拥有多个事务管理器的情况下默认使用的事务管理器
    @Override
    public PlatformTransactionManager annotationDrivenTransactionManager() {
        return txManager2;
    }

    public static void main(String[] args) {
        SpringApplication.run(ProfiledemoApplication.class, args);
    }

}

@Component
public class DevSendMessage implements SendMessage {

    // 使用value具体指定使用哪个事务管理器
    @Transactional(value="txManager1")
    @Override
    public void send() {
        System.out.println(">>>>>>>>Dev Send()<<<<<<<<");
        send2();
    }

    // 在存在多个事务管理器的情况下,如果使用value具体指定
    // 则默认使用方法 annotationDrivenTransactionManager() 返回的事务管理器
    @Transactional
    public void send2() {
        System.out.println(">>>>>>>>Dev Send2()<<<<<<<<");
    }

}


           

问题1:

业务:新增用户时,需要对用户详细信息进行保存USER表,还要对用户的角色进行保存USER_ROLE表(一对多)。

此时就需要对新增用户进行事务控制,避免二者不能同时更新成功。

项目采用SpringBoot+Mybatis

SpringBoot不用单独的去配置事务管理,使用@Transactional即可,但是在service层方法上加上@Transactional后发现事务并没有生效。代码如下:

@Transactional (rollbackFor = Exception. class)
public ResponseVo addUser (CreatUserEntity user) {
try {
userMapper.addUser(user);
userMapper.addRoleById(user.getRoles());
return ResponseVo. success(true);
} catch (RuntimeException e) {
log. error("Fail to addUser data:", e);
return ResponseVo. fail(ResponseCode.ERROR_ACCESS_DB);
}
}
           

此时新增用户成功,新增角色时抛出异常,但是用户成功被添加了。这是不允许的,在一对多的数据操作中,肯定是需要全部数据操作都成功才行,否则业务会出现极大的损失。

后来发现时由于@Transactional在抛出异常时进行回滚,但是try catch已经把异常捕获了,@Transactional没办法获取异常,也不知道在哪发生的异常,所以失效了。对代码进行修改,如下:

Controller层:

@RequestMapping ( method = RequestMethod.POST)
public ResponseVo addUser (@RequestBody CreatUserEntity user) {
try {
return userService.addUser(user);
} catch (RuntimeException e) {
log. error("Fail to addUser data:", e);
return ResponseVo.fail(ResponseCode.ERROR_ACCESS_DB);
}
           

Service层:

@Transactional (rollbackFor = Exception. class)
public ResponseVo addUser (CreatUserEntity user) {
userMapper.addUser (user) ;
userMapper.addRoleById(user.getRoles());
return ResponseVo.success(true) ;
}
           

问题2:

像问题1中,如果需要启用事务回滚,必须要在Service层中添加事务注解。但是如果我就想在Controller层中加上事务呢?

可以这样做:

@Transactional(rollbackFor = Exception.class)
public void yourMethodName(HttpServletRequest request, HttpServletResponse response) {

    try{
    int status1=mapper1.insert(step1);
    if(status1==1){
    int status2=mapper2.update(step2);
    if(status2==1){
    int status3=mapper3.delete(step3);
    if(status3==1){
    logger.info("成功!")
    }else{
    int e=1/0;
    logger.error("失败!启用事务回滚")    
    }
    }else{
    int e=1/0;
    logger.error("失败!启用事务回滚")    
    }
    }else{
    int e=1/0;
    logger.error("失败!启用事务回滚")    
    }
    
   
}catch(Exception e){
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();//手动启动回滚事务机制
e.printStackTrace();
}


}
           

重点的语句是:

@Transactional(rollbackFor = Exception.class)

TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();//手动启动回滚事务机制

只要在try catch中,如果发现insert、update、delete方法返回的状态码不是1,都是mapper处理数据不成功的状态码,所以可以在不成功的else中手动启用int e=1/0;的事务回滚,1/0一定会报被除数不能为0的异常,所以手动进入回滚事务,这样就不会产生脏数据。