备案控制台
探索云世界
开发者社区 大数据 文章 正文

服务链路追踪---Sleuth

2018-04-26 1839
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： Sleuth：日志收集工具包，封装了Dapper和log-based追踪以及Zipkin和HTrace操作，为SpringCloud应用实现了一种分布式追踪解决方案。

Sleuth：日志收集工具包，封装了Dapper和log-based追踪以及Zipkin和HTrace操作，为SpringCloud应用实现了一种分布式追踪解决方案。

当服务与服务之间调用复杂时，SpringCloud Sleuth配合Zipkin提供的界面，可以直观的分析追踪数据，这篇文章介绍SpringCloud Sleuth与Zipkin配合使用。

新建Zipkin Server，加入zipkin依赖，pom文件如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.dalaoyang</groupId>
    <artifactId>springcloud_zipkin</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>springcloud_zipkin</name>
    <description>springcloud_zipkin</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Edgware.SR1</spring-cloud.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</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>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

配置文件只配置了一个端口号：

##端口号
server.port=9000

启动类加入注解@EnableZipkinServer，来声明是一个ZipkinServer，启动项目，可以看到控制的log已经变化了，如图

9953332-54a36a74c760ab97
image

然后在浏览器访问http://localhost:9000/zipkin/dependency/，如下图

9953332-17e4555d6c7d52d1
image

为了方便我们观察，分别创建了两个项目，first_service（9001），second_service（9002），pom文件加入spring-cloud-starter-zipkin依赖，
first_service（9001）pom文件代码如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.dalaoyang</groupId>
    <artifactId>springcloud_zipkin_firstservice</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>springcloud_zipkin_firstservice</name>
    <description>springcloud_zipkin_firstservice</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Edgware.SR1</spring-cloud.version>
    </properties>

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

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

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zipkin</artifactId>
            <version>1.3.1.RELEASE</version>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

配置文件，其中spring.zipkin.base-url指定zipkin server地址

server.port=9001
spring.zipkin.base-url=http://localhost:9000
spring.application.name=first_service

启动类加上@RestController注解方便测试，然后新建两个方法，一个用于被调用，一个调用其他，代码如下：

package com.dalaoyang;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@RestController
public class SpringcloudZipkinFirstserviceApplication {

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

    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

    @Value("${spring.application.name}")
    String serviceName;

    @RequestMapping("/callSecond")
    public String callSecond(){
        return restTemplate().getForObject("http://localhost:9002/second", String.class);
    }


    @RequestMapping("/first")
    public String first(){
        return serviceName;

    }
}

到这里first_service（9001）代码展示完成，接下来是second_service（9002）代码，内容不在赘述，和first_service（9001）类似。

pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.dalaoyang</groupId>
    <artifactId>springcloud_zipkin_secondservice</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>springcloud_zipkin_secondservice</name>
    <description>springcloud_zipkin_secondservice</description>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.9.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
        <java.version>1.8</java.version>
        <spring-cloud.version>Edgware.SR1</spring-cloud.version>
    </properties>

    <dependencies>
        <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>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zipkin</artifactId>
            <version>1.3.1.RELEASE</version>
        </dependency>
    </dependencies>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>${spring-cloud.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>


</project>

配置文件：

server.port=9002
spring.zipkin.base-url=http://localhost:9000
spring.application.name=second_service

启动类：

package com.dalaoyang;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@RestController
public class SpringcloudZipkinSecondserviceApplication {

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


    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

    @Value("${spring.application.name}")
    String serviceName;

    @RequestMapping("/second")
    public String second(){
        return serviceName;
    }

    @RequestMapping("/callFirst")
    public String callFirst(){
        return restTemplate().getForObject("http://localhost:9001/first",String.class);
    }
}

启动这两个项目，浏览器访问http://localhost:9001/callSecond，然后观看Zipkin Server页面，可以看到调用关系，请求细节等，如下图：

9953332-6ce3a4e59bf5ab21
image
9953332-52a1b88202106b1a
image
9953332-4e6ee8bdbb1d3b36
image
9953332-2781280af5dc6a08
image

源码下载 ：大老杨码云

个人网站：https://www.dalaoyang.cn

文章标签：
可观测链路 OpenTelemetry 版
负载均衡
数据格式
XML
关键词：
服务可观测链路 OpenTelemetry 版
可观测链路 OpenTelemetry 版sleuth
可观测链路 OpenTelemetry 版服务
服务可观测链路 OpenTelemetry 版sleuth
相关实践学习
分布式链路追踪Skywalking
Skywalking是一个基于分布式跟踪的应用程序性能监控系统，用于从服务和云原生等基础设施中收集、分析、聚合以及可视化数据，提供了一种简便的方式来清晰地观测分布式系统，具有分布式追踪、性能指标分析、应用和服务依赖分析等功能。 分布式追踪系统发展很快，种类繁多，给我们带来很大的方便。但在数据采集过程中，有时需要侵入用户代码，并且不同系统的 API 并不兼容，这就导致了如果希望切换追踪系统，往往会带来较大改动。OpenTracing为了解决不同的分布式追踪系统 API 不兼容的问题，诞生了 OpenTracing 规范。OpenTracing 是一个轻量级的标准化层，它位于应用程序/类库和追踪或日志分析程序之间。Skywalking基于OpenTracing规范开发，具有性能好，支持多语言探针，无侵入性等优势，可以帮助我们准确快速的定位到线上故障和性能瓶颈。 在本套课程中，我们将全面的讲解Skywalking相关的知识。从APM系统、分布式调用链等基础概念的学习加深对Skywalking的理解，从0开始搭建一套完整的Skywalking环境，学会对各类应用进行监控，学习Skywalking常用插件。Skywalking原理章节中，将会对Skywalking使用的agent探针技术进行深度剖析，除此之外还会对OpenTracing规范作整体上的介绍。通过对本套课程的学习，不止能学会如何使用Skywalking，还将对其底层原理和分布式架构有更深的理解。本课程由黑马程序员提供。
dalaoyang
目录
相关文章
hhzz
|
1月前
|
消息中间件 SpringCloudAlibaba Java
【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记（八）Config服务配置+bus消息总线+stream消息驱动+Sleuth链路追踪
【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记（八）Config服务配置+bus消息总线+stream消息驱动+Sleuth链路追踪
hhzz
778 0
赵广陆
|
7月前
|
数据可视化 Java Docker
Sleuth微服务链路追踪整合ELK和zipkin
Sleuth微服务链路追踪整合ELK和zipkin
赵广陆
194 0
一个风轻云淡
|
9月前
|
存储 监控 NoSQL
一文打通Sleuth+Zipkin 服务链路追踪
一文打通Sleuth+Zipkin 服务链路追踪
一个风轻云淡
79 0
编程达人
|
11月前
|
Dubbo 数据可视化 应用服务中间件
带你读《Apache Dubbo微服务开发从入门到精通》——三、 全链路追踪（1）
带你读《Apache Dubbo微服务开发从入门到精通》——三、 全链路追踪（1）
编程达人
138 0
编程达人
|
11月前
|
Dubbo 数据可视化 应用服务中间件
带你读《Apache Dubbo微服务开发从入门到精通》——三、 全链路追踪（2）
带你读《Apache Dubbo微服务开发从入门到精通》——三、 全链路追踪（2）
编程达人
84 0
编程达人
|
11月前
|
监控 Dubbo 数据可视化
带你读《Apache Dubbo微服务开发从入门到精通》——三、 全链路追踪（3）
带你读《Apache Dubbo微服务开发从入门到精通》——三、 全链路追踪（3）
编程达人
76 0
编程达人
|
11月前
|
监控 Dubbo 数据可视化
带你读《Apache Dubbo微服务开发从入门到精通》——三、 全链路追踪（4）
带你读《Apache Dubbo微服务开发从入门到精通》——三、 全链路追踪（4）
编程达人
198 0
马超伟
|
监控 网络协议 Java
分布式链路追踪- SkyWalking使用手册
分布式链路追踪- SkyWalking使用手册
马超伟
906 0
分布式链路追踪- SkyWalking使用手册
一只会写程序的猫
|
5月前
|
存储 监控 数据可视化
Golang链路追踪：实现高效可靠的分布式系统监控
Golang链路追踪：实现高效可靠的分布式系统监控
一只会写程序的猫
214 1
阿里云
|
5月前
|
消息中间件 监控 安全
RocketMQ x OpenTelemetry 分布式全链路追踪最佳实践(3)
RocketMQ x OpenTelemetry 分布式全链路追踪最佳实践
阿里云
58 0
RocketMQ x OpenTelemetry 分布式全链路追踪最佳实践(3)

热门文章

最新文章

  • 1
    【Springcloud Alibaba微服务分布式架构 | Spring Cloud】之学习笔记（八）Config服务配置+bus消息总线+stream消息驱动+Sleuth链路追踪
  • 2
    告别日志查询 | 阿里云发布链路追踪服务Tracing Analysis
  • 3
    进阶篇丨链路追踪（Tracing）很简单：链路成本指南
  • 4
    稳定性专题 | 通过链路追踪快速发现和定位业务问题的实践
  • 5
    使用篇丨链路追踪（Tracing）很简单：链路实时分析、监控与告警
  • 6
    SpringCloud Sleuth分布式请求链路追踪
  • 7
    分布式链路追踪- SkyWalking使用手册
  • 8
    链路追踪（Tracing）其实很简单——分布式链路追踪的应用与兴起
  • 9
    链路追踪（Tracing）其实很简单——分布式链路追踪的挑战与限制
  • 10
    Kubernetes + Spring Cloud 集成链路追踪 SkyWalking
  • 1
    skywalking全链路追踪
    41
  • 2
    原来10张图就可以搞懂分布式链路追踪系统原理
    192
  • 3
    开源链路追踪系统如何选型
    42
  • 4
    微服务框架（十六）Spring Boot及Dubbo zipkin 链路追踪组件埋点
    44
  • 5
    日志框架：基于Logback实现链路追踪
    261
  • 6
    微服务线上问题排查困难？不知道问题出在哪一环？那是你还不会分布式链路追踪
    79
  • 7
    Golang链路追踪：实现高效可靠的分布式系统监控
    214
  • 8
    基础篇丨链路追踪（Tracing）其实很简单（3）
    78
  • 9
    基础篇丨链路追踪（Tracing）其实很简单（2）
    79
  • 10
    基础篇丨链路追踪（Tracing）其实很简单（1）
    89

    • 相关课程

    更多
  • 业务全链路追踪最佳实践
  • 分布式链路追踪Skywalking

    • 相关电子书

    更多
  • Android内存泄露自动化链路分析组件——Probe
  • Android内存泄漏自动化链路分析组件--Probe
  • Android内存泄漏自动化链路分析组件Probe

    • 相关实验场景

    更多
  • 基于OpenTelemetry构建全链路追踪与监控
  • 日志服务之告警接入与管理
    • 下一篇
    阿里云oss简介和使用流程