个人中心
gpt4 book ai didi

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

转载 作者：qq735679552 更新时间：2022-09-27 22:32:09 26 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章浅谈Spring-cloud 之 sleuth 服务链路跟踪由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

这篇文章主要讲述服务追踪组件zipkin，spring cloud sleuth集成了zipkin组件.

1、简介 。

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文件中引入相应的依赖即可.

2、服务追踪分析 。

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

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

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

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

3、术语 。

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注解的过程图形化:

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

4、构建工程 。

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

4.1 构建server-zipkin 。

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
<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的功能:

?
1
2
3
4
5
6
7
8
@springbootapplication
@enablezipkinserver
public class serverzipkinapplication {
 
  public static void main(string[] args) {
  springapplication.run(serverzipkinapplication. class , args);
  }
}

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

?
1
server.port= 9411

4.2 创建service-hi 。

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
<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”指定:

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

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

对外暴露接口:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
@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.

对外暴露接口:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
@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/，会出现以下界面:

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

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

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

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

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

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

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

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

原文链接：http://blog.csdn.net/forezp/article/details/70162074 。

最后此篇关于浅谈Spring-cloud 之 sleuth 服务链路跟踪的文章就讲到这里了,如果你想了解更多关于浅谈Spring-cloud 之 sleuth 服务链路跟踪的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

26 4 0
文章推荐： Jupyter安装nbextensions,启动提示没有nbextensions库
文章推荐： spring事务异常回滚实例解析
文章推荐： python+opencv识别图片中的圆形
文章推荐： 使用公共电脑时需注意的安全事项有哪些
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com