2. 程式人生 > >Spring Cloud(七)：鏈路追蹤Sleuth-Zipkin與Mysql資料的持久化

Spring Cloud(七)：鏈路追蹤Sleuth-Zipkin與Mysql資料的持久化

阿新 • • 發佈：2019-02-07

一：回顧

上節我們瞭解到Spring Cloud Sleuth可以實現對服務的追蹤，以及和Zipkin結合，可以視覺化服務追蹤介面和依賴等相關資訊。遺憾的是資料不能持久化。

二：專案的構建

構建三個專案sleuth-stream-server,sleuth-stream-provider,sleuth-stream-consumer
前期準備:
下載rabbitMq，http://www.rabbitmq.com/
啟動rabbit服務,
這裡寫圖片描述

2.1:sleuth-stream-server構建
2.1.1:pom.xml

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.6.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>Dalston.SR2</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>

    <!--此依賴會自動引入spring-cloud-sleuth-stream並且引入zipkin的依賴包-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>
    </dependency>

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

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

    <!--儲存到資料庫需要如下依賴-->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</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>

2.1.2:application.properties 

server.port=9110
spring.application.name=zipkin-stream-server
#zipkin資料儲存到資料庫中需要進行如下配置
#表示當前程式不使用sleuth
spring.sleuth.enabled=false
#表示zipkin資料儲存方式是mysql
zipkin.storage.type=mysql
#資料庫指令碼建立地址，當有多個是可使用[x]表示集合第幾個元素
spring.datasource.schema[0]=classpath:/mysql.sql
#spring boot資料來源配置
    spring.datasource.url=jdbc:mysql://localhost:3306/sleuth_log?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.initialize=true
spring.datasource.continue-on-error=true


#rabbitmq配置
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

2.1.3:在classPath目錄下新建mysql.sql

CREATE TABLE IF NOT EXISTS zipkin_spans (
  `trace_id_high` BIGINT NOT NULL DEFAULT 0 COMMENT 'If non zero, this means the trace uses 128 bit traceIds instead of 64 bit',
  `trace_id` BIGINT NOT NULL,
  `id` BIGINT NOT NULL,
  `name` VARCHAR(255) NOT NULL,
  `parent_id` BIGINT,
  `debug` BIT(1),
  `start_ts` BIGINT COMMENT 'Span.timestamp(): epoch micros used for endTs query and to implement TTL',
      `duration` BIGINT COMMENT 'Span.duration(): micros used for minDuration and maxDuration query'
) ENGINE=InnoDB ROW_FORMAT=COMPRESSED CHARACTER SET=utf8 COLLATE utf8_general_ci;

ALTER TABLE zipkin_spans ADD UNIQUE KEY(`trace_id_high`, `trace_id`, `id`) COMMENT 'ignore insert on duplicate';
ALTER TABLE zipkin_spans ADD INDEX(`trace_id_high`, `trace_id`, `id`) COMMENT 'for joining with zipkin_annotations';
ALTER TABLE zipkin_spans ADD INDEX(`trace_id_high`, `trace_id`) COMMENT 'for getTracesByIds';
ALTER TABLE zipkin_spans ADD INDEX(`name`) COMMENT 'for getTraces and getSpanNames';
ALTER TABLE zipkin_spans ADD INDEX(`start_ts`) COMMENT 'for getTraces ordering and range';

CREATE TABLE IF NOT EXISTS zipkin_annotations (
  `trace_id_high` BIGINT NOT NULL DEFAULT 0 COMMENT 'If non zero, this means the trace uses 128 bit traceIds instead of 64 bit',
  `trace_id` BIGINT NOT NULL COMMENT 'coincides with zipkin_spans.trace_id',
  `span_id` BIGINT NOT NULL COMMENT 'coincides with zipkin_spans.id',
  `a_key` VARCHAR(255) NOT NULL COMMENT 'BinaryAnnotation.key or Annotation.value if type == -1',
  `a_value` BLOB COMMENT 'BinaryAnnotation.value(), which must be smaller than 64KB',
  `a_type` INT NOT NULL COMMENT 'BinaryAnnotation.type() or -1 if Annotation',
  `a_timestamp` BIGINT COMMENT 'Used to implement TTL; Annotation.timestamp or zipkin_spans.timestamp',
  `endpoint_ipv4` INT COMMENT 'Null when Binary/Annotation.endpoint is null',
  `endpoint_ipv6` BINARY(16) COMMENT 'Null when Binary/Annotation.endpoint is null, or no IPv6 address',
  `endpoint_port` SMALLINT COMMENT 'Null when Binary/Annotation.endpoint is null',
  `endpoint_service_name` VARCHAR(255) COMMENT 'Null when Binary/Annotation.endpoint is null'
) ENGINE=InnoDB ROW_FORMAT=COMPRESSED CHARACTER SET=utf8 COLLATE utf8_general_ci;

