首页 文章 精选 留言 我的

使用Zipkin 和 Brave 实现http(springmvc)服务调用跟踪(二)

2018-03-05 717

使用Zipkin 和 Brave 实现http(springmvc)服务调用跟踪(二)

上次讲了Brave为Spring提供的Servlet拦截器（ServletHandlerInterceptor）及Rest（BraveClientHttpRequestInterceptor）模板的拦截器，向zipkin报告监控数据，其中，BraveClientHttpRequestInterceptor负责cs与cr的处理，ServletHandlerInterceptor负责sr与ss的处理，并没有记录到请求参数的监控及使用的是默认的span名称，那如何才能记录请求参数及修改span名称。

需要实现自定义拦截器，我选择在服务端做处理记录请求参数的过程，先看看Brave提供服务端拦截器ServletHandlerInterceptor的源码实现，发现使用HttpServerRequestAdapter适配器，

再跟踪HttpServerRequestAdapter源码，在其中实现ServerRequestAdapter接口，包括跟踪数据的获取，span名称的获取及键值数据的添加。

那我们除了实现自定义拦截器，还需要实现自己的适配器，适配器实现接口ServerRequestAdapter，在获取键值数据的方法中实现添加请求参数到keyvalue,在span名称获取方法返回自己span名称，即完成了请求参数的添加及span名称的自定义

以下实现在上篇中提供的git的工程中实现，可直接下载，git地址：https://github.com/blacklau/brave-webmvc-example

1、拦截器的实现

 

[java] view plain copy

  1. package brave.interceptor;
  3. import static com.github.kristofa.brave.internal.Util.checkNotNull;
  5. import java.net.URI;
  6. import java.net.URISyntaxException;
  8. import javax.servlet.http.HttpServletRequest;
  9. import javax.servlet.http.HttpServletResponse;
  11. import org.springframework.beans.factory.annotation.Autowired;
  12. import org.springframework.context.annotation.Configuration;
  13. import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
  15. import com.github.kristofa.brave.Brave;
  16. import com.github.kristofa.brave.ServerRequestInterceptor;
  17. import com.github.kristofa.brave.ServerResponseInterceptor;
  18. import com.github.kristofa.brave.ServerSpan;
  19. import com.github.kristofa.brave.ServerSpanThreadBinder;
  20. import com.github.kristofa.brave.http.DefaultSpanNameProvider;
  21. import com.github.kristofa.brave.http.HttpResponse;
  22. import com.github.kristofa.brave.http.HttpServerRequest;
  23. import com.github.kristofa.brave.http.HttpServerRequestAdapter;
  24. import com.github.kristofa.brave.http.HttpServerResponseAdapter;
  25. import com.github.kristofa.brave.http.SpanNameProvider;
  26. import com.github.kristofa.brave.spring.ServletHandlerInterceptor;
  28. import brave.adapter.CustomServerRequestAdapter;
  30. @Configuration
  31. public class CustomServletHandlerInterceptor  extends HandlerInterceptorAdapter {
  33.     static final String HTTP_SERVER_SPAN_ATTRIBUTE = ServletHandlerInterceptor.class.getName() + ".customserver-span";
  35.     /** Creates a tracing interceptor with custom */
  36.     public static CustomServletHandlerInterceptor create(Brave brave) {
  37.         return new Builder(brave).build();
  38.     }
  40.     public static Builder builder(Brave brave) {
  41.         return new Builder(brave);
  42.     }
  44.     public static final class Builder {
  45.         final Brave brave;
  46.         SpanNameProvider spanNameProvider = new DefaultSpanNameProvider();
  48.         Builder(Brave brave) { // intentionally hidden
  49.             this.brave = checkNotNull(brave, "brave");
  50.         }
  52.         public Builder spanNameProvider(SpanNameProvider spanNameProvider) {
  53.             this.spanNameProvider = checkNotNull(spanNameProvider, "spanNameProvider");
  54.             return this;
  55.         }
  57.         public CustomServletHandlerInterceptor build() {
  58.             return new CustomServletHandlerInterceptor(this);
  59.         }
  60.     }
  62.     private final ServerRequestInterceptor requestInterceptor;
  63.     private final ServerResponseInterceptor responseInterceptor;
  64.     private final ServerSpanThreadBinder serverThreadBinder;
  65.     private final SpanNameProvider spanNameProvider;
  67.     @Autowired // internal
  68.     CustomServletHandlerInterceptor(SpanNameProvider spanNameProvider, Brave brave) {
  69.         this(builder(brave).spanNameProvider(spanNameProvider));
  70.     }
  72.     CustomServletHandlerInterceptor(Builder b) { // intentionally hidden
  73.         this.requestInterceptor = b.brave.serverRequestInterceptor();
  74.         this.responseInterceptor = b.brave.serverResponseInterceptor();
  75.         this.serverThreadBinder = b.brave.serverSpanThreadBinder();
  76.         this.spanNameProvider = b.spanNameProvider;
  77.     }
  79.     /**
  80.      * @deprecated please use {@link #create(Brave)} or {@link #builder(Brave)}
  81.      */
  82.     @Deprecated
  83.     public CustomServletHandlerInterceptor(ServerRequestInterceptor requestInterceptor, ServerResponseInterceptor responseInterceptor, SpanNameProvider spanNameProvider, final ServerSpanThreadBinder serverThreadBinder) {
  84.         this.requestInterceptor = requestInterceptor;
  85.         this.spanNameProvider = spanNameProvider;
  86.         this.responseInterceptor = responseInterceptor;
  87.         this.serverThreadBinder = serverThreadBinder;
  88.     }
  90.     @Override
  91.     public boolean preHandle(final HttpServletRequest request, final HttpServletResponse response, final Object handler) {
  92.         requestInterceptor.handle(new CustomServerRequestAdapter(request, spanNameProvider));
  94.         return true;
  95.     }
  97.     @Override
  98.     public void afterConcurrentHandlingStarted(final HttpServletRequest request, final HttpServletResponse response, final Object handler) {
  99.         request.setAttribute(HTTP_SERVER_SPAN_ATTRIBUTE, serverThreadBinder.getCurrentServerSpan());
  100.         serverThreadBinder.setCurrentSpan(null);
  101.     }
  103.     @Override
  104.     public void afterCompletion(final HttpServletRequest request, final HttpServletResponse response, final Object handler, final Exception ex) {
  106.         final ServerSpan span = (ServerSpan) request.getAttribute(HTTP_SERVER_SPAN_ATTRIBUTE);
  108.         if (span != null) {
  109.             serverThreadBinder.setCurrentSpan(span);
  110.         }
  112.        responseInterceptor.handle(new HttpServerResponseAdapter(new HttpResponse() {
  113.            @Override
  114.            public int getHttpStatusCode() {
  115.                return response.getStatus();
  116.            }
  117.        }));
  118.     }
  119. }

