AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

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

2018-03-06 2953
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

使用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

文章标签：
Java
关键词：
Spring MVC服务调用
zipkin HTTP
优惠券发放
目录
相关文章
优惠码发放
|
Web App开发 Java Apache
使用Zipkin 和 Brave 实现http(springmvc)服务调用跟踪(一)
优惠码发放
4348 0
@dailidong@
|
Web App开发 新零售 前端开发
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
1.尽可能地了解需求，系统层面适用开闭原则 2.模块化，低耦合，能快速响应变化，也可以避免一个子系统的问题波及整个大系统 3.
@dailidong@
750 0
@dailidong@
|
Web App开发 前端开发 关系型数据库
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
fuser可用于查询文件、目录、socket端口和文件系统的使用进程 1.查询文件和目录使用者 fuser最基本的用法是查询某个文件或目录被哪个进程使用： # fuser -v .
@dailidong@
883 0
@dailidong@
|
Web App开发 前端开发
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
总结和计划总是让人喜悦或镇痛，一方面以前一段时间没有荒废，能给现在的行动以信心，另一方面看到一年的时间并不能完成很多事情，需要抓紧时间。
@dailidong@
617 0
@dailidong@
|
Web App开发 监控 前端开发
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
Datanode的日志中看到: 10/12/14 20:10:31 INFO hdfs.DFSClient: Could not obtain block blk_XXXXXXXXXXXXXXXXXXXXXX_YYYYYYYY from any node: java.
@dailidong@
693 0
@dailidong@
|
Web App开发 监控 前端开发
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
负载均衡: LVS（Layer 4）, HAProxy（Layer 4、 7）,Nginx（Layer 7） 虚拟化: LXC、KVM、Xen HA：Keepalived、Heartbeat 分布式缓存...
@dailidong@
760 0
@dailidong@
|
Web App开发 前端开发
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
zookeeper watch的定义如下：watch事件是一次性触发器，当watch监视的数据发生变化时，通知设置了该watch的client，即watcher。
@dailidong@
936 0
@dailidong@
|
Web App开发 前端开发 测试技术
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
一、迁移步骤 1.首先安装最新版本gitlab（gitlab7.2安装） 2.停止旧版本gitlab服务 3.将旧的项目文件完整导入新的gitlab   bundle exec rake gitlab:import:r...
@dailidong@
715 0
@dailidong@
|
Web App开发 前端开发
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
从hadoop移除机器把需要移除的机器增加到exclueds文件中，强制刷新datanode列表，等待decommission 状态正常后，即可停机下架，如有必要在namenode执行balancer操作。
@dailidong@
680 0
@dailidong@
|
Web App开发 前端开发
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
service cloudera-scm-agent stop service cloudera-scm-agent stop umount /var/run/cloudera-scm-agent/process umo...
@dailidong@
760 0

热门文章

最新文章

  • 1
    Java发送Http请求（HttpClient）
  • 2
    阿里云虚拟主机HTTPS（HTTP+SSL）加密开通了
  • 3
    android-async-http框架的学习和使用
  • 4
    <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
  • 5
    关于使用HTTP代理IP爬虫采集的认知误区
  • 6
    HTTP连接客户端，选 HttpClient 还是 OkHttp ？
  • 7
    <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd"> <html><head><meta http-equiv="Cont
  • 8
    统计http连接数
  • 9
    Tomcat 无法及时响应，http请求一直pending状态
  • 10
    nginx HTTP Upstream模块
  • 1
    SpringMVC04 实现简单的留言墙功能
    41
  • 2
    SpringMVC03 基础操作续与几个简单的交互
    35
  • 3
    Spring MVC框架概述
    84
  • 4
    SpringBoot与SpringMVC有哪些区别？
    422
  • 5
    SpringBoot：SpringMVC（下）
    42
  • 6
    SpringBoot：SpringMVC（上）
    49
  • 7
    生活小事件(SpringMVC主要的组件及作用和执行流程)
    95
  • 8
    数据塑造：Spring MVC中@ModelAttribute的高级数据预处理技巧
    68
  • 9
    数据之桥：深入Spring MVC中传递数据给视图的实用指南
    92
  • 10
    头头是道：揭示Spring MVC如何获取和处理请求头数据
    109

    • 相关课程

    更多
  • Java Web开发-Web应用、Tomcat、HTTP请求与响应
  • 云安全基础课- HTTP协议基础

    • 相关电子书

    更多
  • 阿里巴巴HTTP 2.0实践及无线通信协议的演进之路
  • Apache Dubbo3 源码深入解读
  • 低代码开发师（初级）实战教程

    • 相关实验场景

    更多
  • 通过轻量消息队列（原MNS）主题HTTP订阅+ARMS实现自定义数据多渠道告警
  • 快速上手使用Dubbo进行远程调用
    • 下一篇
    无影云桌面