ALTER TABLE zipkin_annotations ADD UNIQUE KEY(`trace_id_high`, `trace_id`, `span_id`, `a_key`, `a_timestamp`) COMMENT 'Ignore insert on duplicate';
ALTER TABLE zipkin_annotations ADD INDEX(`trace_id_high`, `trace_id`, `span_id`) COMMENT 'for joining with zipkin_spans';
ALTER TABLE zipkin_annotations ADD INDEX(`trace_id_high`, `trace_id`) COMMENT 'for getTraces/ByIds';
ALTER TABLE zipkin_annotations ADD INDEX(`endpoint_service_name`) COMMENT 'for getTraces and getServiceNames';
ALTER TABLE zipkin_annotations ADD INDEX(`a_type`) COMMENT 'for getTraces';
ALTER TABLE zipkin_annotations ADD INDEX(`a_key`) COMMENT 'for getTraces';
ALTER TABLE zipkin_annotations ADD INDEX(`trace_id`, `span_id`, `a_key`) COMMENT 'for dependencies job';

CREATE TABLE IF NOT EXISTS zipkin_dependencies (
  `day` DATE NOT NULL,
  `parent` VARCHAR(255) NOT NULL,
  `child` VARCHAR(255) NOT NULL,
  `call_count` BIGINT,
  `error_count` BIGINT
) ENGINE=InnoDB ROW_FORMAT=COMPRESSED CHARACTER SET=utf8 COLLATE utf8_general_ci;

ALTER TABLE zipkin_dependencies ADD UNIQUE KEY(`day`, `parent`, `child`);

2.1.4:入口程式

@SpringBootApplication
@EnableZipkinStreamServer
public class SleuthStreamServerApplication {

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

@Bean
public MySQLStorage mySQLStorage(DataSource datasource) {
    return MySQLStorage.builder().datasource(datasource).executor(Runnable::run).build();
    }
}

3.1：sleuth-stream-provider
3.1.1:pom.xml

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.6.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>Dalston.SR2</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-sleuth-zipkin-stream</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-sleuth</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>

3.1.2:application.yml

server:
  port: 9111
spring:
  application:
    name: sleuth-stream-provider

 #rabbitmq配置
  rabbitmq:
    host: localhost
    username: guest
    password: guest

3.1.3: 程式入口

@SpringBootApplication
public class SleuthStreamProviderApplication {

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

3.1.4:提供一個服務

@RestController
public class SleuthProviderController {

private static final Logger LOGGER = LoggerFactory.getLogger(SleuthProviderController.class);

@GetMapping({"","/"})
public String index(){
    return "this is a spring-cloud sleuth provider!";
}

/**
 * 用來測試鏈路
 * @return
 */
@GetMapping("/index")
public String providerIndex(){
    LOGGER.info("<<<<<<<<<<<<<<<<trace sleuth demo provider is being called! >>>>>>>>>>>>>>>");
    return "Hello dy_bom ,this is a spring-cloud sleuth provider!";
        }
}

4.1：sleuth-stream-consumer
4.1.1:pom.xml