2、适配器的实现

[java] view plain copy

  1. package brave.adapter;
  3. import static com.github.kristofa.brave.IdConversion.convertToLong;
  5. import java.util.ArrayList;
  6. import java.util.Collection;
  7. import java.util.Collections;
  8. import java.util.List;
  9. import java.util.Map;
  11. import javax.servlet.http.HttpServletRequest;
  13. import com.github.kristofa.brave.KeyValueAnnotation;
  14. import com.github.kristofa.brave.ServerRequestAdapter;
  15. import com.github.kristofa.brave.SpanId;
  16. import com.github.kristofa.brave.TraceData;
  17. import com.github.kristofa.brave.http.BraveHttpHeaders;
  18. import com.github.kristofa.brave.http.SpanNameProvider;
  20. import zipkin.TraceKeys;
  22. public class CustomServerRequestAdapter  implements ServerRequestAdapter {
  23.     private final HttpServletRequest request;
  25.     public CustomServerRequestAdapter(HttpServletRequest request, SpanNameProvider spanNameProvider) {
  26.         this.request = request;
  27.     }
  29.     @Override
  30.     public TraceData getTraceData() {
  31.         String sampled = request.getHeader(BraveHttpHeaders.Sampled.getName());
  32.         String parentSpanId = request.getHeader(BraveHttpHeaders.ParentSpanId.getName());
  33.         String traceId = request.getHeader(BraveHttpHeaders.TraceId.getName());
  34.         String spanId = request.getHeader(BraveHttpHeaders.SpanId.getName());
  36.         // Official sampled value is 1, though some old instrumentation send true
  37.         Boolean parsedSampled = sampled != null
  38.             ? sampled.equals("1") || sampled.equalsIgnoreCase("true")
  39.             : null;
  41.         if (traceId != null && spanId != null) {
  42.             return TraceData.create(getSpanId(traceId, spanId, parentSpanId, parsedSampled));
  43.         } else if (parsedSampled == null) {
  44.             return TraceData.EMPTY;
  45.         } else if (parsedSampled.booleanValue()) {
  46.             // Invalid: The caller requests the trace to be sampled, but didn't pass IDs
  47.             return TraceData.EMPTY;
  48.         } else {
  49.             return TraceData.NOT_SAMPLED;
  50.         }
  51.     }
  53.     @Override
  54.     public String getSpanName() {
  55.         return "custom spanName";
  56.     }
  58.     @Override
  59.     public Collection<KeyValueAnnotation> requestAnnotations() {
  60.         List<KeyValueAnnotation> kvs = new ArrayList<KeyValueAnnotation>();
  62.         Map<String, String[]> params = this.request.getParameterMap();
  63.         for(String key:params.keySet()){
  64.             KeyValueAnnotation kv = KeyValueAnnotation.create(key, params.get(key)[0]);
  65.             kvs.add(kv);
  66.         }
  68.         KeyValueAnnotation uriAnnotation = KeyValueAnnotation.create(
  69.                 TraceKeys.HTTP_URL, request.getRequestURI().toString());
  70.         kvs.add(uriAnnotation);
  71.         return kvs;
  72.     }
  74.     static SpanId getSpanId(String traceId, String spanId, String parentSpanId, Boolean sampled) {
  75.         return SpanId.builder()
  76.             .traceIdHigh(traceId.length() == 32 ? convertToLong(traceId, 0) : 0)
  77.             .traceId(convertToLong(traceId))
  78.             .spanId(convertToLong(spanId))
  79.             .sampled(sampled)
  80.             .parentId(parentSpanId == null ? null : convertToLong(parentSpanId)).build();
  81.    }
  82. }

 

