rabbitmq+sleuth+zinkip 分布式鏈路追蹤-有解無憂

我們都知道，微服務之間通過feign傳遞，在復雜的微服務架構系統中，幾乎每一個前端請求都會形成一個復雜的分布式服務呼叫鏈路，在每條鏈路中任何一個依賴服務出現延遲超時或者錯誤都有可能引起整個請求最后的失敗，當業務流程足夠復雜時，一個完整的HTTP請求呼叫鏈一般會經過多個微服務系統，要通過日志來跟蹤一整個呼叫鏈變得不再那么簡單，通過sleuth可以很方便的看出每個采集請求的耗時情況，分析出哪些服務呼叫比較耗時，當服務呼叫的耗時隨著請求量的增大而增大時，可以針對業務做一些優化措施，所以我們可以通過我們可以通過Spring Cloud Sleuth來解決這個問題，這里我們將演示如何通過Spring Cloud Sleuth來追蹤這個程序，并借助Zipkin以圖形化界面的方式展示，展示之前，分別介紹一下rabbitmq、sleuth、zinkip，

rabbitmq
- RabbitMQ是實作了高級訊息佇列協議（AMQP）的開源訊息代理軟體（亦稱面向訊息的中間件），RabbitMQ服務器是用Erlang語言撰寫的，而群集和故障轉移是構建在開放電信平臺框架上的，所有主要的編程語言均有與代理介面通訊的客戶端庫，
sleuth和zinkip
- sleuth 是spring cloud的組成部分之一，為springcloud應用實作了一種分布式追蹤解決方案，其兼容了zinkip,HTrace和log-based追蹤
- Zipkin 是一款開源的分布式實時資料追蹤系統（Distributed Tracking System），基于 Google Dapper 的論文設計而來，由 Twitter公司開發貢獻，其主要功能是聚集來自各個異構系統的實時監控資料，用來追蹤微服務架構下的系統延時問題，Zipkin 的用戶界面可以呈現一幅關聯圖表，以顯示有多少被追蹤的請求通過了每一層應用，Zipkin 以 Trace 結構表示對一次請求的追蹤，又把每個 Trace 拆分為若干個有依賴關系的 Span，在微服務架構中，一次用戶請求可能會由后臺若干個服務負責處理，那么每個處理請求的服務就可以理解為一個 Span（可以包括 API 服務，快取服務，資料庫服務以及報表服務等），當然這個服務也可能繼續請求其他的服務，因此 Span 是一個樹形結構，以體現服務之間的呼叫關系，Zipkin 的用戶界面除了可以查看 Span 的依賴關系之外，還以瀑布圖的形式顯示了每個 Span 的耗時情況，可以一目了然的看到各個服務的性能狀況，

sleuth中的一些術語

Span：基本作業單元，例如，在一個新建的span中發送一個RPC等同于發送一個回應請求給RPC，span通過一個64位ID唯一標識，trace以另一個64位ID表示，span還有其他資料資訊，比如摘要、時間戳事件、關鍵值注釋(tags)、span的ID、以及進度ID(通常是IP地址) ,span在不斷的啟動和停止，同時記錄了時間資訊，當你創建了一個span，你必須在未來的某個時刻停止它，

Trace：一系列spans組成的一個樹狀結構，例如，如果你正在跑一個分布式工程，你可能需要創建一個trace，

Annotation：用來及時記錄一個事件的存在，一些核心annotations用來定義一個請求的開始和結束

cs - Client Sent -客戶端發起一個請求，這個annotion描述了這個span的開始

sr - Server Received -服務端獲得請求并準備開始處理它，如果將其sr減去cs時間戳便可得到網路延遲

ss - Server Sent -注解表明請求處理的完成(當請求回傳客戶端)，如果ss減去sr時間戳便可得到服務端需要的處理請求時間

cr - Client Received -表明span的結束，客戶端成功接收到服務端的回復，如果cr減去cs時間戳便可得到客戶端從服務端獲取回復的所有所需時間

接下來就開始搭建
這里cloud版本用的Greenwich.SR1，boot使用的是2.1.6

1.在pom.xml中引入sleuth依賴

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

2.模擬兩個日志這兩個服務之間通過feign呼叫，由test呼叫system，這里本來有一個注冊中心，這里就不在演示了

test模塊

@Slf4j
@RestController
public class TestController {

	@Autowired
	private IHelloService helloService;

	@GetMapping("hello")
	public String hello(String name) {
    log.info("Feign呼叫system的/hello服務");
    return this.helloService.hello(name);
   }
}

在test模塊的service包下創建IHelloService