 <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>1.5.6.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>Dalston.SR2</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-sleuth-zipkin-stream</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-rabbit</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-sleuth</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>

4.1.2:application.yml

server:
  port: 9112
spring:
  application:
    name: sleuth-stream-consumer

#rabbitmq配置
  rabbitmq:
    host: localhost
    username: guest
    password: guest

4.1.3:程式入口

@SpringBootApplication
public class SleuthStreamConsumerApplication {

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

4.1.4:服務消費

@RestController
public class SleuthConsumerController {

private static final Logger LOGGER = LoggerFactory.getLogger(SleuthConsumerController.class);
@Autowired
private RestTemplate restTemplate;

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

/**
 * 專案說明
 * @return
 */
@GetMapping({"/",""})
public String index(){
    return "this is spring-cloud-sleuth-consumer";
}

/**
 * 遠端服務
 * @return
 */
@GetMapping( "/index")
public Object sleuthProviderIndex() {

    LOGGER.info("<<<<<<<<<<<<<<<<calling trace demo provider>>>>>>>>>>>>>>>");
    String str =  restTemplate.getForObject("http://localhost:9111/index", String.class);
    return str;
    }
 }

說明，從上面的配置可以看出，我們客戶端無須加入配置Server的地址。因為我們不是通過Http的Zipkin來收集資料。而是通過資料流Stream傳輸的。而且在這裡我們沒有配置它的手機採集率，即是預設的0.1。

三：專案的啟動

依次啟動專案Server端，服務提供端，服務消費端。
多次訪問：http://localhost:9112/index
這裡寫圖片描述
看日誌。解釋一下：
紅色部分分別表示服務名稱，traceId,spanId,boolean(代表是否進入了ZipKin)，由於我們沒設定採集率所以，你會發現很多false。
檢視資料庫是否入庫了：
這裡寫圖片描述
檢視zipKin管理頁面，檢視追蹤資訊
這裡寫圖片描述

可以看出描述的很詳細。

四：重啟Server端
重啟Server，檢視zipKin管理頁面，檢視追蹤資訊是否有歷史資料

相關推薦

Spring Cloud(七)：鏈路追蹤Sleuth-Zipkin與Mysql資料的持久化

一：回顧 上節我們瞭解到Spring Cloud Sleuth可以實現對服務的追蹤，以及和Zipkin結合，可以視覺化服務追蹤介面和依賴等相關資訊。遺憾的是資料不能持久化。 二：專案的構建 構建三個專案sleuth-stream-server,sleu

Spring Cloud 整合分散式鏈路追蹤系統Sleuth和ZipKin實戰，分析系統瓶頸

導讀 　　微服務架構中，是否遇到過這種情況，服務間呼叫鏈過長，導致效能遲遲上不去，不知道哪裡出問題了，巴拉巴拉....，迴歸正題，今天我們使用SpringCloud元件，來分析一下微服務架構中系統呼叫的瓶頸問題~ SpringCloud鏈路追蹤元件Sleuth實戰 官網 　　主要功能：做日誌埋點 什麼是S

Spring Boot + Spring Cloud 實現許可權管理系統 後端篇（二十二）：鏈路追蹤（Sleuth、Zipkin）

線上演示 演示地址：http://139.196.87.48:9002/kitty 使用者名稱：admin 密碼：admin 技術背景 在微服務架構中，隨著業務發展，系統拆分導致系統呼叫鏈路愈發複雜，一個看似簡單的前端請求可能最終需要呼叫很多次後端服務才能完成，那麼當整個請求出現問題時，我們很難得知到

spring cloud（七、鏈路追蹤）

Spring Cloud Sleuth 主要功能就是在分散式系統中提供追蹤解決方案，並且相容支援了 zipkin，zipkin為分散式鏈路呼叫監控系統，聚合各業務系統呼叫延遲資料，達到鏈路呼叫監控跟蹤。 隨著微服務數量不斷增長，它們之間的關係會越來越複雜，如果鏈路上任何一個服務出現問題或者網路超

Spring Cloud Sleuth--服務鏈路追蹤元件配置與使用

目標：使用Spring Cloud Sleuth建立服務鏈路追蹤中心開發環境：IntelliJ IDEA操作步驟：基礎環境配置->使用zipkin元件建立服務追蹤中心->使用Eureka/Zuul/Client構建服務註冊/閘道器/API功能->應用啟動測試

Spring Cloud（Finchley.RELEASE版本）微服務學習實踐：6.2全鏈路追蹤監控-Zipkin

環境：jdk1.8；spring boot2.0.3；spring cloud（Finchley.RELEASE版本）;Maven3.3摘要說明：Zipkin：Zipkin是一個分散式追蹤系統。它有助於收集解決微服務架構中的延遲問題所需的時序資料。它管理這些資料的收集和查詢。

Spring Cloud 分散式鏈路跟蹤 Sleuth + Zipkin + Elasticsearch

隨著業務越來越複雜，系統也隨之進行各種拆分，特別是隨著微服務架構的興起，看似一個簡單的應用，後臺可能很多服務在支撐；一個請求可能需要多個服務的呼叫；當請求遲緩或不可用時，無法得知是哪個微服務引起的，這時就需要解決如何快速定位服務故障點，Zipkin 分散式跟蹤系統就能很好的解決這樣的問題。 如果想學習Java

Spring Cloud 分散式鏈路跟蹤 Sleuth + Zipkin + Elasticsear

隨著業務越來越複雜，系統也隨之進行各種拆分，特別是隨著微服務架構的興起，看似一個簡單的應用，後臺可能很多服務在支撐；一個請求可能需要多個服務的呼叫；當請求遲緩或不可用時，無法得知是哪個微服務引起的，這時就需要解決如何快速定位服務故障點，Zipkin 分散式跟蹤系統就能很好的解決這樣的問題。 那麼到底怎麼使用

spring cloud(七)：Hystrix的應用

hystrix java 微服務 1、概念 熔斷器，容錯管理工具，旨在通過熔斷機制控制服務和第三方庫的節點,從而對延遲和故障提供更強大的容錯能力。除了熔斷的功能還有服務降級、線程和信號隔離、請求緩存、請求合並以及服務監控等強大功能。2、集成 a、工程的 pom.xml 的

SpringCloud學習記錄——Sleuth服務鏈路追蹤（Zipkin實現）

1、簡介。Spring Cloud Sleuth 主要功能就是在分散式系統中提供追蹤解決方案，並且相容支援了 zipkin，你只需要在pom檔案中引入相應的依賴即可。（呃呃，講人話就是：“既然是搞分散式微服務架構，那麼隨著專案的越來越大，微服務就會越來越多，微服務之間的呼叫會

《springcloud — Finchley.RELEASE版》第八篇 服務鏈路追蹤Sleuth

Sleuth簡述 微服務架構是通過業務來劃分服務的，對外暴露的介面，可能需要很多個服務協同才能完成一個介面功能，如果鏈路上任何一個服務出現問題，都會形成導致介面呼叫失敗。此時查找出現問題的微服務是很困難的。Spring Cloud Sleuth主要功能就是在分散式系統中提供

SpringCloud（7）服務鏈路追蹤Sleuth

1.簡介 Spring Cloud Sleuth 主要功能就是在分散式系統中提供追蹤解決方案，並且相容支援了 zipkin，你只需要在pom檔案中引入相應的依賴即可。本文主要講述服務追蹤元件zipkin，Spring Cloud Sleuth集成了zipkin元件。 2.術語 Span：基本工作單

分散式服務鏈路追蹤系統Zipkin學習記錄

Zipkin是一個分散式追蹤系統。它有助於收集解決微服務架構中延遲問題所需的時序資料。它管理這些資料的收集和查詢。Zipkin的設計基於Google Dapper論文。應用程式用於向Zipkin報告時間資料。Zipkin使用者介面還提供了一個依賴關係圖，顯示每個應用程式有多少

Spring Boot + Spring Cloud 構建微服務系統（八）：分散式鏈路追蹤（Sleuth、Zipkin）

技術背景 在微服務架構中，隨著業務發展，系統拆分導致系統呼叫鏈路愈發複雜，一個看似簡單的前端請求可能最終需要呼叫很多次後端服務才能完成，那麼當整個請求出現問題時，我們很難得知到底是哪個服務出了問題導致的，這時就需要解決一個問題，如何快速定位服務故障點，於是，分散式系統呼叫鏈追蹤技術就此誕生了。 ZipKin

第十八天：浪跡天涯網上商城(1.0版本)--引入spring cloud sleuth分散式鏈路追蹤

1、需求 我們都知道隨著專案的發展，各個底層的服務呼叫關係複雜，有時候因為某個服務的效能問題導致整個呼叫鏈出現故障，那麼排查問題是很困難的。現在我們引入Spring Cloud Sleuth分散式鏈路追蹤來解決這個問題。 2、Spring Cloud Sleut

spring cloud 入門系列八：使用spring cloud sleuth整合zipkin進行服務鏈路追蹤

好久沒有寫部落格了，主要是最近有些忙，今天忙裡偷閒來一篇。 =======我是華麗的分割線========== 微服務架構是一種分散式架構，微服務系統按照業務劃分服務單元，一個微服務往往會有很多個服務單元，一個請求往往會有很多個單元參與，一旦請求出現異常，想要去定位問題點真心不容易，因此需要有個東西去跟蹤

業余草 SpringCloud教程 | 第九篇: 服務鏈路追蹤(Spring Cloud Sleuth)(Finchley版本)

描述 -s util ont packaging tdd res [] 新建 這篇文章主要講述服務追蹤組件zipkin，Spring Cloud Sleuth集成了zipkin組件。 一、簡介 Add sleuth to the classpath of a Spr

全鏈路追蹤spring-cloud-sleuth-zipkin

authorize 采樣 quest child 手機號 main rgs lin oot 微服務架構下 多個服務之間相互調用，在解決問題的時候，請求鏈路的追蹤是十分有必要的，鑒於項目中采用的spring cloud架構，所以為了方便使用，便於接入等 項目中采用了sprin

SpringCloud2.0版本入門 | 服務鏈路追蹤(Spring Cloud Sleuth)簡單入門

本文出自 [ 慌途L ] 最近開始寫部落格，一些問題可能瞭解也不夠透徹，寫一下快速入門並且踩過的坑，希望大家少踩坑。本文簡單介紹一下springcloud的服務鏈路追蹤，不足之處希望大家指出，我改正。不喜勿噴！ 這篇文章主要講述服務追蹤元件zipkin，Spr

Spring Cloud Sleuth服務鏈路追蹤（mysql儲存鏈路資料）（Finchley版本）

在Spring Cloud Sleuth服務鏈路追蹤（Finchley版本）中，我們使用Spring Cloud Sleuth和zipkin的整合實現了服務鏈路的追蹤，但是遺憾的是鏈路資料儲存在記憶體中，無法持久化。zipkin的持久化可以結合Elasticsearch，MySQL實現。本節