随着业务的发展，系统规模变得越来越大，微服务拆分越来越细，各微服务间的调用关系也越来越复杂。客户端请求在后端系统中会经过多个不同的微服务调用来协同产生最后的请求结果，几平每一个请求都会形成一个复杂的分布式服务调用链路，在每条链路中任何一个依赖服务出现延迟超时或者错误都有可能引起整个请求最后的失败
这时需要一个能够监控微服务整个调用链的工具，跟踪一个用户请求的全过程（包括数据采集、数据传输、数据存储、数据分析、数据可视化），捕获这些跟踪数据，构建微服务整个调用链的视图，Spring Cloud Sleuth 就是这样一个工具
服务追踪系统的实现主要包括三个部分：
下面我们再来看一下 Sleuth 的核心概念
Zipkin 是一个开源的分布式追踪系统，用于对服务间的调用链路进行监控追踪。在微服务架购下，用户的一个请求可能涉及很多个后台服务间的调用。Zipkin 可以追踪（trace）调用链路、收集在各个微服务上所花的时间等信息，并上报到 Zipkin 服务器
Zipkin 提供可插拔数据存储方式：In-Memory、MySQL、Cassandra 以及 Elasticsearch，为了方便在开发环境直接采用 In-Memory 方式进行存储，生产数据量大的情况则推荐使用 Elasticsearch
Zipkin 主要由四个核心组件组成：
Zipkin 以 Trace 结构表示对一次请求的追踪，把每个 Trace 拆分为若于个有依赖关系的 Span，可以把每个处理请求的服务理解为一个 Span。Zipkin 除了可以查看 Span 的依赖关系之外，还以瀑布图的形式显示每个 Span 的耗时情况，可以清晰地看到各个服务的性能状况。打开每个 Span，还有更详细的数据以键值对的形式呈现，而且这些数据可以在装备应用的时候自行添加
Zipkin 下载地址：https://repo1.maven.org/maven2/io/zipkin/zipkin-server/
这里选择 zipkin-server-2.24.3-exec.jar 版本，既然是一个 jar 包，那么直接使用 java 命令运行即可，访问：http://localhost:9411/zipkin/ 可查看控制台
如果使用 MySQL 进行数据存储，需要事先搭建好 MySQL 数据库，执行建表脚本，可在 GitHub 获取：https://github.com/openzipkin/zipkin/blob/master/zipkin-storage/mysql-v1/src/main/resources/mysql.sql
启动 ZipKin，连接 MySQL，具体启动命令如下：
java -jar .\zipkin-server-2.24.3-exec.jar --STORAGE_TYPE=mysql --MYSQL_HOST=127.0.0.1 --MYSQL_TCP_PORT=3306 --MYSQL_DB=test_db --MYSQL_USER=root --MYSQL_PASS=123
在 server-01 和 server-02 项目分别添加依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-sleuth</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-sleuth-zipkin</artifactId>
</dependency>
在 server-01 和 server-02 项目分别添加配置
spring:
zipkin:
base-url: http://localhost:9411
enabled: true
sleuth:
enabled: true
如果 spring-cloud-sleuth-zipkin 位于类路径中，则该应用程序会生成并收集与 Zipkin 兼容的 Trace，默认情况下，应用程序通过 HTTP 将 ace 信息发送到本地主机（端口 9411）上的 ZipKin 服务器，可以通过设置 spring.zipkin.base-url 来配置服务的地址
在 server-01 使用 Feign 调用 server-02 接口
// server-01
@Slf4j
@RestController
public class TestCon {
@Autowired
private Server02FeignClient server02FeignClient;
@GetMapping("/test/getConfigByFeign")
public void getConfigByFeign() {
server02FeignClient.getConfig();
}
}
// server-02
@Slf4j
@RestController
public class TestCon {
@Value("${test.value}")
private String testValue;
@Value("${spring.application.name}")
private String applicationName;
@Value("${server.port}")
private String port;
@GetMapping("/test/getConfig")
public void getConfig() {
log.info("testValue: {} by {}-{}", testValue, applicationName, port);
}
}
查看 ZipKin 控制台，选择 Dependencies 选项卡，点击 RUN QUERY 查看具体请求链路，选择 Find a trace 选项卡，单击 RUN QUERY，可查看具体的请求信息