(十七)、SpringCloud Sleuth分散式請求鏈路追蹤
阿新 • • 發佈:2021-10-01
Sleuth是什麼
為什麼會出現這個技術?要解決哪些問題?
在微服務框架中,一個由客戶端發起的請求在後端系統中會經過多個不同的的服務節點呼叫來協同產生最後的請求結果,每一個前段請求都會形成一條複雜的分散式服務呼叫鏈路,鏈路中的任何一環出現高延時或錯誤都會引起整個請求最後的失敗。
是什麼
- https://github.com/spring-cloud/spring-cloud-sleuth
- Spring Cloud Sleuth提供了一套完整的服務跟蹤的解決方案
- 在分散式系統中提供追蹤解決方案並且相容支援了zipkin
解決
Sleuth之zipkin搭建安裝
1.zipkin
下載
- SpringCloud從F版起已不需要自己構建Zipkin Server了,只需呼叫jar包即可
- https://dl.bintray.com/openzipkin/maven/io/zipkin/java/zipkin-server/
- zipkin-server-2.12.9-exec.jar
執行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