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

喜欢ヅ旅行 2021-12-09 01:11 198阅读 0赞

### 什么是fescar? ###

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

![434643-20190129220547876-2116362323.png][]

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

![434643-20190129221741166-209668681.png][]

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

### Spring Boot如何集成fescar? ###

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

![434643-20190129222552483-1063912503.png][]

和很多2PC提交协议（如[tx\_lcn][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传送门][application.conf]

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

### last thing ###

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

转载于:https://www.cnblogs.com/DKSL/p/fescar.html

[fescar wiki]: https://github.com/alibaba/fescar/wiki/%E6%A6%82%E8%A7%88
[434643-20190129220547876-2116362323.png]: /images/20211209/d045fffc2941406b95f3f547aaf5b0f4.png
[434643-20190129221741166-209668681.png]: /images/20211209/d1f6787a8e8c486e8464d958475249c7.png
[Link 1]: https://github.com/alibaba/fescar
[434643-20190129222552483-1063912503.png]: /images/20211209/53fd97fbe99246bdbff10dfead3683d0.png
[tx_lcn]: https://github.com/codingapi/tx-lcn
[application.conf]: https://github.com/alibaba/fescar/blob/develop/examples/src/main/resources/application.conf