浏览器输入测试： http://localhost:80810brave-webmvc-example/a?service=account.user.login

打开zipkin:  http://localhost:9411/, 查看跟踪结果

原文地址http://www.bieryun.com/1923.html

上一篇 下一篇
优秀的个人博客,低调大师

微信关注我们

原文链接：https://yq.aliyun.com/articles/511613

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

使用Zipkin 和 Brave 实现http(springmvc)服务调用跟踪(一)

使用Zipkin 和 Brave 实现http(springmvc)服务调用跟踪(一) Zipkin是一款开源的分布式实时数据追踪系统（Distributed Tracking System），基于Google Dapper的论文设计而来，由 Twitter 公司开发贡献。其主要功能是聚集来自各个异构系统的实时监控数据，用来追踪微服务架构下的系统延时问题。 Brave 是用来装备 Java 程序的类库，提供了面向 Standard Servlet、Spring MVC、Http Client、JAX RS、Jersey、Resteasy 和 MySQL 等接口的装备能力，可以通过编写简单的配置和代码，让基于这些框架构建的应用可以向 Zipkin 报告数据。同时 Brave 也提供了非常简单且标准化的接口，在以上封装无法满足要求的时候可以方便扩展与定制（下篇会讲）。 有关zipkin与Brave的详细介绍：http://www.tuicool.com/articles/f2qAZnZ 客户端发起请求到接收到服务端回应，先后经过四个阶段：客户端/消费者发起请求（cs）、服务端/生产者接收...
2018-03-06
605
上一篇

scons\python2.7\MinGW安装

1.文档参考： 略。 2.软件安装： 编译环境：win7 编译器：g++ 解释：windows下用g++编译需要安装MinGW这个软件。而MinGW这个软件是在线安装的，下载下来非常小，点开后开始在线安装。安装过程需要fq，安装过程需要fq. 安装教程： https://www.jianshu.com/p/ff24a81f3637 自动化构建工具：scons 解释：这个软件类似makefile的作用，控制编译用的。Python开发的。所以要让它运行还需要安装python2.7. 安装教程： 先安装python， python安装教程： http://blog.csdn.net/lin_not_for_codes/article/details/55051700 scons安装：（kanzi提供scons的压缩包。也可以从网上下载zip。） https://www.cnblogs.com/westfly/archive/2012/03/10/2388836.html 安装完成之后要注意配置系统的环境变量： 这里我直接贴出我的Path，标注红色的是要注意参考的，根据实际路径填写。 C:\...
2018-03-06
631
下一篇

相关文章

发表评论

资源下载

更多资源
优质分享App

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

时间: 2025-12-03 大小: 4.36MB 下载: 23次
Nacos

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

时间: 2025-12-21 大小: 189MB 下载: 2次
Spring

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

时间: 2025-12-17 大小: 5MB 下载: 1次
Rocky Linux

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

时间: 2026-01-03 大小: 1.42GB 下载: 2次
手机查看

扫码在手机上查看文章

扫描二维码，手机阅读更方便

热门标签
Gemini3 Kubernetes SpringCloud Redis SpringBoot4 Jdk25 OpenAi Nacos3 DeepSeek Docker Rocky HarmonyOS6 Service Mesh

欢迎您来访！

登录后，您将获得更多功能！
热门文章
联系我们

有任何问题或合作意向欢迎联系我们

Email: 99873273@qq.com

QQ: 99873273

用户登录
用户注册