Java外功精要(6)——Spring事务及其传播机制

用户11873138

发布于 2026-01-13 21:44:11

1300

1.概述

Spring事务管理是Spring框架中用于确保数据库操作 原子性、一致性、隔离性和持久性(ACID) 的核心机制。它通过声明式或编程式(本文略)方式管理事务，支持多种事务传播行为和隔离级别

相较于编程式事务，声明式事务通过@Transactional注解实现事务管理，无需手动编写事务代码
事务基本概念在全面解析MySQL(5)——“索引、事务、JDBC”三大核心一文中有介绍，本文不再赘述

2.@Transactional

作用：提供声明式事务管理。它简化了在应用程序中管理数据库事务的流程。开发者只需在方法或类上添加此注解，Spring框架就会自动处理事务的开启、提交和回滚，无需手动编写事务管理代码(如 begin、commit、rollback) 级别：类 + 方法

作为类注解：为类中所有public方法添加注解
作为方法注解：默认仅对public方法生效

@RequestMapping("/test")
@RestController
@Slf4j
public class TestController {
    private final UserService userService;

    @Autowired
    public TestController(UserService userService) {
        this.userService = userService;
    }

    @Transactional
    @RequestMapping("/test1")
    public String test1(String userName,String password) {
        UserInfo userInfo = new UserInfo();
        userInfo.setUserName(userName);
        userInfo.setPassword(password);
        Integer result = userService.register(userInfo);
        if (result == 1){
            log.info("test1注册成功,userName:{},password:{}", userName, password);
        }
        return "注册成功";
    }
}

使用PostMan向后端发送请求：

MySQL查询结果如下：

后端日志日志如下：

2.1 rollbackfor

作用：指定哪些异常触发回滚，默认情况下在抛出 非受查异常(RuntimeException)/错误(Error) 时触发回滚

抛出受查异常时

@RequestMapping("/test")
@RestController
@Slf4j
public class TestController {
    private final UserService userService;

    @Autowired
    public TestController(UserService userService) {
        this.userService = userService;
    }

    @Transactional
    @RequestMapping("/test2")
    public String test2(String userName,String password) throws IOException {
        UserInfo userInfo = new UserInfo();
        userInfo.setUserName(userName);
        userInfo.setPassword(password);
        Integer result = userService.register(userInfo);
        if (result == 1){
            log.info("test2注册成功,userName:{},password:{}", userName, password);
            throw new IOException();
        }
        return "注册成功";
    }
}

使用PostMan向后端发送请求：

MySQL查询结果如下：

后端日志日志如下：

抛出非受查异常时

@RequestMapping("/test")
@RestController
@Slf4j
public class TestController {
    private final UserService userService;

    @Autowired
    public TestController(UserService userService) {
        this.userService = userService;
    }

    @Transactional
    @RequestMapping("/test3")
    public String test3(String userName,String password) {
        UserInfo userInfo = new UserInfo();
        userInfo.setUserName(userName);
        userInfo.setPassword(password);
        Integer result = userService.register(userInfo);
        if (result == 1){
            log.info("test3注册成功,userName:{},password:{}", userName, password);
            throw new RuntimeException();
        }
        return "注册成功";
    }
}

使用PostMan向后端发送请求：

MySQL查询结果如下：

后端日志日志如下：

指定回滚类型

@RequestMapping("/test")
@RestController
@Slf4j
public class TestController {
    private final UserService userService;

    @Autowired
    public TestController(UserService userService) {
        this.userService = userService;
    }

    @Transactional(rollbackFor = Exception.class)
    @RequestMapping("/test4")
    public String test4(String userName,String password) throws IOException {
        UserInfo userInfo = new UserInfo();
        userInfo.setUserName(userName);
        userInfo.setPassword(password);
        Integer result = userService.register(userInfo);
        if (result == 1){
            log.info("test4注册成功,userName:{},password:{}", userName, password);
            throw new IOException();
        }
        return "注册成功";
    }
}