正文 

当前位置： 首页 > java > java教程

第二十八章springboot+zipkin（brave定制-asynchttpclient）

赵计刚 赵计刚     2022-08-03     436

关键词：

brave本身没有对AsyncHttpClient提供类似于brave-okhttp的ClientRequestInterceptor和ClientResponseInterceptor，所以需要我们定制，而ServerRequestInterceptor和ServerResponseInterceptor是在BraveServletFilter部分直接指定就好了（这在任何client技术下都可以复用）。

实际上，ClientRequestInterceptor和ClientResponseInterceptor也是我们的定制点。

 

一、代码

基本参考第二十七章 springboot + zipkin（brave-okhttp实现）

1、service1

1.1、pom.xml

 1 <!-- zipkin brave -->
 2         <dependency>
 3             <groupId>io.zipkin.brave</groupId>
 4             <artifactId>brave-core</artifactId>
 5             <version>3.9.0</version>
 6         </dependency>
 7         <dependency>
 8             <groupId>io.zipkin.brave</groupId>
 9             <artifactId>brave-spancollector-http</artifactId>
10             <version>3.9.0</version>
11         </dependency>
12         <dependency>
13             <groupId>io.zipkin.brave</groupId>
14             <artifactId>brave-web-servlet-filter</artifactId>
15             <version>3.9.0</version>
16         </dependency>
17         <!-- async-http-client -->
18         <dependency>
19             <groupId>com.ning</groupId>
20             <artifactId>async-http-client</artifactId>
21             <version>1.9.31</version>
22         </dependency>
View Code

1.2、ZipkinConfig

 1 package com.xxx.service1.zipkin.brave.async;
 2 
 3 import org.springframework.context.annotation.Bean;
 4 import org.springframework.context.annotation.Configuration;
 5 
 6 import com.github.kristofa.brave.Brave;
 7 import com.github.kristofa.brave.EmptySpanCollectorMetricsHandler;
 8 import com.github.kristofa.brave.Sampler;
 9 import com.github.kristofa.brave.SpanCollector;
10 import com.github.kristofa.brave.http.DefaultSpanNameProvider;
11 import com.github.kristofa.brave.http.HttpSpanCollector;
12 import com.github.kristofa.brave.servlet.BraveServletFilter;
13 import com.ning.http.client.AsyncHttpClient;
14 
15 @Configuration
16 public class ZipkinConfig {
17     @Bean
18     public SpanCollector spanCollector() {
19         HttpSpanCollector.Config spanConfig = HttpSpanCollector.Config.builder()
20                                               .compressionEnabled(false)//默认false，span在transport之前是否会被gzipped。
21                                               .connectTimeout(5000)//5s，默认10s
22                                               .flushInterval(1)//1s
23                                               .readTimeout(6000)//5s，默认60s
24                                               .build();
25         return HttpSpanCollector.create("http://localhost:9411", 
26                                         spanConfig,
27                                         new EmptySpanCollectorMetricsHandler());
28     }
29 
30     @Bean
31     public Brave brave(SpanCollector spanCollector) {
32         Brave.Builder builder = new Brave.Builder("asyn1 - service1 - 1");//指定serviceName
33         builder.spanCollector(spanCollector);
34         builder.traceSampler(Sampler.create(1));//采集率
35         return builder.build();
36     }
37 
38     @Bean
39     public BraveServletFilter braveServletFilter(Brave brave) {
40         /**
41          * 设置sr、ss拦截器
42          */
43         return new BraveServletFilter(brave.serverRequestInterceptor(), 
44                                       brave.serverResponseInterceptor(),
45                                       new DefaultSpanNameProvider());
46     }
47 
48     @Bean
49     public AsyncHttpClient asyncHttpClient(){
50         return new AsyncHttpClient();
51     }
52 }
View Code

说明：指定了serviceName："asyn1 - service1 - 1"

