脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Spring-cloud 服务跟踪

浅谈Spring-cloud 之 sleuth 服务链路跟踪

 更新时间：2018年01月04日 10:41:49   作者：方志朋  
本篇文章主要介绍了浅谈Spring-cloud 之 sleuth 服务链路跟踪，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧

这篇文章主要讲述服务追踪组件zipkin，Spring Cloud Sleuth集成了zipkin组件。

一、简介

Add sleuth to the classpath of a Spring Boot application (see below for Maven and Gradle examples), and you will see the correlation data being collected in logs, as long as you are logging requests.

—— 摘自官网

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

二、服务追踪分析

微服务架构上通过业务来划分服务的，通过REST调用，对外暴露的一个接口，可能需要很多个服务协同才能完成这个接口功能，如果链路上任何一个服务出现问题或者网络超时，都会形成导致接口调用失败。随着业务的不断扩张，服务之间互相调用会越来越复杂。

Paste_Image.png

随着服务的越来越多，对调用链的分析会越来越复杂。它们之间的调用关系也许如下：

Paste_Image.png

三、术语

Span：基本工作单元，例如，在一个新建的span中发送一个RPC等同于发送一个回应请求给RPC，span通过一个64位ID唯一标识，trace以另一个64位ID表示，span还有其他数据信息，比如摘要、时间戳事件、关键值注释(tags)、span的ID、以及进度ID(通常是IP地址)

span在不断的启动和停止，同时记录了时间信息，当你创建了一个span，你必须在未来的某个时刻停止它。

Trace：一系列spans组成的一个树状结构，例如，如果你正在跑一个分布式大数据工程，你可能需要创建一个trace。

Annotation：用来及时记录一个事件的存在，一些核心annotations用来定义一个请求的开始和结束

  1. cs - Client Sent -客户端发起一个请求，这个annotion描述了这个span的开始
  2. sr - Server Received -服务端获得请求并准备开始处理它，如果将其sr减去cs时间戳便可得到网络延迟
  3. ss - Server Sent -注解表明请求处理的完成(当请求返回客户端)，如果ss减去sr时间戳便可得到服务端需要的处理请求时间
  4. cr - Client Received -表明span的结束，客户端成功接收到服务端的回复，如果cr减去cs时间戳便可得到客户端从服务端获取回复的所有所需时间

将Span和Trace在一个系统中使用Zipkin注解的过程图形化：

Paste_Image.png

四、构建工程

基本知识讲解完毕，下面我们来实战，本文的案例主要有三个工程组成:一个server-zipkin,它的主要作用使用ZipkinServer 的功能，收集调用数据，并展示；一个service-hi,对外暴露hi接口；一个service-miya,对外暴露miya接口；这两个service可以相互调用；并且只有调用了，server-zipkin才会收集数据的，这就是为什么叫服务追踪了。

4.1 构建server-zipkin

建一个spring-boot工程取名为server-zipkin，在其pom引入依赖：

<dependencies>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter</artifactId>
 </dependency>

 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>
  <scope>test</scope>
 </dependency>

 <dependency>
  <groupId>io.zipkin.java</groupId>
  <artifactId>zipkin-server</artifactId>
 </dependency>

 <dependency>
  <groupId>io.zipkin.java</groupId>
  <artifactId>zipkin-autoconfigure-ui</artifactId>
 </dependency>

 </dependencies>

 <dependencyManagement>
 <dependencies>
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-dependencies</artifactId>
  <version>Camden.SR6</version>
  <type>pom</type>
  <scope>import</scope>
  </dependency>
 </dependencies>
 </dependencyManagement>

在其程序入口类, 加上注解@EnableZipkinServer，开启ZipkinServer的功能：

@SpringBootApplication
@EnableZipkinServer
public class ServerZipkinApplication {

 public static void main(String[] args) {
 SpringApplication.run(ServerZipkinApplication.class, args);
 }
}

在配置文件application.yml指定服务端口为：

server.port=9411

4.2 创建service-hi

在其pom引入起步依赖spring-cloud-starter-zipkin，代码如下：

<dependencies>

 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
 </dependency>
 <!--compile('org.springframework.cloud:spring-cloud-starter-zipkin')-->

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

 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>
  <scope>test</scope>
 </dependency>
 </dependencies>

 <dependencyManagement>
 <dependencies>
  <dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-dependencies</artifactId>
  <version>Dalston.RC1</version>
  <type>pom</type>
  <scope>import</scope>
  </dependency>
 </dependencies>
 </dependencyManagement>

在其配置文件application.yml指定zipkin server的地址，头通过配置“spring.zipkin.base-url”指定：

server.port=8988
spring.zipkin.base-url=http://localhost:9411
spring.application.name=service-hi

通过引入spring-cloud-starter-zipkin依赖和设置spring.zipkin.base-url就可以了。

对外暴露接口：

@SpringBootApplication
@RestController
public class ServiceHiApplication {

