美文网首页
谈谈Spring事务注解

谈谈Spring事务注解

作者: 北方有你南方有我 | 来源:发表于2020-04-30 15:18 被阅读0次

    @Transation 注解是我们在开发中常用的注解,但是我们大多数只知道配置上就可以开启事务,很多人比如我,都不知道spring的事务原理,比如事务的嵌套生效情况 ,事务什么时候会失效,spring的事务又和mysql数据库的事务有何联系,其实这些都是面试中的高频考点。

    下面进行逐步分析:

    Spring中七种事务传播行为

    事务传播行为类型说明

    PROPAGATION_REQUIRED如果当前没有事务,就新建一个事务,如果已经存在一个事务中,加入到这个事务中。这是最常见的选择。是默认的传播机制;

    PROPAGATION_SUPPORTS支持当前事务,如果当前没有事务,就以非事务方式执行。

    PROPAGATION_MANDATORY使用当前的事务,如果当前没有事务,就抛出异常。

    PROPAGATION_REQUIRES_NEW新建事务,如果当前存在事务,把当前事务挂起。

    PROPAGATION_NOT_SUPPORTED以非事务方式执行操作,如果当前存在事务,就把当前事务挂起。

    PROPAGATION_NEVER以非事务方式执行,如果当前存在事务,则抛出异常。

    PROPAGATION_NESTED如果当前存在事务,则在嵌套事务内执行。如果当前没有事务,则执行与PROPAGATION_REQUIRED类似的操作。

    Spring事务嵌套详解:

    1.PROPAGATION_REQUIRED

    User1Service方法:

    @Servicepublic class User1ServiceImpl implements User1Service {

        //省略其他...    @Override    @Transactional(propagation = Propagation.REQUIRED)

        public void addRequired(User1 user){

            user1Mapper.insert(user);

        }

    }

    User2Service方法:

    @Servicepublic class User2ServiceImpl implements User2Service {

        //省略其他...    @Override    @Transactional(propagation = Propagation.REQUIRED)

        public void addRequired(User2 user){

            user2Mapper.insert(user);

        }

    }

    验证方法1:

        @Override    public void notransaction_exception_required_required(){

            User1 user1=new User1();

            user1.setName("张三");

            user1Service.addRequired(user1);

            User2 user2=new User2();

            user2.setName("李四");

            user2Service.addRequired(user2);

            throw new RuntimeException();

        }

    结果:插入了张三 李四 数据 外围方法未开启事务,插入“张三”、“李四”方法在自己的事务中独立运行,外围方法异常不影响内部插入“张三”、“李四”方法独立的事务。

    验证方法2:

      @Override    @Transactional(propagation = Propagation.REQUIRED)

        public void transaction_exception_required_required(){

            User1 user1=new User1();

            user1.setName("张三");

            user1Service.addRequired(user1);

            User2 user2=new User2();

            user2.setName("李四");

            user2Service.addRequired(user2);

            throw new RuntimeException();

        }

    结果:都没有插入 张三 李四 数据  外围方法开启事务,内部方法加入外围方法事务,外围方法回滚,内部方法也要回滚。

    1. 在外围方法未开启事务的情况下Propagation.REQUIRED修饰的内部方法会新开启自己的事务,且开启的事务相互独立,互不干扰。

    2.外围方法开启事务的情况下Propagation.REQUIRED修饰的内部方法会加入到外围方法的事务中,所有Propagation.REQUIRED修饰的内部方法和外围方法均属于同一事务,只要一个方法回滚,整个事务均回滚。

    2.PROPAGATION_REQUIRES_NEW

    我们为User1Service和User2Service相应方法加上Propagation.REQUIRES_NEW属性。

    User1Service方法:

    @Servicepublic class User1ServiceImpl implements User1Service {

        //省略其他...    @Override    @Transactional(propagation = Propagation.REQUIRES_NEW)

        public void addRequiresNew(User1 user){

            user1Mapper.insert(user);

        }

        @Override    @Transactional(propagation = Propagation.REQUIRED)

        public void addRequired(User1 user){

            user1Mapper.insert(user);

        }

    }

    User2Service方法:

    @Servicepublic class User2ServiceImpl implements User2Service {

        //省略其他...    @Override    @Transactional(propagation = Propagation.REQUIRES_NEW)

        public void addRequiresNew(User2 user){

            user2Mapper.insert(user);

        }

        @Override    @Transactional(propagation = Propagation.REQUIRES_NEW)

        public void addRequiresNewException(User2 user){

            user2Mapper.insert(user);

            throw new RuntimeException();

        }

    }

    外围方法没有开启事务。

    验证方法1:

        @Override    public void notransaction_exception_requiresNew_requiresNew(){

            User1 user1=new User1();

            user1.setName("张三");

            user1Service.addRequiresNew(user1);

            User2 user2=new User2();

            user2.setName("李四");

            user2Service.addRequiresNew(user2);

            throw new RuntimeException();

        }

    结果:张三 李四都插入 。外围方法没有事务,插入“张三”、“李四”方法都在自己的事务中独立运行,外围方法抛出异常回滚不会影响内部方法。

    验证方法2:

        @Override    @Transactional(propagation = Propagation.REQUIRED)

        public void transaction_exception_required_requiresNew_requiresNew(){

            User1 user1=new User1();

            user1.setName("张三");

            user1Service.addRequired(user1);

            User2 user2=new User2();

            user2.setName("李四");

            user2Service.addRequiresNew(user2);

            User2 user3=new User2();

            user3.setName("王五");

            user2Service.addRequiresNew(user3);

            throw new RuntimeException();

        }

    结果:张三 未插入 李四 王五都插入 。外围方法没有事务,插入“张三”、“李四”方法都在自己的事务中独立运行,外围方法抛出异常回滚不会影响内部方法。

    1.在外围方法未开启事务的情况下Propagation.REQUIRES_NEW修饰的内部方法会新开启自己的事务,且开启的事务相互独立,互不干扰。

    2.在外围方法开启事务的情况下Propagation.REQUIRES_NEW修饰的内部方法依然会单独开启独立事务,且与外部方法事务也独立,内部方法之间、内部方法和外部方法事务均相互独立,互不干扰

    3.PROPAGATION_NESTED

    我们为User1Service和User2Service相应方法加上Propagation.NESTED属性。

    User1Service方法:

    @Servicepublic class User1ServiceImpl implements User1Service {

        //省略其他...    @Override    @Transactional(propagation = Propagation.NESTED)

        public void addNested(User1 user){

            user1Mapper.insert(user);

        }

    }

    User2Service方法:

    @Servicepublic class User2ServiceImpl implements User2Service {

        //省略其他...    @Override    @Transactional(propagation = Propagation.NESTED)

        public void addNested(User2 user){

            user2Mapper.insert(user);

        }

        @Override    @Transactional(propagation = Propagation.NESTED)

        public void addNestedException(User2 user){

            user2Mapper.insert(user);

            throw new RuntimeException();

        }

    }

    此场景外围方法没有开启事务。

    验证方法1:

        @Override    public void notransaction_exception_nested_nested(){

            User1 user1=new User1();

            user1.setName("张三");

            user1Service.addNested(user1);

            User2 user2=new User2();

            user2.setName("李四");

            user2Service.addNested(user2);

            throw new RuntimeException();

        }

    结果:张三 李四都插入。外围方法未开启事务,插入“张三”、“李四”方法在自己的事务中独立运行,外围方法异常不影响内部插入“张三”、“李四”方法独立的事务。

    验证方法2:

        @Transactional    @Override    public void transaction_exception_nested_nested(){

            User1 user1=new User1();

            user1.setName("张三");

            user1Service.addNested(user1);

            User2 user2=new User2();

            user2.setName("李四");

            user2Service.addNested(user2);

            throw new RuntimeException();

        }

    结果:张三 李四都没有插入。外围方法开启事务,内部事务为外围事务的子事务,外围方法回滚,内部方法也要回滚。

    验证方法3:

        @Transactional    @Override    public void transaction_nested_nested_exception_try(){

            User1 user1=new User1();

            user1.setName("张三");

            user1Service.addNested(user1);

            User2 user2=new User2();

            user2.setName("李四");

            try {

                user2Service.addNestedException(user2);

            } catch (Exception e) {

                System.out.println("方法回滚");

            }

        }

    结果:张三 插入 ,李四没有插入  这里李四抛出的异常被捕获,不影响张三事务提交。外围方法开启事务,内部事务为外围事务的子事务,插入“李四”内部方法抛出异常,可以单独对子事务回滚。

    1.在外围方法未开启事务的情况下Propagation.NESTED和Propagation.REQUIRED作用相同,修饰的内部方法都会新开启自己的事务,且开启的事务相互独立,互不干扰。

    2.在外围方法开启事务的情况下Propagation.NESTED修饰的内部方法属于外部事务的子事务,外围主事务回滚,子事务一定回滚,而内部子事务可以单独回滚而不影响外围主事务和其他子事务

    我们在实际工作中如何正确应用spring事务呢?我来举一个示例:

    假设我们有一个注册的方法,方法中调用添加积分的方法,如果我们希望添加积分不会影响注册流程(即添加积分执行失败回滚不能使注册方法也回滚),

    而且在addPoint()中还要用一个addRecord()方法,这个方法用来记录日志。

    做以下设计:

    会员注册实现:

    @Service  public class UserServiceImpl implements UserService {

        @Transactional        public void register(User user){

                try {

                     membershipPointService.addPoint(Point point);

                } catch (Exception e) {

                  //省略...            }

                //省略...        }

            //省略...  }

    注册失败要影响addPoint()方法(注册方法回滚添加积分方法也需要回滚)

    @Service  public class MembershipPointServiceImpl implements MembershipPointService{

        @Transactional(propagation = Propagation.NESTED)

            public void addPoint(Point point){

                try {

                    recordService.addRecord(Record record);

                } catch (Exception e) {

                  //省略...            }

                //省略...        }

            //省略...  }

    对于日志无所谓精确,可以多一条也可以少一条,所以addRecord()方法本身和外围addPoint()方法抛出异常都不会使addRecord()方法回滚,并且addRecord()方法抛出异常也不会影响外围addPoint()方法的执行。

      @Service  public class RecordServiceImpl implements RecordService{

            @Transactional(propagation = Propagation.NOT_SUPPORTED)

            public void addRecord(Record record){

                 //省略...        }

            //省略...  }

    Spring事务失效条件:

    1.@Transactional 注解只能应用到 public 可见度的方法上。 如果你在 protected、private 或者 package-visible 的方法上使用 @Transactional 注解,它也不会报错,事务也会失效。

    2. Spring团队建议在具体的类(或类的方法)上使用 @Transactional 注解,而不要使用在类所要实现的任何接口上。在接口上使用 @Transactional 注解,只能当你设置了基于接口的代理时它才生效。因为注解是不能继承 的,这就意味着如果正在使用基于类的代理时,那么事务的设置将不能被基于类的代理所识别,而且对象也将不会被事务代理所包装。

    3.数据库不知道事务(一般不会有)

    4.在业务代码中,有如下两种情况,比如:

    throw new RuntimeException(“xxxxxxxxxxxx”); 事务回滚

    throw new Exception(“xxxxxxxxxxxx”); 事务没有回滚

    一般不需要在业务方法中catch异常,如果非要catch,在做完你想做的工作后(比如关闭文件等)一定要抛出runtime exception,否则spring会将你的操作commit,这样就会产生脏数据

    5.异常类型是否配置正确

    默认只支持 RuntimeException和Error ,不支持检查异常

    @Transactional(rollbackFor=Exception.class)  显示写了遇到Exception回滚,抛出的是RuntimeException 会造成事务失效

    Spring事务与数据库事务的关系:

    对数据库来说隔离级别只有4种,

    #读未提交set tx_isolation='read-uncommitted';  #读已提交set tx_isolation='read-committed';  #为可重复读set tx_isolation='REPEATABLE-READ';  #为串行化set tx_isolation='SERIALIZABLE';

    Spring有5种隔离级别,7种传播行为,Spring多了一个DEFAULT 这是一个PlatfromTransactionManager默认的隔离级别。

    spring的事务是对数据库的事务的封装,最后本质的实现还是在数据库,假如数据库不支持事务的话,spring的事务是没有作用的

    数据库的事务说简单就只有开启,回滚和关闭,spring对数据库事务的包装,原理就是拿一个数据连接,根据spring的事务配置,操作这个数据连接对数据库进行事务开启,回滚或关闭操作.但是spring除了实现这些,还配合spring的传播行为对事务进行了更广泛的管理.其实这里还有个重要的点,那就是事务中涉及的隔离级别,

    相关文章

      网友评论

          本文标题:谈谈Spring事务注解

          本文链接:https://www.haomeiwen.com/subject/fnnzwhtx.html