1.3、ZipkinAsyncController

 1 package com.xxx.service1.zipkin.brave.async;
 2 
 3 import java.net.URI;
 4 import java.util.concurrent.Future;
 5 
 6 import org.springframework.beans.factory.annotation.Autowired;
 7 import org.springframework.web.bind.annotation.RequestMapping;
 8 import org.springframework.web.bind.annotation.RequestMethod;
 9 import org.springframework.web.bind.annotation.RestController;
10 
11 import com.github.kristofa.brave.Brave;
12 import com.github.kristofa.brave.http.DefaultSpanNameProvider;
13 import com.github.kristofa.brave.http.HttpClientRequest;
14 import com.github.kristofa.brave.http.HttpClientRequestAdapter;
15 import com.github.kristofa.brave.http.HttpClientResponseAdapter;
16 import com.github.kristofa.brave.http.HttpResponse;
17 import com.ning.http.client.AsyncHttpClient;
18 import com.ning.http.client.Request;
19 import com.ning.http.client.RequestBuilder;
20 import com.ning.http.client.Response;
21 
22 import io.swagger.annotations.Api;
23 import io.swagger.annotations.ApiOperation;
24 
25 @Api("zipkin brave async api")
26 @RestController
27 @RequestMapping("/zipkin/async/service1")
28 public class ZipkinAsyncController {
29 
30     @Autowired
31     private AsyncHttpClient asyncHttpClient;
32     @Autowired
33     private Brave           brave;
34 
35     @ApiOperation("trace第一步")
36     @RequestMapping(value = "/test1", method = RequestMethod.GET)
37     public String myboot() {
38 
39         try {
40             RequestBuilder builder = new RequestBuilder();
41             String url = "http://localhost:8032/zipkin/async/service2/test2";
42             builder.setUrl(url);
43             Request request = builder.build();
44 
45             clientRequestInterceptor(request);
46             Future<Response> response = asyncHttpClient.executeRequest(request);
47             clientResponseInterceptor(response.get());
48 
49             return response.get().getResponseBody();
50         } catch (Exception e) {
51             e.printStackTrace();
52             return "";
53         }
54     }
55 
56     private void clientRequestInterceptor(Request request) {
57         brave.clientRequestInterceptor().handle(new HttpClientRequestAdapter(new HttpClientRequest() {
58 
59             @Override
60             public URI getUri() {
61                 return URI.create(request.getUrl());
62             }
63 
64             @Override
65             public String getHttpMethod() {
66                 return request.getMethod();
67             }
68 
69             @Override
70             public void addHeader(String headerKey, String headerValue) {
71                 request.getHeaders().add(headerKey, headerValue);
72             }
73         }, new DefaultSpanNameProvider()));
74     }
75 
76     private void clientResponseInterceptor(Response response) {
77         brave.clientResponseInterceptor().handle(new HttpClientResponseAdapter(new HttpResponse() {
78             public int getHttpStatusCode() {
79                 return response.getStatusCode();
80             }
81         }));
82     }
83 
84 }
View Code

说明：

  • clientRequestInterceptor(com.ning.http.client.Request request)
    • 其实就是在做cs
  • clientResponseInterceptor(com.ning.http.client.Response response)
    • 其实就是在做cr

 

2、service2

2.1、pom.xml

 1 <!-- zipkin brave -->
 2         <dependency>
 3             <groupId>io.zipkin.brave</groupId>
 4             <artifactId>brave-core</artifactId>
 5             <version>3.9.0</version>
 6         </dependency>
 7         <dependency>
 8             <groupId>io.zipkin.brave</groupId>
 9             <artifactId>brave-spancollector-http</artifactId>
10             <version>3.9.0</version>
11         </dependency>
12         <dependency>
13             <groupId>io.zipkin.brave</groupId>
14             <artifactId>brave-web-servlet-filter</artifactId>
15             <version>3.9.0</version>
16         </dependency>
17         <!-- async-http-client -->
18         <dependency>
19             <groupId>com.ning</groupId>
20             <artifactId>async-http-client</artifactId>
21             <version>1.9.31</version>
22         </dependency>
View Code

