SpringCloud Hoxton版 + SpringCloud alibaba学习笔记（7）-- SpringCloud Sleuth分布式请求链路追踪

柔情只为你懂 2022-12-30 13:51 26阅读 0赞

## 上一篇：[SpringCloud Hoxton版 + SpringCloud alibaba学习笔记（6）-- SpringCloud Stream消息驱动][SpringCloud Hoxton_ _ SpringCloud alibaba_6_-- SpringCloud Stream] ##

### 一、概述 ###

#### 1、为什么会出现这个技术？需要解决哪些问题？ ####

问题  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 1]

#### 2、是什么 ####

##### ①、https://github.com/spring-cloud/spring-cloud-sleuth #####

##### ②、Spring Cloud Sleuth提供了一套完整的服务跟踪的解决方案 #####

##### ③、在分布式系统中提供追踪解决方案并且兼容支持了zipkin #####

#### 3、解决 ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 2]

### 二、搭建链路监控步骤 ###

#### 1、zipkin ####

##### ①、下载 #####

SpringCloud从F版起已不需要自己构建Zipkin server了，只需要调用jar包即可  
[https://dl.bintray.com/openzipkin/maven/io/zipkin/java/zipkin-server/][https_dl.bintray.com_openzipkin_maven_io_zipkin_java_zipkin-server]  
zipkin-server-2.12.9.exec.jar

##### ②、运行jar #####

java -jar zipkin-server-2.12.9-exec.jar  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 3]

##### ③、运行控制台 #####

http://localhost:9411/zipkin/  
完整的调用链路  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 4]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 5]  
Trace:类似于树结构的Span集合，表示一条调用链路，存在唯一标识  
span:表示调用链路来源，通俗的理解span就是一次请求信息

#### 2、服务提供者 ####

##### ①、cloud-provider-payment8001 #####

##### ②、POM #####

<dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-zipkin</artifactId>
    </dependency>

##### ③、YML #####

