SpringBoot2.0 ZipKin示例代码

2019-11-26 09:32:23

字体：大中小

来源：转载

供稿：网友

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-testzipkin.url=http://localhost:9411zipkin.connectTimeout=6000zipkin.readTimeout=6000zipkin.flushInterval=1zipkin.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 就可以看到