2.2、ZipkinConfig

 1 package com.xxx.service1.zipkin.brave.async;
 2 
 3 import org.springframework.context.annotation.Bean;
 4 import org.springframework.context.annotation.Configuration;
 5 
 6 import com.github.kristofa.brave.Brave;
 7 import com.github.kristofa.brave.EmptySpanCollectorMetricsHandler;
 8 import com.github.kristofa.brave.Sampler;
 9 import com.github.kristofa.brave.SpanCollector;
10 import com.github.kristofa.brave.http.DefaultSpanNameProvider;
11 import com.github.kristofa.brave.http.HttpSpanCollector;
12 import com.github.kristofa.brave.servlet.BraveServletFilter;
13 import com.ning.http.client.AsyncHttpClient;
14 
15 @Configuration
16 public class ZipkinConfig {
17     @Bean
18     public SpanCollector spanCollector() {
19         HttpSpanCollector.Config spanConfig = HttpSpanCollector.Config.builder()
20                                               .compressionEnabled(false)//默认false，span在transport之前是否会被gzipped。
21                                               .connectTimeout(5000)//5s，默认10s
22                                               .flushInterval(1)//1s
23                                               .readTimeout(6000)//5s，默认60s
24                                               .build();
25         return HttpSpanCollector.create("http://localhost:9411", 
26                                         spanConfig,
27                                         new EmptySpanCollectorMetricsHandler());
28     }
29 
30     @Bean
31     public Brave brave(SpanCollector spanCollector) {
32         Brave.Builder builder = new Brave.Builder("asyn2 - service2 - 2");//指定serviceName
33         builder.spanCollector(spanCollector);
34         builder.traceSampler(Sampler.create(1));//采集率
35         return builder.build();
36     }
37 
38     @Bean
39     public BraveServletFilter braveServletFilter(Brave brave) {
40         /**
41          * 设置sr、ss拦截器
42          */
43         return new BraveServletFilter(brave.serverRequestInterceptor(), 
44                                       brave.serverResponseInterceptor(),
45                                       new DefaultSpanNameProvider());
46     }
47 
48     @Bean
49     public AsyncHttpClient asyncHttpClient(){
50         return new AsyncHttpClient();
51     }
52 }
View Code

说明：指定了serviceName："asyn2 - service2 - 2"

2.3、ZipkinAsyncController

 1 package com.xxx.service2.zipkin.brave.async;
 2 
 3 import java.net.URI;
 4 import java.util.concurrent.Future;
 5 
 6 import org.springframework.beans.factory.annotation.Autowired;
 7 import org.springframework.web.bind.annotation.RequestMapping;
 8 import org.springframework.web.bind.annotation.RequestMethod;
 9 import org.springframework.web.bind.annotation.RestController;