server:
      port: 8001
    
    spring:
      application:
        name: cloud-payment-service
      zipkin:
        base-url: http://localhost:9411
      sleuth:
        sampler:
        probability: 1
      datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: org.gjt.mm.mysql.Driver
        url: 
        username: root
        password: 
    
    mybatis:
      mapperLocations: classpath:mapper/*.xml
      type-aliases-package: com.atguigu.springcloud.entities
    
    
    eureka:
      client:
        register-with-eureka: true
        fetchRegistry: true
        service-url:
          defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  #集群版
      instance:
        instance-id: payment8001
        prefer-ip-address: true

##### ④、业务类PaymentController #####

package com.atguigu.springcloud.controller;
     
    import com.atguigu.springcloud.entities.CommonResult;
    import com.atguigu.springcloud.entities.Payment;
    import com.atguigu.springcloud.service.PaymentService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.cloud.client.ServiceInstance;
    import org.springframework.web.bind.annotation.*;
    import org.springframework.cloud.client.discovery.DiscoveryClient;
     
    import javax.annotation.Resource;
    import java.util.List;
    import java.util.concurrent.TimeUnit;
     
     
    @RestController
    @Slf4j
    public class PaymentController
    { 
        @Resource
        private PaymentService paymentService;
     
        @Value("${server.port}")
        private String serverPort;
     
        @Resource
        private DiscoveryClient discoveryClient;
     
        @PostMapping(value = "/payment/create")
        public CommonResult create(@RequestBody Payment payment)
        { 
            int result = paymentService.create(payment);
            log.info("*****插入结果："+result);
     
            if(result > 0)
            { 
                return new CommonResult(200,"插入数据库成功,serverPort: "+serverPort,result);
            }else{ 
                return new CommonResult(444,"插入数据库失败",null);
            }
        }
     
        @GetMapping(value = "/payment/get/{id}")
        public CommonResult<Payment> getPaymentById(@PathVariable("id") Long id)
        { 
            Payment payment = paymentService.getPaymentById(id);
     
            if(payment != null)
            { 
                return new CommonResult(200,"查询成功,serverPort: "+serverPort,payment);
            }else{ 
                return new CommonResult(444,"没有对应记录,查询ID: "+id,null);
            }
        }
     
        @GetMapping(value = "/payment/discovery")
        public Object discovery()
        { 
            List<String> services = discoveryClient.getServices();
            for (String element : services) { 
                log.info("*****element: "+element);
            }
     
            List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICE");
            for (ServiceInstance instance : instances) { 
                log.info(instance.getServiceId()+"\t"+instance.getHost()+"\t"+instance.getPort()+"\t"+instance.getUri());
            }
     
            return this.discoveryClient;
        }
     
        @GetMapping(value = "/payment/lb")
        public String getPaymentLB()
        { 
            return serverPort;
        }
     
        @GetMapping(value = "/payment/feign/timeout")
        public String paymentFeignTimeout()
        { 
            // 业务逻辑处理正确，但是需要耗费3秒钟
            try {  TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) {  e.printStackTrace(); }
            return serverPort;
        }
     
        @GetMapping("/payment/zipkin")
        public String paymentZipkin()
        { 
            return "hi ,i'am paymentzipkin server fall back，welcome to atguigu，O(∩_∩)O哈哈~";
        }
    }

#### 3、服务消费者（调用方） ####

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-zipkin</artifactId>
    </dependency>

##### ①、cloud-consumer-order80 #####

##### ②、POM #####

<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-zipkin</artifactId>
            </dependency>

##### ③、YML #####

server:
      port: 80
     
    spring:
        application:
            name: cloud-order-service
        zipkin:
          base-url: http://localhost:9411
        sleuth:
          sampler:
            probability: 1
     
    eureka:
      client:
        #表示是否将自己注册进EurekaServer默认为true。
        register-with-eureka: false
        #是否从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
        fetchRegistry: true
        service-url:
          #单机
          #defaultZone: http://localhost:7001/eureka
          # 集群
          defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版

##### ④、业务类OrderController #####

// ====================> zipkin+sleuth
        @GetMapping("/consumer/payment/zipkin")
        public String paymentZipkin()
        { 
            String result = restTemplate.getForObject("http://localhost:8001"+"/payment/zipkin/", String.class);
            return result;
        }

#### 4、依次启动eureka7001/8001/80 ####

80调用8001几次测试下

#### 5、打开浏览器访问:http:localhost:9411 ####

会出现以下界面  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 6]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 7]

查看依赖关系  
原理  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 8]

## 下一篇：[SpringCloud Hoxton版 + SpringCloud alibaba学习笔记（8）-- SpringCloud Alibaba入门简介][SpringCloud Hoxton_ _ SpringCloud alibaba_8_-- SpringCloud Alibaba] ##

[SpringCloud Hoxton_ _ SpringCloud alibaba_6_-- SpringCloud Stream]: https://blog.csdn.net/exodus3/article/details/111570767
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70]: /images/20221120/70a3826963114f5dba96001929bbdd9c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20201226020016116.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201226020127942.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM=,size_16,color_FFFFFF,t_70
[https_dl.bintray.com_openzipkin_maven_io_zipkin_java_zipkin-server]: https://dl.bintray.com/openzipkin/maven/io/zipkin/java/zipkin-server/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 3]: https://img-blog.csdnimg.cn/20201226020415199.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 4]: https://img-blog.csdnimg.cn/20201226020453749.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 5]: https://img-blog.csdnimg.cn/20201226020506485.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 6]: https://img-blog.csdnimg.cn/20201226232808131.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 7]: https://img-blog.csdnimg.cn/20201226232848764.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM_size_16_color_FFFFFF_t_70 8]: https://img-blog.csdnimg.cn/20201226232827945.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2V4b2R1czM=,size_16,color_FFFFFF,t_70
[SpringCloud Hoxton_ _ SpringCloud alibaba_8_-- SpringCloud Alibaba]: https://blog.csdn.net/exodus3/article/details/111771395