kim-sleuth-zipkin: 使用sleuth-zipkin实现分布式链路追踪 ①使用http方式实现链路追踪 ②使用rabbitmq方式实现链路追踪 ③使用elasticsearch方式存储链路追踪记录

一、使用HTTP方式实现sleuth

①   启动zipkin服务端

java -jar zipkin-server-2.23.2-exec.jar
    
②   加入链路追踪依赖

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-zipkin</artifactId>
            </dependency>
            
③   配置文件写入

###数据库配置
    spring:
      application:
        name: kim-b
      zipkin:
        base-url: http://127.0.0.1:9411 #Web 连接方式使用
        service:
          name: kim-b
        sender:
          type: web # 还有 activemq、kafka、rabbit 
      sleuth:
        sampler:
          probability: 1 #跟踪信息收集采样比例，默认 0.1，为 1 即 100%，收集所有 注意之前的版本是 percentage 新版本中更换为 probability
          #      rate: 50 # 每秒速率，即每秒最多能跟踪的请求，rate 优先
          
二、使用rabbitmq方式

①   启动zipkin服务端

java -jar zipkin-server-2.23.2-exec.jar --RABBIT_ADDRESSES=127.0.0.1:5672
    
②   加入链路追踪依赖

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-zipkin</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-amqp</artifactId>
            </dependency>
            
③   配置文件写入

spring:
      zipkin:
        sender:
          type: rabbit
      sleuth:
        sampler:
          probability: 1.0 #跟踪信息收集采样比例，默认 0.1，为 1 即 100%，收集所有 注意之前的版本是 percentage 新版本中更换为 probability
          #      rate: 50 # 每秒速率，即每秒最多能跟踪的请求，rate 优先
      rabbitmq:
        host: 127.0.0.1
        port: 5672
        username: guest
        password: guest

三、增加es方式存储链路追踪

①   启动zipkin服务端

java -jar zipkin-server-2.23.2-exec.jar --STORAGE_TYPE=elasticsearch --ES_HOSTS=http://127.0.0.1:9200 --RABBIT_ADDRESSES=127.0.0.1:5672 --ES_USERNAME=elastic --ES_PASSWORD=123456

②   加入链路追踪依赖

<dependency>
                <groupId>io.zipkin.java</groupId>
                <artifactId>zipkin-autoconfigure-storage-elasticsearch-http</artifactId>
                <version>2.8.4</version>
            </dependency>
            
③   配置文件写入

zipkin:
      storage:
        type: elasticsearch
        elasticsearch:
          hosts: http://127.0.0.1:9200
          username: elastic
          password: 123456
          cluster: elasticsearch
          index: zipkin
          index-shards: 1
          index-replicas: 1
          
          
PS:

与 Seata 集成的冲突问题

如果微服务中使用分布式事务 Seata，那集成 Zipkin 后， 就会出现问题服务调用服务失败的问题如下
    com.netflix.client.ClientException: Load balancer does not have available server for client:ip
    主要原因是 pom 引入的 Zipkin 包含 Sleuth，而 Sleuth 的配置类 TraceFeignClientAutoConfiguration 和 Seata 的配置类 SeataFeignClientAutoConfiguration 都创建了 Bean:feignHystrixBuilder，冲突导致上面的错误。

问题解决

每个服务工程配置 Seata 拦截器类 SetSeataInterceptor ，以拦截器的方式传递 XID

import com.bpmaxx.common.utils.StringUtils;
    import feign.RequestInterceptor;
    import feign.RequestTemplate;
    import io.seata.core.context.RootContext;
    import io.seata.spring.annotation.GlobalTransactional;
    import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
    import org.springframework.stereotype.Component;
    
    /**
     * @Description: 解决 seata 与 zipkin 整合时因 SeataFeignClientAutoConfiguration 和 TraceFeignClientAutoConfiguration 都创建 Bean:feignHystrixBuilder 冲突问题
     */
    @Component
    @ConditionalOnClass({RequestInterceptor.class,GlobalTransactional.class})
    public class SetSeataInterceptor implements RequestInterceptor {
        @Override
        public void apply(RequestTemplate request) {
            String xid = RootContext.getXID();
            if (StringUtils.isNotEmpty(xid)) {
                request.header(RootContext.KEY_XID, xid);
            }
        }
    }
    
启动类排除 SeataFeignClientAutoConfiguration.class

@SpringBootApplication(exclude = {SeataFeignClientAutoConfiguration.class})

Kim_wu/kim-sleuth-zipkin

简介

发行版

贡献者

近期动态

Kim_wu/kim-sleuth-zipkin .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

Kim_wu/kim-sleuth-zipkin