1.注入DataSourceTransactionManager
@Autowired
private DataSourceTransactionManager dataSourceTransactionManager;

2.手动开启事务

DefaultTransactionDefinition defaultTransactionDefinition = new DefaultTransactionDefinition();
defaultTransactionDefinition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
TransactionStatus transaction = dataSourceTransactionManager.getTransaction(defaultTransactionDefinition);

3.try catch业务代码

try{
    // 业务代码

    // 手动提交事务
    dataSourceTransactionManager.commit(transaction);
} catch {
    // 手动回滚事务
    dataSourceTransactionManager.rollback(transaction);
}

注意:

如果业务中修改了A表,然后调用其他异步服务,其他异步服务修改了B表,若这个异步服务出现异常,A表仍然会被修改,不会受其他异步服务影响。若不是异步服务,是同步的话,则受事务影响,即其他服务出现异常,AB表都不会被修改。(以上说的服务都是属于同一个微服务中,若是涉及到远程调用其他微服务,则属于分布式事务,以上讨论的是本地事务。)

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