1. 程式人生 > 其它 >(十七)、SpringCloud Sleuth分散式請求鏈路追蹤

(十七)、SpringCloud Sleuth分散式請求鏈路追蹤

Sleuth是什麼

為什麼會出現這個技術?要解決哪些問題?

在微服務框架中,一個由客戶端發起的請求在後端系統中會經過多個不同的的服務節點呼叫來協同產生最後的請求結果,每一個前段請求都會形成一條複雜的分散式服務呼叫鏈路,鏈路中的任何一環出現高延時或錯誤都會引起整個請求最後的失敗。

是什麼

解決

Sleuth之zipkin搭建安裝

1.zipkin

下載

執行jar

java -jar zipkin-server-2.12.9-exec.jar

執行控制檯

http://localhost:9411/zipkin/

術語

完整的呼叫鏈路

表示一請求鏈路,一條鏈路通過Trace ld唯一標識,Span標識發起的請求資訊,各span通過parent id關聯起來

—條鏈路通過Trace ld唯一標識,Span標識發起的請求資訊,各span通過parent id關聯起來。

整個鏈路的依賴關係如下:

名詞解釋

  • Trace:類似於樹結構的Span集合,表示一條呼叫鏈路,存在唯一標識
  • span:表示呼叫鏈路來源,通俗的理解span就是一次請求資訊

Sleuth鏈路監控展現

服務提供者cloud-provider-payment8001

POM

<!--包含了sleuth+zipkin-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>

YML

server:
  port: 8001

spring:
  application:
    name: cloud-payment-service
  zipkin: #<-------------------------------------關鍵
    base-url: http://localhost:9411
    sleuth: #<-------------------------------------關鍵
      sampler:
      #取樣率值介於 0 到 1 之間,1 則表示全部採集
      probability: 1

  datasource:
    type: com.alibaba.druid.pool.DruidDataSource            # 當前資料來源操作型別
    driver-class-name: com.mysql.jdbc.Driver      # mysql驅動包
    url: jdbc:mysql://waiwanga.mysql.rds.aliyuncs.com:3306/student?useUnicode=true&characterEncoding=utf-8&useSSL=false
    username: root
    password: xxxx

mybatis:
  mapperLocations: classpath:mapper/*.xml
  type-aliases-package: com.ylc.cloud.entities    # 所有Entity別名類所在包

eureka:
  client:
    #表示是否將自己註冊進Eurekaserver預設為true。
    register-with-eureka: true
    #是否從EurekaServer抓取已有的註冊資訊,預設為true。單節點無所謂,叢集必須設定為true才能配合ribbon使用負載均衡
    fetchRegistry: true
    service-url:
      #defaultZone: http://localhost:7001/eureka
       defaultZone: http://eureka7001.com:7001/eureka, http://eureka7002.com:7002/eureka
  instance:
    instance-id: payment8001 #新增此處
    prefer-ip-address: true #新增此處
    #心跳檢測與續約時間
    #開發時沒置小些,保證服務關閉後註冊中心能即使剔除服務
    #Eureka客戶端向服務端傳送心跳的時間間隔,單位為秒(預設是30秒)
    lease-renewal-interval-in-seconds: 1
    #Eureka服務端在收到最後一次心跳後等待時間上限,單位為秒(預設是90秒),超時將剔除服務
    lease-expiration-duration-in-seconds: 2

業務類PaymentController

    @GetMapping("/payment/zipkin")
    public String paymentZipkin() {
        return "hi ,i'am paymentzipkin server fall back,welcome to here, O(∩_∩)O哈哈~";
    }

服務消費者(呼叫方)cloue-consumer-order80

POM

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

YML

spring:
    application:
        name: cloud-order-service
    zipkin:
      base-url: http://localhost:9411
    sleuth:
      sampler:
        probability: 1

業條類OrderController

    @GetMapping("/consumer/payment/zipkin")
    public String paymentZipkin()
    {
        String result = restTemplate.getForObject("http://localhost:8001"+"/payment/zipkin/", String.class);
        return result;
    }

4.依次啟動eureka7001/8001/80 - 80呼叫8001幾次測試下

5.開啟瀏覽器訪問: http://localhost:9411