From 081c3cbbf35323fe3ca63fafed497b5b709b8a5f Mon Sep 17 00:00:00 2001 From: zhangxin10 Date: Fri, 4 Dec 2015 10:55:38 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=86HttpClient=E7=9A=84header=E7=9A=84Valu?= =?UTF-8?q?e=E5=80=BC=E6=94=B9=E6=88=90=E4=BA=8C=E7=BA=A7=EF=BC=8C?= =?UTF-8?q?=E4=B8=BA=E7=9A=84=E6=98=AF=E5=92=8CDubbo=E5=AF=B9=E5=BA=94?= =?UTF-8?q?=E4=B8=80=E8=87=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../plugin/httpclient/trace/HttpClientTracing.java | 2 +- .../cloud/skywalking/plugin/web/SkyWalkingFilter.java | 11 ++++++++++- 2 files changed, 11 insertions(+), 2 deletions(-) diff --git a/skywalking-sdk-plugin/httpclient-plugin/src/main/java/com/ai/cloud/skywalking/plugin/httpclient/trace/HttpClientTracing.java b/skywalking-sdk-plugin/httpclient-plugin/src/main/java/com/ai/cloud/skywalking/plugin/httpclient/trace/HttpClientTracing.java index d3e0619dc..3336374a6 100644 --- a/skywalking-sdk-plugin/httpclient-plugin/src/main/java/com/ai/cloud/skywalking/plugin/httpclient/trace/HttpClientTracing.java +++ b/skywalking-sdk-plugin/httpclient-plugin/src/main/java/com/ai/cloud/skywalking/plugin/httpclient/trace/HttpClientTracing.java @@ -13,7 +13,7 @@ public class HttpClientTracing { public static R execute(String url, String traceHearName, HttpRequest httpRequest, Executor executor) throws IOException { try { httpRequest.setHeader(traceHearName, - sender.beforeSend(Identification.newBuilder() + "ContextData=" + sender.beforeSend(Identification.newBuilder() .viewPoint(url) .spanType('W') .build()) diff --git a/skywalking-sdk-plugin/web-plugin/src/main/java/com/ai/cloud/skywalking/plugin/web/SkyWalkingFilter.java b/skywalking-sdk-plugin/web-plugin/src/main/java/com/ai/cloud/skywalking/plugin/web/SkyWalkingFilter.java index 1f247a2a9..274ea0d39 100644 --- a/skywalking-sdk-plugin/web-plugin/src/main/java/com/ai/cloud/skywalking/plugin/web/SkyWalkingFilter.java +++ b/skywalking-sdk-plugin/web-plugin/src/main/java/com/ai/cloud/skywalking/plugin/web/SkyWalkingFilter.java @@ -11,6 +11,7 @@ import java.io.IOException; public class SkyWalkingFilter implements Filter { + private final String secondKey = "ContextData"; private String tracingName; private static final String DEFAULT_TRACE_NAME = "SkyWalking-TRACING-NAME"; @@ -25,7 +26,15 @@ public class SkyWalkingFilter implements Filter { RPCBuriedPointReceiver receiver = null; try { HttpServletRequest request = (HttpServletRequest) servletRequest; - String contextDataStr = request.getHeader(tracingName); + String tracingHeaderValue = request.getHeader(tracingName); + String contextDataStr = null; + int index = tracingHeaderValue.indexOf("="); + if (index > 0) { + String key = tracingHeaderValue.substring(0, index); + if (secondKey.equals(key)) { + contextDataStr = tracingHeaderValue.substring(index + 1); + } + } ContextData contextData = null; if (contextDataStr != null && contextDataStr.length() > 0) { contextData = new ContextData(contextDataStr);