Spring Cloud构建微服务架构：分布式服务跟踪（入门）【Dalston版】

妖狐艹你老母 2021-12-05 21:21 231阅读 0赞

通过之前的N篇博文介绍，实际上我们已经能够通过使用它们搭建起一个基础的微服务架构系统来实现我们的业务需求了。但是，随着业务的发展，我们的系统规模也会变得越来越大，各微服务间的调用关系也变得越来越错综复杂。通常一个由客户端发起的请求在后端系统中会经过多个不同的微服务调用来协同产生最后的请求结果，在复杂的微服务架构系统中，几乎每一个前端请求都会形成一条复杂的分布式服务调用链路，在每条链路中任何一个依赖服务出现延迟过高或错误的时候都有可能引起请求最后的失败。这时候对于每个请求全链路调用的跟踪就变得越来越重要，通过实现对请求调用的跟踪可以帮助我们快速的发现错误根源以及监控分析每条请求链路上的性能瓶颈等好处。

针对上面所述的分布式服务跟踪问题，Spring Cloud Sleuth提供了一套完整的解决方案。在本章中，我们将详细介绍如何使用Spring Cloud Sleuth来为我们的微服务架构增加分布式服务跟踪的能力。

### 快速入门 ###

在介绍各种概念与原理之前，我们先通过实现一个简单的示例，对存在服务调用的应用增加一些sleuth的配置实现基本的服务跟踪功能，以此来对Spring Cloud Sleuth有一个初步的了解，随后再逐步展开介绍实现过程中的各个细节部分。

#### 准备工作 ####

在引入Sleuth之前，我们先按照之前章节学习的内容来做一些准备工作，构建一些基础的设施和应用：

*  服务注册中心：`eureka-server`，这里不做赘述，直接使用之前构建的工程。
 *  微服务应用：`trace-1`，实现一个REST接口`/trace-1`，调用该接口后将触发对`trace-2`应用的调用。具体实现如下：
    
     *  创建一个基础的Spring Boot应用，在`pom.xml`中增加下面依赖：

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
       	<version>1.5.10.RELEASE</version>
        <relativePath/> 
    </parent>
    <dependency>
      	<groupId>org.springframework.boot</groupId>
       	<artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
       	<groupId>org.springframework.cloud</groupId>
       	<artifactId>spring-cloud-starter-eureka</artifactId>
    </dependency>
    <dependency>
       	<groupId>org.springframework.cloud</groupId>
       	<artifactId>spring-cloud-starter-ribbon</artifactId>
    </dependency>
    <dependencyManagement>
       	<dependencies>
       		<dependency>
       			<groupId>org.springframework.cloud</groupId>
       			<artifactId>spring-cloud-dependencies</artifactId>
       			<version>Dalston.SR5</version>
       			<type>pom</type>
       			<scope>import</scope>
       		</dependency>
       	</dependencies>
    </dependencyManagement>

*  创建应用主类，并实现`/trace-1`接口，并使用`RestTemplate`调用`trace-2`应用的接口。具体如下：

@RestController
    @EnableDiscoveryClient
    @SpringBootApplication
    public class TraceApplication {
    
        private final Logger logger = Logger.getLogger(getClass());
    
        @Bean
        @LoadBalanced
        RestTemplate restTemplate() {
        	return new RestTemplate();
        }
    
        @RequestMapping(value = "/trace-1", method = RequestMethod.GET)
        public String trace() {
        	logger.info("===call trace-1===");
     //下面http://trace-2/trace-2中的第一个trace-2其实是指trace-2应用服务在euraka注册中心服务器上注册的服务名，第二个trace-2是trace-2应用里的一个@RequestMapping方法
        	return restTemplate().getForEntity("http://trace-2/trace-2", String.class).getBody();
        }
    
        public static void main(String[] args) {
        	SpringApplication.run(TraceApplication.class, args);
        }
    
    }

*  `application.properties`中将`eureka.client.serviceUrl.defaultZone`参数指向eureka-server的地址，具体如下：

spring.application.name=trace-1
    server.port=9101
    eureka.client.serviceUrl.defaultZone=http://localhost:1001/eureka/

*  微服务应用：`trace-2`，实现一个REST接口`/trace-2`，供`trace-1`调用。具体实现如下：
    
     *  创建一个基础的Spring Boot应用，`pom.xml`中的依赖与`trace-1`相同
     *  创建应用主类，并实现`/trace-2`接口，具体实现如下：

@RestController
    @EnableDiscoveryClient
    @SpringBootApplication
    public class TraceApplication {
    
        private final Logger logger = Logger.getLogger(getClass());
    
        @RequestMapping(value = "/trace-2", method = RequestMethod.GET)
        public String trace() {
        	logger.info("===<call trace-2>===");
        	return "Trace";
        }
    
        public static void main(String[] args) {
        	SpringApplication.run(TraceApplication.class, args);
        }
    
    }

*  `application.properties`中将`eureka.client.serviceUrl.defaultZone`参数指向eureka-server的地址，另外还需要设置不同的应用名和端口号，具体如下：