@FeignClient(value = https://www.cnblogs.com/yychuyu/p/"system",contextId = "helloServiceClient")
public interface IHelloService {
	@GetMapping("hello")
	String hello(@RequestParam("name") String name);
}

system 模塊

@Slf4j
@RestController
public class TestController {

	@GetMapping("hello")
	public String hello(String name) {
   		log.info("/hello服務被呼叫");
    	return "hello" + name;
	}
}

3.訪問介面 localhost:8202/test/hello?name=sleuth：會出現兩個我們自定義的日志

啟動的時候查看test模塊產生的

2019-08-23 14:22:51.774  INFO [test,72bb0469bee07104,72bb0469bee07104,false] 22728 --- [nio-8202-exec-1] c.m.f.s.test.controller.TestController   : Feign呼叫system的/hello服務

啟動的時候查看system模塊產生的

2019-08-23 14:22:52.469  INFO [system,72bb0469bee07104,43597a6edded6f2e,false] 812 --- [nio-8201-exec-2] c.m.f.s.s.controller.TestController      : /hello服務被呼叫

可以看到，日志里出現了[Test,72bb0469bee07104,72bb0469bee07104,false]資訊，這些資訊由Spring Cloud Sleuth生成，用于跟蹤微服務請求鏈路，這些資訊包含了4個部分的值，它們的含義如下：

system微服務的名稱，與spring.application.name對應；
72bb0469bee07104稱為Trace ID，在一條完整的請求鏈路中，這個值是固定的，觀察上面的日志即可證實這一點；
43597a6edded6f2e稱為Span ID，它表示一個基本的作業單元；
false表示是否要將該資訊輸出到Zipkin等服務中來收集和展示，這里我們還沒有集成Zipkin，所以為false，

下面我們來整合Zipkin

在整合Zipkin之前，我們需要先搭建RabbitMQ，RabbitMQ用于收集Sleuth提供的追蹤資訊，然后Zipkin Server從RabbitMQ里獲取，這樣可以提升性能，

在安裝RabbitMQ之前，需要先安裝Erlang/OTP，下載地址為：http://www.erlang.org/downloads/，下載exe檔案安裝即可，
安裝完畢后，下載RabbitMQ，下載地址為：
http://www.rabbitmq.com/install-windows.html，下載exe檔案安裝即可，

安裝完RabbitMQ之后，我們到RabbitMQ安裝目錄的sbin下執行如下命令

rabbitmq-plugins enable rabbitmq_management

然后在瀏覽器中輸入http://localhost:15672，默認用戶名和密碼都是guest，登錄后可看到:

點擊Admin Tab頁面，新增一個用戶：

用戶名為febs，密碼為123456，角色為管理員，新添加的用戶還是No access狀態，需要進一步對該用戶進行授權后，方可以遠程通過該用戶名訪問，點擊該新增用戶名，進入授權頁面，點擊Set permission按鈕，進行用戶授權操作，
安裝好RabbitMQ后，我們開始整合Zipkin，在較低版本的Spring Cloud中，我們可以自己搭建Zipkin Server，現在我們只能使用官方搭建好的Zipkin Server，地址為：https://github.com/openzipkin/zipkin

在cmd視窗下運行下面這條命令（windows下沒有curl環境的話，可以在git bash中運行這條命令），下載zipkin.jar：

curl -sSL https://zipkin.io/quickstart.sh | bash -s

如果下載速度極慢，可以復制鏈接到迅雷下載中下載，下載后重命名為zipkin.jar即可，

zipkin支持將追蹤資訊保存到MySQL資料庫，所以在運行zipkin.jar之前，我們先準備好相關庫表，SQL腳本地址為：

https://github.com/openzipkin/zipkin/blob/master/zipkin-storage/mysql-v1/src/main/resources/mysql.sql，

庫表準備好后，運行下面這條命令啟動zipkin.jar：

java -jar zipkin.jar --server.port=8402 --zipkin.storage.type=mysql --zipkin.storage.mysql.db=febs_cloud_base --zipkin.storage.mysql.username=root --zipkin.storage.mysql.password=123456 --zipkin.storage.mysql.host=localhost --zipkin.storage.mysql.port=3306 --zipkin.collector.rabbitmq.addresses=localhost:5672 --zipkin.collector.rabbitmq.username=febs --zipkin.collector.rabbitmq.password=123456

上面命令指定了資料庫鏈接和RabbitMQ鏈接資訊，更多可選配置可以解壓zipkin.jar，查看zipkin\BOOT-INF\classes路徑下的zipkin-server-shared.yml配置類原始碼，

啟動好zipkin.jar后，在對應模塊的pom里引入如下依賴：

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

修改對應模塊的application.yml

spring:
  zipkin:
    sender:
  	  type: rabbit
  sleuth:
    sampler:
      probability: 1
  rabbitmq:
    host: localhost
    port: 5672
    username: febs
    password: 123456

spring.zipkin.sender.type指定了使用RabbitMQ收集追蹤資訊；

spring.sleuth.sampler.probability默認值為0.1，即采樣率才1/10，發送10筆請求只有一筆會被采集，為了測驗方便，我們可以將它設定為1，即100%采樣；

spring.rabbitmq用于配置RabbitMQ連接資訊，你可能會問，為什么剛剛RabbitMQ埠是15672，這里卻配置為5672，是不是寫錯了呢？其實不是，15672是RabbitMQ的管理頁面埠，5672是AMPQ埠，

添加好配置后，啟動system和test模塊，發送一筆localhost:8202/test/hello?name=夏天請求后，使用瀏覽器訪問http://localhost:8402/zipkin/鏈接,然后點擊圖中所示

查看依賴關系：

查看資料表，看是否存盤了資訊：

公眾號：良許Linux

有識訓？希望老鐵們來個三連擊，給更多的人看到這篇文章

轉載請註明出處，本文鏈接：https://www.uj5u.com/caozuo/33312.html

標籤：Linux

上一篇：Cento7 將每小時SSH暴力破解（登陸失敗）超過10次的ip加入系統黑名單----系統安全篇

下一篇：CentOS 7 安裝 libcurl with openssl；Ubuntu 安裝 libcurl with openssl