[Java] 详解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("主动报错");
 
}