10 
11 import com.github.kristofa.brave.Brave;
12 import com.github.kristofa.brave.http.DefaultSpanNameProvider;
13 import com.github.kristofa.brave.http.HttpClientRequest;
14 import com.github.kristofa.brave.http.HttpClientRequestAdapter;
15 import com.github.kristofa.brave.http.HttpClientResponseAdapter;
16 import com.github.kristofa.brave.http.HttpResponse;
17 import com.ning.http.client.AsyncHttpClient;
18 import com.ning.http.client.Request;
19 import com.ning.http.client.RequestBuilder;
20 import com.ning.http.client.Response;
21 
22 import io.swagger.annotations.Api;
23 import io.swagger.annotations.ApiOperation;
24 
25 @Api("zipkin brave async api")
26 @RestController
27 @RequestMapping("/zipkin/async/service2")
28 public class ZipkinAsyncController {
29 
30     @Autowired
31     private AsyncHttpClient asyncHttpClient;
32     @Autowired
33     private Brave           brave;
34 
35     @ApiOperation("trace第2步")
36     @RequestMapping(value = "/test2", method = RequestMethod.GET)
37     public String myboot2() {
38 
39         try {
40             /*****************************serivce3*******************************/
41             RequestBuilder builder3 = new RequestBuilder();
42             String url3 = "http://localhost:8033/zipkin/async/service3/test3";
43             builder3.setUrl(url3);
44             Request request3 = builder3.build();
45 
46             clientRequestInterceptor(request3);
47             Future<Response> response3 = asyncHttpClient.executeRequest(request3);
48             clientResponseInterceptor(response3.get());
49 
50             /*****************************serivce4*******************************/
51             RequestBuilder builder4 = new RequestBuilder();
52             String url4 = "http://localhost:8034/zipkin/async/service4/test4";
53             builder4.setUrl(url4);
54             Request request4 = builder4.build();
55 
56             clientRequestInterceptor(request4);
57             Future<Response> response4 = asyncHttpClient.executeRequest(request4);
58             clientResponseInterceptor(response4.get());
59 
60             return response3.get().getResponseBody() + "=====" + response4.get().getResponseBody();
61         } catch (Exception e) {
62             e.printStackTrace();
63             return "";
64         }
65     }
66 
67     private void clientRequestInterceptor(Request request) {
68         brave.clientRequestInterceptor().handle(new HttpClientRequestAdapter(new HttpClientRequest() {
69 
70             @Override
71             public URI getUri() {
72                 return URI.create(request.getUrl());
73             }
74 
75             @Override
76             public String getHttpMethod() {
77                 return request.getMethod();
78             }
79 
80             @Override
81             public void addHeader(String headerKey, String headerValue) {
82                 request.getHeaders().add(headerKey, headerValue);
83             }
84         }, new DefaultSpanNameProvider()));
85     }
86 
87     private void clientResponseInterceptor(Response response) {
88         brave.clientResponseInterceptor().handle(new HttpClientResponseAdapter(new HttpResponse() {
89             public int getHttpStatusCode() {
90                 return response.getStatusCode();
91             }
92         }));
93     }
94 
95 }
View Code

 

3、service3

3.1、pom.xml

 1 <!-- zipkin brave -->
 2         <dependency>
 3             <groupId>io.zipkin.brave</groupId>
 4             <artifactId>brave-core</artifactId>
 5             <version>3.9.0</version>
 6         </dependency>
 7         <dependency>
 8             <groupId>io.zipkin.brave</groupId>
 9             <查看详情  

                

“全栈2019”java第二十八章：数组详解（上篇）


...开发环境JDKv11IntelliJIDEAv2018.3文章原文链接“全栈2019”Java第二十八章：数组详解（上篇）下一章“全栈2019”Java第二十九章：数组详解（中篇）学习小组加入同步学习小组，共同交流与进步。方式一：关注头条号Gorhaf，私信“Java...  查看详情  

                

“全栈2019”java多线程第二十八章：公平锁与非公平锁详解


...境JDKv11IntelliJIDEAv2018.3文章原文链接“全栈2019”Java多线程第二十八章：公平锁与非公平锁详解下一章“全栈2019”Java多线程第二十九章：可重入锁与不可重入锁详解学习小组加入同步学习小组，共同交流与进步。方式一：关注头...  查看详情  

                

算法导论笔记第二十八章矩阵运算


28.1求解线性方程组定义奇异矩阵：秩不是满秩的矩阵		欠定的(线性方程组)：线性方程组的矩阵向量A的秩小于n超定的(线性方程组)：方程数目超过未知变量的数目n//其实我早就忘得差不多了=。=赶紧捡起来LUP分析找出三个n×n的矩...  查看详情  

                

第二十七章springboot+zipkin（brave-okhttp实现）


本文截取自：http://blog.csdn.net/liaokailin/article/details/52077620一、前提1、zipkin基本知识：附8zipkin2、启动zipkinserver：2.1、在官网下载服务jar，http://zipkin.io/pages/quickstart.html，之后使用命令启动服务jar即可。nohupjava-jarzipkin-server  查看详情  

                

wpf学习第二十八章程序集资源(代码片段)


原文:【WPF学习】第二十八章程序集资源　　WPF应用程序中的程序集资源与其他.NET应用程序中的程序集资源在本质上是相同的。基本概念是为项目添加文件，从而Visualstudio可将其嵌入到编译过的应用程序的EXE或DLL文件中。WPF程序...  查看详情  

                