 public static void main(String[] args) {
 SpringApplication.run(ServiceHiApplication.class, args);
 }

 private static final Logger LOG = Logger.getLogger(ServiceHiApplication.class.getName());


 @Autowired
 private RestTemplate restTemplate;

 @Bean
 public RestTemplate getRestTemplate(){
 return new RestTemplate();
 }

 @RequestMapping("/hi")
 public String callHome(){
 LOG.log(Level.INFO, "calling trace service-hi ");
 return restTemplate.getForObject("http://localhost:8989/miya", String.class);
 }
 @RequestMapping("/info")
 public String info(){
 LOG.log(Level.INFO, "calling trace service-hi ");

 return "i'm service-hi";

 }

 @Bean
 public AlwaysSampler defaultSampler(){
 return new AlwaysSampler();
 }
}

4.3 创建service-miya

创建过程痛service-hi，引入相同的依赖，配置下spring.zipkin.base-url。

对外暴露接口：

@SpringBootApplication
@RestController
public class ServiceMiyaApplication {

 public static void main(String[] args) {
 SpringApplication.run(ServiceMiyaApplication.class, args);
 }

 private static final Logger LOG = Logger.getLogger(ServiceMiyaApplication.class.getName());


 @RequestMapping("/hi")
 public String home(){
 LOG.log(Level.INFO, "hi is being called");
 return "hi i'm miya!";
 }

 @RequestMapping("/miya")
 public String info(){
 LOG.log(Level.INFO, "info is being called");
 return restTemplate.getForObject("http://localhost:8988/info",String.class);
 }

 @Autowired
 private RestTemplate restTemplate;

 @Bean
 public RestTemplate getRestTemplate(){
 return new RestTemplate();
 }
}

4.4 启动工程，演示追踪

依次启动上面的三个工程，打开浏览器访问：http://localhost:9411/，会出现以下界面：

Paste_Image.png

访问：http://localhost:8989/miya，浏览器出现：i'm service-hi

再打开http://localhost:9411/的界面，点击Dependencies,可以发现服务的依赖关系：

Paste_Image.png

点击find traces,可以看到具体服务相互调用的数据：

Paste_Image.png

本文源码下载： https://github.com/forezp/SpringCloudLearning/tree/master/chapter9

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • 详解Mybatis分页插件 - 示例代码

    详解Mybatis分页插件 - 示例代码

    这篇文章主要介绍了详解Mybatis分页插件 - 示例代码,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧。
    2016-12-12
  • Java利用DFA算法实现敏感词管理

    Java利用DFA算法实现敏感词管理

    我们在完成一些文章发布的功能是,可以使用第三方工具如阿里云的内容安全来进行文章的审核,但是这个第三方接口并不能过滤一些敏感词,所以本文就来讲讲如何通过DFA算法就行敏感词管理吧
    2024-11-11
  • Windows下如何安装配置Redis环境

    Windows下如何安装配置Redis环境

    这篇文章主要介绍了Windows下如何安装配置Redis环境,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-12-12
  • Java8新特性Stream的完全使用指南

    Java8新特性Stream的完全使用指南

    这篇文章主要给大家介绍了关于Java8新特性Stream的完全使用指南，文中通过示例代码介绍的非常详细，对大家学习或者使用Java8具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
    2020-05-05
  • Java中List集合对象去重及按属性去重的8种方法

    Java中List集合对象去重及按属性去重的8种方法

    这篇文章主要介绍了Java中List集合对象去重及按属性去重的8种方法,本文给大家介绍的非常详细，对大家的学习或工作具有一地的参考借鉴价值，需要的朋友可以参考下
    2020-09-09
  • 一文详解Java闭锁和栅栏的实现

    一文详解Java闭锁和栅栏的实现

    闭锁与栅栏是在多线程编程中的概念，因为在多线程中，我们不能控制线程的执行状态，所以给线程加锁，让其按照我们的想法有秩序的执行。本文将详解Java闭锁和栅栏的实现，需要的可以参考一下
    2022-06-06
  • JavaFX Application应用实例

    JavaFX Application应用实例

    下面小编就为大家带来一篇JavaFX Application应用实例。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2016-10-10
  • Java将本地项目部署到Linux服务器的实践

    Java将本地项目部署到Linux服务器的实践

    本文主要介绍了Java将本地项目部署到Linux服务器的实践，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧<BR>
    2022-06-06
  • 详解Jmeter中的BeanShell脚本

    详解Jmeter中的BeanShell脚本

    BeanShell是一种完全符合Java语法规范的脚本语言,并且又拥有自己的一些语法和方法，所以它和java是可以无缝衔接的，学了Java的一些基本语法后，就可以来在Jmeter中写写BeanShell脚本了
    2021-12-12
  • 详解mybatis 批量更新数据两种方法效率对比

    详解mybatis 批量更新数据两种方法效率对比

    这篇文章主要介绍了详解mybatis 批量更新数据两种方法效率对比，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-02-02

最新评论