Spring Cloud Zipkin 和 Sleuth 使用教程

演示项目源码下载：（访问密码：9987）
spring-cloud-zipkin.zip

Zipkin是非常有效的工具分布追踪在微服务生态系统。分布式跟踪通常是分布式事务中每个组件的延迟测量，其中调用多个微服务来为单个业务用例提供服务。假设在我们的应用程序中，我们必须为一个事务调用 4 个不同的服务/组件。在启用分布式跟踪的情况下，我们可以测量哪个组件花费了多少时间。

当涉及许多底层系统并且应用程序在任何特定情况下变慢时，这在调试期间非常有用。在这种情况下，我们首先需要确定哪个底层服务实际上很慢。一旦发现服务缓慢，我们就可以努力解决该问题。分布式跟踪有助于识别生态系统中的缓慢组件。
 

Zipkin

1. 收集器——一旦任何组件将跟踪数据发送到 Zipkin 收集器守护进程，它就会被 Zipkin 收集器验证、存储和索引以进行查找。
2. 存储- 该模块在后端存储和索引查找数据。支持 Cassandra、ElasticSearch和MySQL。
3. 搜索- 该模块提供了一个简单的 JSON API，用于查找和检索存储在后端的跟踪。此 API 的主要使用者是 Web UI。
4. Web UI – 一个非常漂亮的 UI 界面，用于查看跟踪。

如何安装 Zipkin

java -jar zipkin-server-1.30.3-exec.jar

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

Sleuth

• 使用RestTemplate等发出的请求。
• 通过Netflix Zuul微代理的请求
• 在Spring MVC控制器接收到的 HTTP 标头
• 通过消息传递技术（如 Apache Kafka 或 RabbitMQ 等）发出请求。

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

Zipkin 和 Sleuth 集成示例

创建微服务

import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.sleuth.sampler.AlwaysSampler;
import org.springframework.context.annotation.Bean;
import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.HttpMethod;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
 
@SpringBootApplication
public class ZipkinService1Application {
 
    public static void main(String[] args) {
        SpringApplication.run(ZipkinService1Application.class, args);
    }
}
 
@RestController
class ZipkinController{
     
    @Autowired
    RestTemplate restTemplate;
 
    @Bean
    public RestTemplate getRestTemplate() {
        return new RestTemplate();
    }
 
    @Bean
    public AlwaysSampler alwaysSampler() {
        return new AlwaysSampler();
    }
 
    private static final Logger LOG = Logger.getLogger(ZipkinController.class.getName());
     
    @GetMapping(value="/zipkin")
    public String zipkinService1() 
    {
        LOG.info("Inside zipkinService 1..");
         
         String response = (String) restTemplate.exchange("http://localhost:8082/zipkin2", 
                        HttpMethod.GET, null, new ParameterizedTypeReference<String>() {}).getBody();
        return "Hi...";
    }
}

应用程序配置

server.port = 8081
spring.application.name = zipkin-server1

演示

要快速启动和停止，请使用 bat 文件Start-all.bat和Stop-all.bat.

总结

演示项目源码下载：（访问密码：9987）
spring-cloud-zipkin.zip

Spring Cloud Zipkin Spring Cloud Zipkin Sleuth Spring Cloud

https://www.leftso.com/article/858.html