SpringCloud Alibaba入门到精通（十三）- 分布式请求链路跟踪Sleuth（不推荐）

阅读数：次 2021-01-21

转载字数统计: 2k字 | 预计阅读时长≈ 7分钟

此文章主要讲解 springcloud 中的分布式请求链路跟踪 Sleuth 的相关知识。

参考文章： https://www.yuque.com/sunxiaping/yg511q/xc44uq

微服务架构下的问题

在大型系统的微服务化构建中，一个系统会被拆分成许多模块。这些模块负责不同的功能，组合成系统，最终可以提供丰富的功能。在这种架构中，一次请求往往需要涉及到多个服务。互联网应用构建在不同的软件模块集上，这些软件模块，可能是由不同团队开发、可能使用不同的编程语言来实现、可能部署在几千台服务器上，横跨多个不同的数据中心，也就意味着这种架构形式也会存在一些问题：
- 如何快速的发现问题？
- 如何判断故障影响范围？
- 如何梳理服务依赖以及依赖的合理性？
- 如何分析链路性能问题以及实时容量规划？
分布式链路追踪（Distributed Tracing），就是将一次分布式请求还原成调用链路，进行日志记录，性能监控并将一次分布式请求的调用情况集中展示。比如各个服务节点上的耗时、请求具体到达那台机器上、每个服务节点的请求状态等等。
目前业界比较流行的链路追踪系统如：Twitter 的Zipkin，阿里的鹰眼，美团的Mtrace，大众点评的cat等，大部分都是基于 Google 发表的Dapper。Dapper 阐述了分布式系统，特别是微服务架构中链路追踪的概念、数据展示、埋点、传递、收集、存储和展示等技术细节。

Sleuth

分布式请求链路跟踪，超大型系统。需要在微服务模块极其多的情况下，比如80调用8001的，8001调用8002的，这样就形成了一个链路，如果链路中某环节出现了故障，我们可以使用Sleuth进行链路跟踪，从而找到出现故障的环节。

在微服务框架中，一个由客户端发起的请求在后端系统中会经过多个不同的的服务节点调用来协同产生最后的请求结果，每一个前段请求都会形成一条复杂的分布式服务调用链路，链路中的任何一环出现高延时或错误都会引起整个请求最后的失败。

简介

Spring Cloud Sleuth主要功能就是在分布式系统中提供追踪解决方案，并且兼容支持了 zipkin，只需要在 pom 文件中引入相应的依赖即可。
sleuth 负责跟踪，而 zipkin 负责展示。

环境

zipkin 下载

从 SpringBoot2.0 开始，官方就不再支持使用自建 Zipkin Server 的方式进行服务链路追踪，而是直接提供了编译好的 jar 包来给我们使用。可以从官方网站上下载 Zipkin 。

zipkin 下载地址：点我下载。

zipkin 启动

使在命令行输入java -jar zipkin-server-2.12.9-exec.jar启动 Zipkin Server。

默认 Zipkin Server 的请求端口是9411.
在浏览器输入 http://localhost:9411 即可进入到 Zipkin Server 的管理后台。

使用 Docker 启动 Zipkin Server

1	docker run -d -p 9411:9411 --name zipkin openzipkin/zipkin:2.12.9

案例

使用之前创建的模块 cloud-provider-payment8001 和 cloud-consumer-order80 进行改造

引依赖

<!-- 包含了 sleuth + zipkin -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>

YML 配置

spring:
  # zipkin
  zipkin:
    base-url: http://localhost:9411/ # Zipkin Server端的请求地址
    sender:
      type: web # 数据的传输方式，以HTTP的形式向Zipkin Server端发送数据
  sleuth:
    sampler:
      probability: 1 # 采样比  默认为0.1，即10%，这里配置1，是记录全部的sleuth信息，是为了收集到更多的数据（仅供测试使用）
   .......

消费者：

server:
  port: 80

spring:
  application:
    name: cloud-order-service
  zipkin:
    base-url: http://localhost:9411/ # Zipkin Server端的请求地址
    sender:
      type: web # 数据的传输方式，以HTTP的形式向Zipkin Server端发送数据
  sleuth:
    sampler:
      probability: 1 # 采样比  默认为0.1，即10%，这里配置1，是记录全部的sleuth信息，是为了收集到更多的数据（仅供测试使用）

eureka:
  client:
    register-with-eureka: true
    fetch-registry: true
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/

提供者：

# 端口号
server:
  port: 8001
spring:
  application:
    name: cloud-payment-service
  zipkin:
    base-url: http://localhost:9411/ # Zipkin Server端的请求地址
    sender:
      type: web # 数据的传输方式，以HTTP的形式向Zipkin Server端发送数据
  sleuth:
    sampler:
      probability: 1 # 采样比  默认为0.1，即10%，这里配置1，是记录全部的sleuth信息，是为了收集到更多的数据（仅供测试使用）

  # 数据源
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/springcloud2020?useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: root

# mybatis 相关
mybatis:
  mapper-locations: classpath:mapper/*.xml
  type-aliases-package: com.itjing.springcloud.entities # 所有Entity 别名类所在包

eureka:
  client:
    # 注册进 Eureka 的服务中心
    register-with-eureka: true
    # 是否从eureka抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
    fetch-registry: true
    service-url:
      # 设置与 Eureka Server 交互的地址
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
    healthcheck:
      enabled: true # 开启健康检查(依赖spring-boot-actuator)
  instance:
    instance-id: payment8001
    prefer-ip-address: true # 访问路径可以显示ip地址
    # Eureka客户端向服务端发送心跳的时间间隔，单位为秒（默认为30秒）
    lease-renewal-interval-in-seconds: 10
    # Eureka服务端在收到最后一次心跳后等待时间上限，单位为秒（默认为90秒，超时将剔除服务）
    lease-expiration-duration-in-seconds: 20

业务类

在 8001 的 Controller 中添加一个简单的请求

@GetMapping("/payment/zipkin")
public String paymentZipkin() {
    return "hi,i'm paymentzipkin server fall back, 哈哈~";
}

在 80 的 Controller 中添加请求

@GetMapping("/consumer/payment/zipkin")
public String paymentZipkin() {
    String result = restTemplate.getForObject(PAYMENT_URL + "/payment/zipkin", String.class);
    return result;
}

测试

启动 eureka 7001
启动提供者 8001
启动消费者 80

使 80 访问 8001 几次： http://localhost/consumer/payment/zipkin

访问： http://localhost:9411/zipkin/ ，查看情况

点击该 trace 可以看到请求的细节：

本文作者： LiJing
发布时间： 2021-01-21
最后更新： 2024-06-24
本文标题： SpringCloud Alibaba入门到精通（十三）- 分布式请求链路跟踪Sleuth（不推荐）
本文链接： https://blog-yilia.xiaojingge.com/posts/6bab2f78.html
版权声明： 本作品采用 CC BY-NC-SA 4.0 许可协议进行许可。转载请注明出处！