spring.application.name=trace-2
    server.port=9102
    eureka.client.serviceUrl.defaultZone=http://localhost:1001/eureka/

在实现了上面内容之后，我们可以将`eureka-server`、`trace-1`、`trace-2`三个应用都启动起来，我们可以通过浏览器直接访问http://localhost:9101/trace-1，如下图所示  
![在这里插入图片描述][2019071715423775.png]  
然后再看trace-1的控制台，打印出来了`===call trace-1===`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjQxOTU3_size_16_color_FFFFFF_t_70]  
然后再看trace-2的控制台，打印出了`===<call trace-2>===`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjQxOTU3_size_16_color_FFFFFF_t_70 1]  
疑问：我们在trace-1里面有这样的一段代码，

restTemplate().getForEntity("http://trace-2/trace-2", String.class).getBody();

那我们能不能直接通过浏览器访问`http://trace-2/trace-2`，从而访问trace-2里的方法呢？  
答：不能，因为`http://trace-2/trace-2`中的第一个`trace-2`是指trace-2服务器在euraka注册中心服务器上注册的服务名，所以只能在euraka客户端（**解释:凡是在euraka上注册了自己的服务的应用，都是euraka客户端**）内部使用，第二个`trace-2`是`trace-2服务器`的controller层里写的一个@RequestMapping方法。 而浏览器地址栏可不会解析什么euraka服务，所以不能直接通过`http://服务名/方法映射路径`的方式来访问，只能通过`ip地址+端口号+方法映射路径`的方式来访问，如下图为通过浏览器来访问`trace-2服务器`的 `@RequestMapping(value = "/trace-2", method = RequestMethod.GET)`的结果图  
![在这里插入图片描述][20190717160533953.png]

## 实现跟踪 ##

在完成了准备工作之后，接下来我们开始进行本章的主题内容，为上面的trace-1和trace-2来添加服务跟踪功能。通过Spring Cloud Sleuth的封装，我们为应用增加服务跟踪能力的操作非常简单，只需要在trace-1和trace-2的pom.xml依赖管理中增加spring-cloud-starter-sleuth依赖即可，具体如下：

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

到这里，实际上我们已经为`trace-1`和`trace-2`实现服务跟踪做好了基础的准备，重启`trace-1`和`trace-2`后，再对`trace-1`的接口发送请求`http://localhost:9101/trace-1`。此时，我们可以从它们的控制台输出中，窥探到sleuth的一些端倪。

trace-1的控制台：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjQxOTU3_size_16_color_FFFFFF_t_70 2]  
trace-2的控制台：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjQxOTU3_size_16_color_FFFFFF_t_70 3]  
从上面的控制台输出内容中，我们可以看到多了一些形如`[trace-1,6f6f8ad72fcb13f0,6f6f8ad72fcb13f0,false]`的日志信息，而这些元素正是实现分布式服务跟踪的重要组成部分，它们每个值的含义如下：

*  第一个值：trace-1，它记录了应用的名称，也就是application.properties中spring.application.name参数配置的属性。
 *  第二个值：6f6f8ad72fcb13f0，Spring Cloud Sleuth生成的一个ID，称为Trace ID，它用来标识一条请求链路。一条请求链路中包含一个Trace ID，多个Span ID。
 *  第三个值：6f6f8ad72fcb13f0，Spring Cloud Sleuth生成的另外一个ID，称为Span ID，它表示一个基本的工作单元，比如：发送一个HTTP请求。
 *  第四个值：false，表示是否要将该信息输出到Zipkin等服务中来收集和展示。

上面四个值中的Trace ID和Span ID是Spring Cloud Sleuth实现分布式服务跟踪的核心。在一次服务请求链路的调用过程中，会保持并传递同一个Trace ID，从而将整个分布于不同微服务进程中的请求跟踪信息串联起来，以上面输出内容为例，trace-1和trace-2同属于一个前端服务请求来源，所以他们的Trace ID是相同的，处于同一条请求链路中。

本文转载地址：  
[http://blog.didispace.com/spring-cloud-starter-dalston-8-1/][http_blog.didispace.com_spring-cloud-starter-dalston-8-1]

[2019071715423775.png]: /images/20211205/da54905db64a45028e2e524b44ff7da3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjQxOTU3_size_16_color_FFFFFF_t_70]: /images/20211205/f849e66291414ccc9db431b58fa8c253.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjQxOTU3_size_16_color_FFFFFF_t_70 1]: /images/20211205/a133ed9dce074808a192727c4e82b568.png
[20190717160533953.png]: /images/20211205/b04e107883e743ed8d1e8c3cc3285afb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjQxOTU3_size_16_color_FFFFFF_t_70 2]: /images/20211205/08b1d2cb8374471d9d4239ad4a3c7bda.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQwMjQxOTU3_size_16_color_FFFFFF_t_70 3]: /images/20211205/f207fa0c7f484f71a3db5c1da217ec7f.png
[http_blog.didispace.com_spring-cloud-starter-dalston-8-1]: http://blog.didispace.com/spring-cloud-starter-dalston-8-1/