首页 > 代码库 > SpringCloud Sleuth 使用

SpringCloud Sleuth 使用

2024-08-29 05:50:11   221人阅读

1. 介绍
  Spring-Cloud-Sleuth是Spring Cloud的组成部分之一，为SpringCloud应用实现了一种分布式追踪解决方案，其兼容了Zipkin, HTrace和log-based追踪
    相关说明： zipkin 
      Span：基本工作单元，例如，在一个新建的span中发送一个RPC等同于发送一个回应请求给RPC，span通过一个64位ID唯一标识，trace以另一个64位ID表示，span还有其他数据信息，比如摘要、时间戳事件、关键值注释(tags)、span的ID、以及进度ID(通常是IP地址)

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

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

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

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

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

   
2. 使用
    使用http://start.spring.io/  生成项目
    pom.xml  文件如下：
    
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. 	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. 	<modelVersion>4.0.0</modelVersion>
  6. 	<groupId>com.example</groupId>
  7. 	<artifactId>zipkinclient</artifactId>
  8. 	<version>0.0.1-SNAPSHOT</version>
  9. 	<packaging>jar</packaging>
  11. 	<name>zipkinclient</name>
  12. 	<description>Demo project for Spring Boot</description>
  14. 	<parent>
  15. 		<groupId>org.springframework.boot</groupId>
  16. 		<artifactId>spring-boot-starter-parent</artifactId>
  17. 		<version>1.4.3.RELEASE</version>
  18. 		<relativePath/> <!-- lookup parent from repository -->
  19. 	</parent>
  21. 	<properties>
  22. 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  23. 		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  24. 		<java.version>1.8</java.version>
  25. 	</properties>
  27. 	<dependencies>
  28. 		<dependency>
  29. 			<groupId>org.springframework.cloud</groupId>
  30. 			<artifactId>spring-cloud-starter-sleuth</artifactId>
  31. 		</dependency>
  32. 		<dependency>
  33. 			<groupId>org.springframework.cloud</groupId>
  34. 			<artifactId>spring-cloud-starter-zipkin</artifactId>
  35. 		</dependency>
  36. 		<dependency>
  37. 			<groupId>org.springframework.boot</groupId>
  38. 			<artifactId>spring-boot-starter-web</artifactId>
  39. 		</dependency>
  41. 		<dependency>
  42. 			<groupId>org.springframework.boot</groupId>
  43. 			<artifactId>spring-boot-starter-test</artifactId>
  44. 			<scope>test</scope>
  45. 		</dependency>
  46. 	</dependencies>
  48. 	<dependencyManagement>
  49. 		<dependencies>
  50. 			<dependency>
  51. 				<groupId>org.springframework.cloud</groupId>
  52. 				<artifactId>spring-cloud-dependencies</artifactId>
  53. 				<version>Camden.BUILD-SNAPSHOT</version>
  54. 				<type>pom</type>
  55. 				<scope>import</scope>
  56. 			</dependency>
  57. 		</dependencies>
  58. 	</dependencyManagement>
  60. 	<build>
  61. 		<plugins>
  62. 			<plugin>
  63. 				<groupId>org.springframework.boot</groupId>
  64. 				<artifactId>spring-boot-maven-plugin</artifactId>
  65. 			</plugin>
  66. 		</plugins>
  67. 	</build>
  69. 	<repositories>
  70. 		<repository>
  71. 			<id>spring-snapshots</id>
  72. 			<name>Spring Snapshots</name>
  73. 			<url>https://repo.spring.io/snapshot</url>
  74. 			<snapshots>
  75. 				<enabled>true</enabled>
  76. 			</snapshots>
  77. 		</repository>
  78. 		<repository>
  79. 			<id>spring-milestones</id>
  80. 			<name>Spring Milestones</name>
  81. 			<url>https://repo.spring.io/milestone</url>
  82. 			<snapshots>
  83. 				<enabled>false</enabled>
  84. 			</snapshots>
  85. 		</repository>
  86. 	</repositories>
  88. </project>

3. 编写调用service 
    都是spring rest  service   
    
  2. 	@RequestMapping("/demo")
  3. 	
  4. 	public String getinfo(){
  5. 		 LOG.log(Level.INFO, "RestDemo demo backend is being called");
  6. 		
  7. 		return "dalongdemo";
  8. 	}
  9. 	@Bean    //  此处可以使用配置说明
  10. 	public Sampler defaultSampler() {
  11. 		return new AlwaysSampler();
  12. 	}
  13. }
 
4. 调用方式：
    
  1. public class FirstController {
  2.   
  3. 	@Autowired
  4. 	public RestTemplate restTemplate;
  5. 	@RequestMapping("/first")
  6. 	public String  first(){
  7. 		
  8. 		
  9. 		String result=restTemplate.getForObject("http://localhost:8987/second", String.class);
  10. 		
  11. 		return "from [second]"+result;
  12. 		
  13. 		
  14. 	}
  15. 	@Bean
  16. 	public Sampler defaultSampler() {
  17. 		return new AlwaysSampler();
  18. 	}
  19. }
5. 配置zipkin 访问地址：
     application.properties
  1. server.port=8988
  2. spring.zipkin.base-url=http://XXXXXXX:9411
  3. spring.application.name=first

6. 启动服务
 mvn   spring-boot:run
7. 查看请求信息，以及服务依赖

  还是比较方便的，建议看看官方的例子以及说明文档：http://cloud.spring.io/spring-cloud-sleuth/1.0.x/
   技术分享
 
技术分享
 技术分享
 技术分享
 



  
   

  

SpringCloud Sleuth 使用


联系
我们