Spring Cloud构建微服务架构:分布式服务跟踪(入门)【Dalston版】

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: Spring Cloud构建微服务架构:分布式服务跟踪(入门)【Dalston版】

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

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

快速入门

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

准备工作

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

  • 服务注册中心:eureka-server,这里不做赘述,直接使用之前构建的工程。或者直接使用我的公益eureka注册中心,下面的例子使用该注册中心。
  • 微服务应用: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===");
      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://eureka.didispace.com/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://eureka.didispace.com/eureka/

在实现了上面内容之后,我们可以将eureka-servertrace-1trace-2三个应用都启动起来,并通过postman或curl等工具来对trace-1的接口发送请求http://localhost:9101/trace-1,我们可以得到返回值Trace,同时还能在它们的控制台中分别获得下面的输出:

-- trace-1
INFO 25272 --- [nio-9101-exec-2] ication$$EnhancerBySpringCGLIB$$36e12c68 : ===<call trace-1>===
-- trace-2
INFO 7136 --- [nio-9102-exec-1] ication$$EnhancerBySpringCGLIB$$52a02f0b : ===<call trace-2>===

实现跟踪

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

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

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

-- trace-1
INFO [trace-1,f410ab57afd5c145,a9f2118fa2019684,false] 25028 --- [nio-9101-exec-1] ication$$EnhancerBySpringCGLIB$$d8228493 : ===<call trace-1>===
-- trace-2
INFO [trace-2,f410ab57afd5c145,e9a377dc2268bc29,false] 23112 --- [nio-9102-exec-1] ication$$EnhancerBySpringCGLIB$$e6cb4078 : ===<call trace-2>===

从上面的控制台输出内容中,我们可以看到多了一些形如[trace-1,f410ab57afd5c145,a9f2118fa2019684,false]的日志信息,而这些元素正是实现分布式服务跟踪的重要组成部分,它们每个值的含义如下:

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

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

本文完整示例:

读者可以根据喜好选择下面的两个仓库中查看trace-1trace-2两个项目:

如果您对这些感兴趣,欢迎star、follow、收藏、转发给予支持!

本文内容部分节选自我的《Spring Cloud微服务实战》,但对依赖的Spring Boot和Spring Cloud版本做了升级。

目录
相关文章
|
7月前
|
负载均衡 Java API
深入了解Spring Cloud Netflix:构建微服务架构的利器
在当今快速发展的软件开发领域,微服务架构已经成为了构建高度可伸缩、灵活性强的应用程序的首选方式。然而,微服务架构也带来了一系列的挑战,包括服务发现、负载均衡、容错处理、配置管理等问题。Spring Cloud Netflix是一组用于构建分布式系统的开源工具,它基于Netflix的一些开源项目,为开发人员提供了强大的解决方案,帮助他们轻松地构建和管理微服务应用程序。本文将深入介绍Spring Cloud Netflix的主要组件以及它们如何帮助开发人员构建稳健的微服务架构。
|
1月前
|
SpringCloudAlibaba Java 持续交付
【构建一套Spring Cloud项目的大概步骤】&【Springcloud Alibaba微服务分布式架构学习资料】
【构建一套Spring Cloud项目的大概步骤】&【Springcloud Alibaba微服务分布式架构学习资料】
142 0
|
8月前
|
负载均衡 Java 测试技术
构建分布式微服务架构:深入探索 Spring Cloud
在当今互联网时代,分布式系统和微服务架构已经成为了构建高效、可扩展应用的标准方式。Spring Cloud,作为 Spring 生态系统的一部分,为开发人员提供了一套强大的工具和库,帮助他们构建稳定、可靠的分布式微服务应用。本文将为您详细介绍 Spring Cloud 的核心概念、组件以及为何它在分布式架构中如此受欢迎。
308 0
|
6月前
|
负载均衡 Java Go
Spring Cloud:构建微服务的最佳实践
Spring Cloud:构建微服务的最佳实践
364 0
|
存储 缓存 负载均衡
Spring Cloud构建微服务架构:服务消费(基础)【Dalston版】
Spring Cloud构建微服务架构:服务消费(基础)【Dalston版】
161 0
|
消息中间件 存储 运维
Spring Cloud构建微服务架构(七)消息总线
Spring Cloud构建微服务架构(七)消息总线
240 0
Spring Cloud构建微服务架构(七)消息总线
|
缓存 监控 Java
Spring Cloud构建微服务架构(三)断路器
Spring Cloud构建微服务架构(三)断路器
140 0
|
存储 JSON 监控
Spring Cloud构建微服务架构:分布式配置中心【Dalston版】
Spring Cloud构建微服务架构:分布式配置中心【Dalston版】
97 0
|
消息中间件 监控 Java
Spring Cloud构建微服务架构:Hystrix监控数据聚合【Dalston版】
Spring Cloud构建微服务架构:Hystrix监控数据聚合【Dalston版】
123 0
Spring Cloud构建微服务架构:Hystrix监控数据聚合【Dalston版】
|
监控 前端开发 Java
Spring Cloud构建微服务架构:分布式服务跟踪(入门)【Dalston版】
Spring Cloud构建微服务架构:分布式服务跟踪(入门)【Dalston版】
107 0