Seata分布式事务失效，不生效事务不回滚的常见场景

一、微服务没有正常获取XID

检查方法：

在每个微服务中调用方法 RootContext.getXID() 检查XID

例如，服务A调用了服务B和服务C

那么可以分别在服务A、服务B、服务C的事务方法中添加

1.  
   ===============服务A
2.  
   @Service
3.  
   public class ServiceAImpl implements IServiceA
4.  
   {
5.  
    
6.  
   private static final Logger log = LoggerFactory.getLogger(ServiceAImpl.class);
7.  
    
8.  
   @Autowired
9.  
   private IServiceB serviceB;
10.  
    @Autowired
11.  
    private IServiceC serviceC;
12.  
     
13.  
    @Override
14.  
    @GlobalTransactional
15.  
    @Transactional
16.  
    public Boolean doA() {
17.  
    log.info("Seata全局事务id=================>{}",RootContext.getXID());
18.  
    //......
19.  
    }
20.  
     
21.  
    }
22.  
     
23.  
    ===============服务B
24.  
    @Service
25.  
    public class ServiceBImpl implements IServiceB
26.  
    {
27.  
     
28.  
    private static final Logger log = LoggerFactory.getLogger(ServiceBImpl.class);
29.  
     
30.  
    @Override
31.  
    @Transactional(propagation = Propagation.REQUIRES_NEW)
32.  
    public Boolean doB() {
33.  
    log.info("Seata全局事务id=================>{}",RootContext.getXID());
34.  
    //......
35.  
    }
36.  
     
37.  
    }
38.  
     
39.  
    ===============服务C
40.  
    @Service
41.  
    public class ServiceCImpl implements IServiceC
42.  
    {
43.  
     
44.  
    private static final Logger log = LoggerFactory.getLogger(ServiceCImpl.class);
45.  
     
46.  
    @Override
47.  
    @Transactional(propagation = Propagation.REQUIRES_NEW)
48.  
    public Boolean doC() {
49.  
    log.info("Seata全局事务id=================>{}",RootContext.getXID());
50.  
    //......
51.  
    }
52.  
     
53.  
    }

（1）查看XID是否为null

（2）每个服务中的XID不一致

如果出现以上两种其中一种，基本可以确定是因为XID导致事务失效

解决办法:

（1）XID正常情况下是通过请求头上的参数传递给下游服务的，可以通过seta包的getModifyRequest方法下的headers.put打断点进行分析

（2）在调用方法中直接传参给下游服务

1.  
   ===============服务A
2.  
   @Service
3.  
   public class ServiceAImpl implements IServiceA
4.  
   {
5.  
    
6.  
   private static final Logger log = LoggerFactory.getLogger(ServiceAImpl.class);
7.  
    
8.  
   @Autowired
9.  
   private IServiceB serviceB;
10.  
    @Autowired
11.  
    private IServiceC serviceC;
12.  
     
13.  
    @Override
14.  
    @GlobalTransactional
15.  
    @Transactional
16.  
    public Boolean doA() {
17.  
    String XID = RootContext.getXID();
18.  
    serviceB.doB(XID);
19.  
    serviceC.doC(XID);
20.  
    //......
21.  
    }
22.  
     
23.  
    }
24.  
     
25.  
    ===============服务B
26.  
    @Service
27.  
    public class ServiceBImpl implements IServiceB
28.  
    {
29.  
     
30.  
    private static final Logger log = LoggerFactory.getLogger(ServiceBImpl.class);
31.  
     
32.  
    @Override
33.  
    @Transactional(propagation = Propagation.REQUIRES_NEW)
34.  
    public Boolean doB(XID) {
35.  
    RootContext.bind(XID);
36.  
    //......
37.  
    }
38.  
     
39.  
    }
40.  
     
41.  
    ===============服务C
42.  
    @Service
43.  
    public class ServiceCImpl implements IServiceC
44.  
    {
45.  
     
46.  
    private static final Logger log = LoggerFactory.getLogger(ServiceCImpl.class);
47.  
     
48.  
    @Override
49.  
    @Transactional(propagation = Propagation.REQUIRES_NEW)
50.  
    public Boolean doC(XID) {
51.  
    RootContext.bind(XID);
52.  
    //......
53.  
    }
54.  
     
55.  
    }

二、undo_log表有脏数据

当Seata没有正常结束时，每个服务对应数据库中的undo_log表和seata持久化数据库的brach_table、global_table、lock_table、undo_log表都有可能有脏数据没有正确删除，从而导致服务一直回滚，却不成功

解决办法:清除undo_log表以及seata持久化数据库的brach_table、global_table、lock_table、undo_log表中的脏数据

三、Fegin调用使用了Fallback降级或抛出的异常被全局处理

这种情况下属于seata服务发现不了下游服务抛出的异常，导致事务不会触发回滚

解决办法:

（1）通过 GlobalTransactionContext.reload(RootContext.getXID()).rollback() 进行手动回滚

1.  
   ===============服务A
2.  
   @Service
3.  
   public class ServiceAImpl implements IServiceA
4.  
   {
5.  
    
6.  
   private static final Logger log = LoggerFactory.getLogger(ServiceAImpl.class);
7.  
    
8.  
   @Autowired
9.  
   private IServiceB serviceB;
10.  
    @Autowired
11.  
    private IServiceC serviceC;
12.  
     
13.  
    @Override
14.  
    @GlobalTransactional
15.  
    @Transactional
16.  
    public Boolean doA() {
17.  
    Integer bStatus = serviceB.doB();
18.  
    if(bStatus == 0){//在Mybatis中，返回值为0证明插入失败
19.  
    //手动回滚
20.  
    GlobalTransactionContext.reload(RootContext.getXID()).rollback();
21.  
    return false;
22.  
    }
23.  
    Integer cStatus = serviceC.doC();
24.  
    if(cStatus == 0){//在Mybatis中，返回值为0证明插入失败
25.  
    //手动回滚
26.  
    GlobalTransactionContext.reload(RootContext.getXID()).rollback();
27.  
    return false;
28.  
    }
29.  
    //......
30.  
    }
31.  
     
32.  
    }
33.  
     
34.  
    ===============服务B
35.  
    @Service
36.  
    public class ServiceBImpl implements IServiceB
37.  
    {
38.  
     
39.  
    private static final Logger log = LoggerFactory.getLogger(ServiceBImpl.class);
40.  
     
41.  
    @Override
42.  
    @Transactional(propagation = Propagation.REQUIRES_NEW)
43.  
    public Boolean doB() {
44.  
    //......
45.  
    Integer insertStatus = serviceBDAO.insert();
46.  
    return insertStatus;
47.  
    }
48.  
     
49.  
    }
50.  
     
51.  
    ===============服务C
52.  
    @Service
53.  
    public class ServiceCImpl implements IServiceC
54.  
    {
55.  
     
56.  
    private static final Logger log = LoggerFactory.getLogger(ServiceCImpl.class);
57.  
     
58.  
    @Override
59.  
    @Transactional(propagation = Propagation.REQUIRES_NEW)
60.  
    public Boolean doC() {
61.  
    //......
62.  
    Integer insertStatus = serviceCDAO.insert();
63.  
    return insertStatus;
64.  
    }
65.  
     
66.  
    }

（2）通过切面类

详见官方文档

https://gitee.com/link?target=http://seata.io/zh-cn/blog/seata-spring-boot-aop-aspectj.html

这篇好文章是转载于：学新通技术网