SpringCloudAlibaba集成zipkin和seata的时候远程调用服务连接不上的问题

r囧r小猫 2023-02-22 12:24 9阅读 0赞

1、报错如下

# 问题： #

在使用seata，使用 **spring-cloud-alibaba-seata** 和 **spring-cloud-starter-sleuth** 两个maven依赖时，在接口调用的时候，会报错：

Caused by: com.netflix.client.ClientException: Load balancer does not have available server for client: 192.168.4.15
      at com.netflix.loadbalancer.LoadBalancerContext.getServerFromLoadBalancer(LoadBalancerContext.java:483) ~[ribbon-loadbalancer-2.3.0.jar:2.3.0]
      at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:184) ~[ribbon-loadbalancer-2.3.0.jar:2.3.0]
      at com.netflix.loadbalancer.reactive.LoadBalancerCommand$1.call(LoadBalancerCommand.java:180) ~[ribbon-loadbalancer-2.3.0.jar:2.3.0]
      at rx.Observable.unsafeSubscribe(Observable.java:10327) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:94) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.internal.operators.OnSubscribeConcatMap.call(OnSubscribeConcatMap.java:42) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.Observable.subscribe(Observable.java:10423) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.Observable.subscribe(Observable.java:10390) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.observables.BlockingObservable.blockForSingle(BlockingObservable.java:443) ~[rxjava-1.3.8.jar:1.3.8]
      at rx.observables.BlockingObservable.single(BlockingObservable.java:340) ~[rxjava-1.3.8.jar:1.3.8]
      at com.netflix.client.AbstractLoadBalancerAwareClient.executeWithLoadBalancer(AbstractLoadBalancerAwareClient.java:112) ~[ribbon-loadbalancer-2.3.0.jar:2.3.0]
      at org.springframework.cloud.openfeign.ribbon.LoadBalancerFeignClient.execute(LoadBalancerFeignClient.java:83) ~[spring-cloud-openfeign-core-2.2.2.RELEASE.jar:2.2.2.RELEASE]
    ... 120 common frames omitted

2、官方修改建议：

Spring Cloud Sleuth默认通过TraceFeignClientAutoConfiguration提供feign的集成，可以设置spring.sleuth.feign.enabled为false来使其无效。

**但是**这种修改方式把sleuth关闭了，导致在zipkin控制台看到的接口调用栈都是没有任何关联的：如果你需要使用seata，但是又不想关闭sleuth，则本篇博客就来解决这个问题。

1、去除  ** *spring-cloud-alibaba-seata 依赖。***

***2、添加以下依赖***

<dependency>
                <groupId>io.seata</groupId>
                <artifactId>seata-spring-boot-starter</artifactId>
                <version>1.2.0</version>
            </dependency>

3、最好在公共工程里新建Feign拦截器类，这样所有的微服务只需要依赖公共工程就可以了，下面的几个类也是一样的

package com.ahies.stm.app.interceptor;
    
    import feign.RequestInterceptor;
    import feign.RequestTemplate;
    import io.seata.core.context.RootContext;
    import lombok.extern.slf4j.Slf4j;
    
    @Slf4j
    public class SeataFeignInterceptor implements RequestInterceptor {
        @Override
        public void apply(RequestTemplate request) {
            String xid = RootContext.getXID();
    
            if (xid != null && !xid.trim().isEmpty()) {
                log.debug("seata - feign add seata-xid http request header [{}]", xid);
                request.header(RootContext.KEY_XID, xid);
            }
        }
    }

4、新建Feign拦截器的配置类

package com.ahies.stm.app.conf;
    
    import com.ahies.stm.app.interceptor.SeataFeignInterceptor;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
    import org.springframework.context.annotation.Bean;
    
    public class SeataFeignConfiguration {
    
        @Bean
        @ConditionalOnMissingBean
        public SeataFeignInterceptor seataFeignInterceptor() {
            return new SeataFeignInterceptor();
        }
    }

5、新建开启分布式事务注解类

package com.ahies.stm.app.anno;
    
    import com.ahies.stm.app.conf.SeataFeignConfiguration;
    import io.seata.integration.http.HttpAutoConfiguration;
    import org.springframework.context.annotation.Import;
    
    import java.lang.annotation.ElementType;
    import java.lang.annotation.Retention;
    import java.lang.annotation.RetentionPolicy;
    import java.lang.annotation.Target;
    
    @Retention(RetentionPolicy.RUNTIME)
    @Target(ElementType.TYPE)
    @Import({SeataFeignConfiguration.class, HttpAutoConfiguration.class})
    public @interface EnableSeata {
    
    }

6、使用方法：在 application启动类上加上@EnableSeata 注解

7、配置文件还是和***spring-cloud-alibaba-seata 一样的用法***