成都创新互联网站制作重庆分公司

SpringBoot微服务怎么集成fescar解决分布式事务问题

这篇文章将为大家详细讲解有关Spring Boot微服务怎么集成fescar解决分布式事务问题,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。

网站的建设成都创新互联公司专注网站定制,经验丰富,不做模板,主营网站定制开发.小程序定制开发,H5页面制作!给你焕然一新的设计体验!已为玻璃贴膜等企业提供专业服务。

什么是fescar?

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

Spring Boot微服务怎么集成fescar解决分布式事务问题

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

Spring Boot微服务怎么集成fescar解决分布式事务问题

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

Spring Boot如何集成fescar?

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

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 {

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

          }
        }
      }
    }
  }
}

这样就完成了fescar的集成。

开始使用吧!

首先在项目中初始化两个Bean:

@Bean

public FescarXidFilter fescarXidFilter(){

  return new FescarXidFilter();

}

 

@Bean

public GlobalTransactionScanner scanner(){

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

  return scanner;

}

然后写两个服务,服务A调用服务B,并在A服务的调用方法上打上@GlobalTransactional标签:

@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("主动报错");

}

最后,两个项目中添加application.conf文件,用于告诉客户端如何与分布式协调器通信,官方示例中有这个文件,就不在此贴代码啦,application.conf传送门

启动事务协调器,sh fescar-server.sh 8091 ~/dksl/git/fescar/data,启动你的项目,开始测试吧!

last thing

分布式事务作为微服务应用中的老大难问题,在现有的解决方案中,个人认为fescar是目前最轻量并且代价最小的一种解决方案。目前的版本,事务协调器还不能分布式部署,官方给出的路线图是在三月底会有第一个生产可用版本。让我们一起参与到fescar的社区中,共同推动fescar生态建设,让落地微服务不必再担心分布式事务的问题。

关于“Spring Boot微服务怎么集成fescar解决分布式事务问题”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。


网站题目:SpringBoot微服务怎么集成fescar解决分布式事务问题
URL链接:http://cxhlcq.com/article/jsicjs.html

其他资讯

在线咨询

微信咨询

电话咨询

028-86922220(工作日)

18980820575(7×24)

提交需求

返回顶部