详解Spring Boot微服务如何集成fescar解决分布式事务问题

DruidDataSource dataSource = initDataSource(dataSourceProps.get("url").toString(), dataSourceProps.get("username").toString(), dataSourceProps.get("password").toString());

DataSourceProxy proxy = new DataSourceProxy(dataSource);

@Component

public class RequestHeaderInterceptor implements RequestInterceptor {

  @Override

  public void apply(RequestTemplate template) {

    String xid = RootContext.getXID();

    if(StringUtils.isNotBlank(xid)){

      template.header("Fescar-Xid",xid);

    }

  }

}

import com.alibaba.fescar.core.context.RootContext;

import org.apache.commons.lang.StringUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.web.filter.OncePerRequestFilter;

 

import javax.servlet.FilterChain;

import javax.servlet.ServletException;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import java.io.IOException;

 

public class FescarXidFilter extends OncePerRequestFilter {

  protected Logger logger = LoggerFactory.getLogger(FescarXidFilter.class);

 

  @Override

  protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {

    String xid = RootContext.getXID();

    String restXid = request.getHeader("Fescar-Xid");

    boolean bind = false;

    if(StringUtils.isBlank(xid)&&StringUtils.isNotBlank(restXid)){

      RootContext.bind(restXid);

      bind = true;

      if (logger.isDebugEnabled()) {

        logger.debug("bind[" + restXid + "] to RootContext");

      }

    }

    try{

      filterChain.doFilter(request, response);

    } finally {

      if (bind) {

        String unbindXid = RootContext.unbind();

        if (logger.isDebugEnabled()) {

          logger.debug("unbind[" + unbindXid + "] from RootContext");

        }

        if (!restXid.equalsIgnoreCase(unbindXid)) {

          logger.warn("xid in change during http rest from " + restXid + " to " + unbindXid);

          if (unbindXid != null) {

            RootContext.bind(unbindXid);

            logger.warn("bind [" + unbindXid + "] back to RootContext");

          }
        }
      }
    }
  }
}

@Bean

public FescarXidFilter fescarXidFilter(){

  return new FescarXidFilter();

}

 

@Bean

public GlobalTransactionScanner scanner(){

  GlobalTransactionScanner scanner = new GlobalTransactionScanner("fescar-test","my_test_tx_group");

  return scanner;

} 

@GlobalTransactional(timeoutMills = 300000, name = "fescar-test-tx")

public void testFescar() throws BusinessException {

  DictionVO dictionVO = new DictionVO();

  dictionVO.setCode("simidatest");

  dictionVO.setValue("1");

  dictionVO.setDesc("simidatest");

  dictionVO.setAppId("sso");

  commonService.createDiction(dictionVO);//远程调用服务B

  areaMapper.deleteAreaBySysNo(2);//本地事务

 

  throw new BusinessException("主动报错");

}