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

什么是fescar?

关于fescar的详细介绍，请参阅fescar wiki。

传统的2pc提交协议，会持有一个全局性的锁，所有局部事务预提交成功后一起提交，或有一个局部事务预提交失败后一起回滚，最后释放全局锁。锁持有的时间较长，会对并发造成较大的影响，死锁的风险也较高。

fescar的创新之处在于，每个局部事务执行完立即提交，释放本地锁；它会去解析你代码中的sql，从数据库中获得事务提交前的事务资源即数据，存放到undo_log中，全局事务协调器在回滚的时候直接使用undo_log中的数据覆盖你提交的数据。

spring boot如何集成fescar?

我们可以从官方代码库中看到，fescar目前提供的示例是针对使用dubbo的服务，那spring boot的项目如何集成fescar呢？

和很多2pc提交协议（如tx_lcn）的解决方案一样，fescar也是在数据源处做了代理，和事务协调器进行通信，来决定本地事务是否回滚。所以，第一步，在你的spring boot项目中，首先应使用fescar提供的代理数据源作为你的数据源，例如：

druiddatasource datasource = initdatasource(datasourceprops.get("url").tostring(), datasourceprops.get("username").tostring(), datasourceprops.get("password").tostring());

datasourceproxy proxy = new datasourceproxy(datasource);

然后，你需要创建一个feign拦截器，把rootcontext中的xid（xid用于标识一个局部事务属于哪个全局事务，需要在调用链路的上下文中传递）传递到上层调用链路。

@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);

}

最后，你需要创建一个http rest请求拦截器，用于把当前上下文中获取到的xid放到rootcontext。

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 {