seata 分布式事务没有传递xid导致事务失效解决方案_java

seata 分布式事务没有传递xid导致事务失效解决方案

当spring cloud 设置全局开启分布式事务，在调用分支事务没有传递xid，原因是feign或者http调用时候 header 没有put xid，可以在SeataHandlerInterceptor.preHandle 方法验证，如果xid 为null则代表调用分支事务进行http调用或者feign调用没有put 事务xid。

feign调用解决方案 1
自动传递xid

@Configuration
public class FeignConfig implements RequestInterceptor {
    @Override
    public void apply(RequestTemplate requestTemplate) {
        String xid = RootContext.getXID();
        if (StringUtils.isNotEmpty(xid)) {
            requestTemplate.header(RootContext.KEY_XID, xid);
        }
    }
}

feign调用解决方案 2
手动传递xid

主事务获取xid
String xid= RootContext.getXID();

分支事务绑定 xid（传递事务xid）
service.method1(xid);
RootContext.bing(xid);
service.method2(xid);
RootContext.bing(xid);

主事务手动回滚
try{
// ...
}catch(){
GlobalTransactionContext.reload(RootContext.getXID()).rollback()
}