openssl详解


...et/liguangxianbin/article/details/79665100目录目录第一章 前言第二章 证书第三章 加密算法第四章 协议第五章 入门第六章 指令 verify第七章 指令asn1parse第八章 指令CA（一）第九章 指令CA（二）第十...  查看详情  

                

第十八章springboot+thymeleaf


代码结构：1、ThymeleafControllerpackagecom.xxx.firstboot.web;importorg.springframework.stereotype.Controller;importorg.springframework.ui.Model;importorg.springframework.web.bind.annotation.RequestMapping;i  查看详情  

                

每日算法&面试题，大厂特训二十八天——第二十八天（数组）


目录标题导读算法特训二十八天面试题点击直接资料领取导读肥友们为了更好的去帮助新同学适应算法和面试题，最近我们开始进行专项突击一步一步来。上一期我们完成了动态规划二十一天现在我们进行下一项对各类算法进行...  查看详情  

                

第二十八课


第一单元语法部分Vてくる／いく＜动作、变化的持续＞以说话的时间为基准，表示状态变化的开始、事物的发展过程或是动作的继续等。   a.Vてくる＜由过去到现在＞   表示事物由过去到现在（强调过去...  查看详情  

                

开始写游戏---第二十八篇


开始写游戏---第二十八篇　　今天：　　　　1、添加：物品奖励组件　　　　2、添加：物品信息弹框组件　　　　3、碰到BUG，现在被卡住了　　　　上图：　　　　1、添加：物品奖励组件　　　　　　　　　　效果：　　　...  查看详情  

                

我的第二十八篇博客---seleinum


fromseleniumimportwebdriver#初始化驱动driver=webdriver.Chrome()#请求页面driver.get(url=‘https://www.baidu.com‘)#找到对应标签，发送文本driver.find_element_by_xpath("//*[@id=‘kw‘]").send_keys(‘2019‘)#找到按钮，点击clickdriver.fin  查看详情  

                

每日算法&面试题，大厂特训二十八天——第二十七天（函数）(代码片段)


目录标题导读算法特训二十八天面试题点击直接资料领取导读肥友们为了更好的去帮助新同学适应算法和面试题，最近我们开始进行专项突击一步一步来。上一期我们完成了动态规划二十一天现在我们进行下一项对各类算法...  查看详情  

                

每日算法&面试题，大厂特训二十八天——第二十六天（循环）(代码片段)


目录标题导读算法特训二十八天面试题点击直接资料领取导读肥友们为了更好的去帮助新同学适应算法和面试题，最近我们开始进行专项突击一步一步来。上一期我们完成了动态规划二十一天现在我们进行下一项对各类算法...  查看详情  

                

第二十八天


昨天有没写，就很尴尬！唉，昨天，白天基本都在图书馆读书，然后，昨晚，你居然迷路了，明明那个地方离你那么近，但你就是找不到这就是传说中的迷路紧张恐惧症呀！我也深深的感觉最近的你好累即使尽力在满足那个老师...  查看详情  

                

-考研第二十八周总结-


-考研第二十八周总结-【本周完成】线代做完题后又大体的过了书历年真题从基础篇开始做的，本周做了4年的手机背单词每天英语听了两节完型的课，一节翻译的课政治目前看到了第三章，第三章多选还没做专业课做...  查看详情  

                

-考研第二十八周总结-


-考研第二十八周总结-【本周完成】线代做完题后又大体的过了书历年真题从基础篇开始做的，本周做了4年的手机背单词每天英语听了两节完型的课，一节翻译的课政治目前看到了第三章，第三章多选还没做专业课做...  查看详情  

                

第二十八课再论智能指针（下）(代码片段)


多个智能指针指向同一片堆空间的需求是巨大的。计数变量也是在堆空间里面定义的，它的生命周期和对象的生命周期相同。添加SharedPointer.h文件：1#ifndefSHAREDPOINTER_H2#defineSHAREDPOINTER_H34#include<cstdlib>5#include"Pointer.h"6#include"Exce...  查看详情