這篇文章主要介紹了SpringBoot2.0中ZipKin的示例分析，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。
Zipkin是一種分布式跟蹤系統。它有助于收集解決微服務架構中延遲問題所需的時序數據。它管理這些數據的收集和查找。Zipkin的設計基于 Google Dapper論文。
應用程序用于向Zipkin報告時間數據。Zipkin用戶界面還提供了一個依賴關系圖，顯示每個應用程序有多少跟蹤請求。如果您正在解決延遲問題或錯誤問題，則可以根據應用程序，跟蹤長度，注釋或時間戳過濾或排序所有跟蹤。選擇跟蹤后，您可以看到每個跨度所需的總跟蹤時間百分比，從而可以識別問題應用程序。
這是翻譯過來的原意，自己在這里想如果有個調用鏈，我們自己該怎么實現。要去質疑任何代碼。
官方流程圖：最關鍵的是Transport這個地方，通過幾種方式傳輸給Conllector。如何在這里支持多種協議，有興趣的可以進去看看源碼。
開始示例，在這里通過一個項目調用不同的方法來進行測試。
先下載Zipkin的web UI，通過java -jar zipkin.jar執行
項目結構：
pom.xml
<dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <!-- zipkin--> <dependency> <groupId>io.zipkin.brave</groupId> <artifactId>brave-core</artifactId> <version>3.10.0</version> </dependency> <dependency> <groupId>io.zipkin.brave</groupId> <artifactId>brave-spancollector-http</artifactId> <version>3.10.0</version> </dependency> <dependency> <groupId>io.zipkin.brave</groupId> <artifactId>brave-web-servlet-filter</artifactId> <version>3.10.0</version> </dependency> <dependency> <groupId>io.zipkin.brave</groupId> <artifactId>brave-okhttp</artifactId> <version>3.10.0</version> </dependency> <!-- zipkin-->
application.properties
server.port=9000 ##########請求的項目名########## server.servlet.context-path=/zipkinTest ##########zipKin################ zipkin.serviceName=zipkin-test zipkin.url=http://localhost:9411 zipkin.connectTimeout=6000 zipkin.readTimeout=6000 zipkin.flushInterval=1 zipkin.compressionEnabled=true
server.port 訪問端口號
server.servlet.context-path 訪問項目名
zipkin.serviceName 服務名
zipkin.url Zipkin的web ui訪問地址
zipkin.connectTimeout 連接時間
zipkin.readTimeout 讀數據時間
zipkin.flushInterval 采集率
zipkin.compressionEnabled 是否壓縮
ZipkinProperties.java
package com.cms.zipkin;
import com.github.kristofa.brave.Brave;
import com.github.kristofa.brave.EmptySpanCollectorMetricsHandler;
import com.github.kristofa.brave.Sampler;
import com.github.kristofa.brave.SpanCollector;
import com.github.kristofa.brave.http.DefaultSpanNameProvider;
import static com.github.kristofa.brave.Brave.Builder;
import static com.github.kristofa.brave.http.HttpSpanCollector.Config;
import static com.github.kristofa.brave.http.HttpSpanCollector.create;
import com.github.kristofa.brave.okhttp.BraveOkHttpRequestResponseInterceptor;
import com.github.kristofa.brave.servlet.BraveServletFilter;
import lombok.Data;
import okhttp3.OkHttpClient;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* @program: zjsz-user
* @description: Zipkin配置
* @author: Mr.Yang
* @create: 2018-07-03 21:58
**/
@Data
@Configuration
@ConfigurationProperties(prefix = ZipkinProperties.ZIPKIN_PREFIX)
public class ZipkinProperties {
public static final String ZIPKIN_PREFIX = "zipkin";
/**
* 服務名稱
*/
private String serviceName;
/**
* zipkin地址
*/
private String url;
/**
* 連接時間
*/
private int connectTimeout;
/**
* 讀取時間
*/
private int readTimeout;
/**
* 每間隔多少秒執行一次Span信息上傳
*/
private int flushInterval;
/**
* 是否啟動壓縮
*/
private boolean compressionEnabled;
/**
* @Description: span（一次請求信息或者一次鏈路調用）信息收集器
* @Param:
* @return: SpanCollector 控制器
* @Author: Mr.Yang
* @Date: 2018/7/3 0002
*/
@Bean
public SpanCollector spanCollector() {
Config config = Config.builder()
// 默認false，span在transport之前是否會被gzipped
.compressionEnabled(compressionEnabled)
.connectTimeout(connectTimeout)
.flushInterval(flushInterval)
.readTimeout(readTimeout)
.build();
return create(url, config, new EmptySpanCollectorMetricsHandler());
}
/**
* @Description: 作為各調用鏈路，只需要負責將指定格式的數據發送給zipkin
* @Param:
* @return:
* @Author: Mr.Yang
* @Date: 2018/7/3 0002
*/
@Bean
public Brave brave(SpanCollector spanCollector) {
//調用服務的名稱
Builder builder = new Builder(serviceName);
builder.spanCollector(spanCollector);
//采集率
builder.traceSampler(Sampler.ALWAYS_SAMPLE);
return builder.build();
}
/**
* @Description: 設置server的（服務端收到請求和服務端完成處理，并將結果發送給客戶端）過濾器
* @Param:
* @return: 過濾器
* @Author: Mr.Yang
* @Date: 2018/7/3 0002
*/
@Bean
public BraveServletFilter braveServletFilter(Brave brave) {
BraveServletFilter filter = new BraveServletFilter(brave.serverRequestInterceptor(),
brave.serverResponseInterceptor(), new DefaultSpanNameProvider());
return filter;
}
/**
* @Description: 設置client的（發起請求和獲取到服務端返回信息）攔截器
* @Param:
* @return: OkHttpClient 返回請求實例
* @Author: Mr.Yang
* @Date: 2018/7/3 0002
*/
@Bean
public OkHttpClient okHttpClient(Brave brave) {
OkHttpClient httpClient = new OkHttpClient.Builder()
.addInterceptor(new BraveOkHttpRequestResponseInterceptor(
brave.clientRequestInterceptor(),
brave.clientResponseInterceptor(),
new DefaultSpanNameProvider())).build();
return httpClient;
}
}ZipkinBraveController1
package com.cms.contorller;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @program: zjsz-user
* @description: 服務一
* @author: Mr.Yang
* @create: 2018-07-03 21:58
**/
@RestController
@RequestMapping("server1")
public class ZipkinBraveController1 {
@Autowired
private OkHttpClient client;
/**
* @Description: 第一步調用
* @Param:
* @return: 字符串
* @Author: Mr.Yang
* @Date: 2018/7/3
*/
@RequestMapping("/zipkin")
public String service1() throws Exception {
Thread.sleep(100);
Request request = new Request.Builder().url("http://localhost:9000/zipkinTest/server2/zipkin").build();
Response response = client.newCall(request).execute();
return response.body().string();
}
}ZipkinBraveController2
package com.cms.contorller;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @program: zjsz-user
* @description: 服務二
* @author: Mr.Yang
* @create: 2018-07-03 21:58
**/
@RestController
@RequestMapping("server2")
public class ZipkinBraveController2 {
@Autowired
private OkHttpClient client;
/**
* @Description: 第二步調用
* @Param:
* @return: 字符串
* @Author: Mr.Yang
* @Date: 2018/7/3
*/
@RequestMapping("/zipkin")
public String service1() throws Exception {
Thread.sleep(100);
Request request = new Request.Builder().url("http://localhost:9000/zipkinTest/server3/zipkin").build();
Response response = client.newCall(request).execute();
return response.body().string();
}
}ZipkinBraveController3
package com.cms.contorller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @program: zjsz-user
* @description: 服務三
* @author: Mr.Yang
* @create: 2018-07-03 21:58
**/
@RestController
@RequestMapping("server3")
public class ZipkinBraveController3 {
/**
* @Description: 第三步調用
* @Param:
* @return: 字符串
* @Author: Mr.Yang
* @Date: 2018/7/3
*/
@RequestMapping("/zipkin")
public String service1() throws Exception {
Thread.sleep(200);
return "你好,歡迎進入Zipkin的世界";
}
}項目啟動后，訪問http://localhost:9000/zipkinTest/server1/zipkin 就可以看到
你好,歡迎進入Zipkin的世界
我們通過http://localhost:9411/zipkin 查看zipkin的web UI
查看每條調用鏈的詳情
感謝你能夠認真閱讀完這篇文章，希望小編分享的“SpringBoot2.0中ZipKin的示例分析”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
