如何在事务提交后才执行某个方法

2021-07-17 15:31:59 阅读：271 来源： 互联网

标签：insert 事务 Transactional void add 提交某个 public

在开发中是否遇到过这种情况，在一个spring事务管理的方法中需要发送一个消息，但是消费消息的时候查询到的数据还是事务提交之前的数据。

代码如下：

@Transactional
    public void add() {
        //插入数据逻辑
        //发送消息
    }

此时我们希望的效果是，等事务提交之后再发mq。
可以改成如下写法：

 public void add() {
        //insert方法

        //发送消息
    }
    
    @Transactional
    public void insert() {
        //insert
    }

但是这样每次涉及这样的业务都需要包一层，而且很多时候并不知道调用add文章的外层是否还有@Transactional注解
我们希望达到的效果是注册一个mq事件，等事务提交后再出发我们的mq事件。

TransactionSynchronizationManager

嵌入如下代码，可以注册一个事务事件，在事务提交之后才出发我的方法。

TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
        @Override
        public void afterCommit() {
            System.out.println("a");
        }
});

总的写法如下：

@Transactional
public void add() {
    //insert
	TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() {
	        @Override
	        public void afterCommit() {
	           //发送消息
	        }
	});
   
}

这样消费消息时查到的数据就是最新的数据了。

还有一种编程式的事务应该也可以解决

public void add() {
	transactionTemplate.execute(status -> {
                
    });
    // 发送消息
}

这种方式还可以用于批量执行时如果遇到错误或者异常不需要回滚的场景 , 不需要单独定一个service用于开启子事务或者动态代理获取当前的service了 , 直接将子事务中需要执行的逻辑用编程式的方式实现就好了。

标签：insert,事务,Transactional,void,add,提交,某个,public
来源： https://blog.csdn.net/qq_37044995/article/details/118857239

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

如何在事务提交后才执行某个方法

TransactionSynchronizationManager