全链路服务追踪spring cloud sleuth+zipkin

我不是女神ヾ 2022-05-22 01:36 259阅读 0赞

**一、About ZipKin**

please google

**二、 Demo Scene**

**![SouthEast][]**

**![SouthEast 1][]**

**![SouthEast 2][]**

**三、 Result Display**

**![SouthEast 3][]**

**![SouthEast 4][]**

**四、Prepare**

**1、soft version**

kafka：2.10-0.10.2.0  
zokeeper：3.4.10  
elasticsearch：5.2.2  
jdk：1.8  
spring boot：1.5.3.RELEASE  
sprign cloud：Dalston.RELEASE  
rabbit mq：3.6.9

**2、install**

kafka+zookeeper  
elasticsearch  
rabbit mq  
mysql

**3、create four spring cloud project**

web-api、user-api、order-api、zipkin  
ps:

why i will create zipkin project use spring boot by myself not use  zipkin.jar from http://zipkin.io/,actually，zipkin.jar is a spring boot project，check it's dependency lib you will find it din't use spring-cloud-sleuth-stream,but i will send trace info to kafka for zipkin server collector ,so i must use spring-cloud-sleuth-stream in my service

and the message send to kafka is a  sleuth.span object and use kafka default serialized，but zipkin.jar only receive zipkin.span and json or thrift encode,so it‘s not matching,That's the reason i create zipkin server

but if you use rabbit mq，that's no problem.

**4、configuration**

**4.1、the service web-api、user-api、order-api config part like:  
pom.xml**

**\[html\]** [view plain][] [copy][view plain]

[print][view plain] [?][view plain]

1.  <dependency>  
2.      <groupId>org.springframework.cloud</groupId>  
3.      <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>  
4.  </dependency>  
5.  <dependency>  
6.      <groupId>org.springframework.cloud</groupId>  
7.      <artifactId>spring-cloud-starter-stream-kafka</artifactId>  
8.  </dependency>

<dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-stream-kafka</artifactId>
    </dependency>

**application.properties**

**\[html\]** [view plain][] [copy][view plain]

[print][view plain] [?][view plain]

1.  spring.sleuth.sampler.percentage=1.0  
2.  spring.cloud.stream.kafka.binder.brokers=10.20.1.11:9092,10.20.1.12:9092  
3.  spring.cloud.stream.kafka.binder.zkNodes=10.20.1.11:2181,10.20.1.12:2181

spring.sleuth.sampler.percentage=1.0
    spring.cloud.stream.kafka.binder.brokers=10.20.1.11:9092,10.20.1.12:9092
    spring.cloud.stream.kafka.binder.zkNodes=10.20.1.11:2181,10.20.1.12:2181

**4.2、the zipkinconfig part like:**

**pom.xml**

**\[html\]** [view plain][] [copy][view plain]

[print][view plain] [?][view plain]

1.    
2.  <dependency>  
3.      <groupId>io.zipkin.java</groupId>  
4.      <artifactId>zipkin</artifactId>  
5.      <version>1.24.0</version>  
6.  </dependency>  
7.  <dependency>  
8.      <groupId>org.springframework.cloud</groupId>  
9.      <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>  
10. </dependency>  
11. <dependency>  
12.     <groupId>org.springframework.cloud</groupId>  
13.     <artifactId>spring-cloud-starter-stream-kafka</artifactId>  
14. </dependency>  
15. <dependency>  
16.     <groupId>io.zipkin.java</groupId>  
17.     <artifactId>zipkin-autoconfigure-storage-elasticsearch-http</artifactId>  
18.     <version>1.24.0</version>  
19.     <optional>true</optional>  
20. </dependency>

<dependency>
    	<groupId>io.zipkin.java</groupId>
    	<artifactId>zipkin</artifactId>
    	<version>1.24.0</version>
    </dependency>
    <dependency>
    	<groupId>org.springframework.cloud</groupId>
    	<artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>
    </dependency>
    <dependency>
    	<groupId>org.springframework.cloud</groupId>
    	<artifactId>spring-cloud-starter-stream-kafka</artifactId>
    </dependency>
    <dependency>
    	<groupId>io.zipkin.java</groupId>
    	<artifactId>zipkin-autoconfigure-storage-elasticsearch-http</artifactId>
    	<version>1.24.0</version>
    	<optional>true</optional>
    </dependency>

**application.properties**

**\[html\]** [view plain][] [copy][view plain]

[print][view plain] [?][view plain]

1.  \#kafka config  
2.  spring.sleuth.enabled=false  
3.  spring.sleuth.sampler.percentage=1.0  
4.  spring.cloud.stream.kafka.binder.brokers=10.20.1.11:9092,10.20.1.12:9092  
5.  spring.cloud.stream.kafka.binder.zkNodes=10.20.1.11:2181,10.20.1.12:2181  
6.  \#elasticsearch config  
7.  zipkin.storage.type=elasticsearch  
8.  zipkin.storage.elasticsearch.hosts=10.20.1.11:9200,10.20.1.12:9200  
9.  zipkin.storage.elasticsearch.cluster=elasticsearch  
10. zipkin.storage.elasticsearch.index=zipkin  
11. zipkin.storage.elasticsearch.index-shards=5  
12. zipkin.storage.elasticsearch.index-replicas=1

#kafka config
    spring.sleuth.enabled=false
    spring.sleuth.sampler.percentage=1.0
    spring.cloud.stream.kafka.binder.brokers=10.20.1.11:9092,10.20.1.12:9092
    spring.cloud.stream.kafka.binder.zkNodes=10.20.1.11:2181,10.20.1.12:2181
    #elasticsearch config
    zipkin.storage.type=elasticsearch
    zipkin.storage.elasticsearch.hosts=10.20.1.11:9200,10.20.1.12:9200
    zipkin.storage.elasticsearch.cluster=elasticsearch
    zipkin.storage.elasticsearch.index=zipkin
    zipkin.storage.elasticsearch.index-shards=5
    zipkin.storage.elasticsearch.index-replicas=1

**ZipKin Server Startup class configuration**

**\[java\]** [view plain][] [copy][view plain]

[print][view plain] [?][view plain]

1.  <span style="font-size:14px;">@SpringBootApplication  
2.  //@EnableZipkinServer //this is used by interface receive trace info  
3.  @EnableZipkinStreamServer //can be used kafka,rabbit  
4.  public class ZkingApplication \{  
5.      public static void main(String\[\] args) \{  
6.          SpringApplication.run(ZkingApplication.class, args);  
7.      \}  
8.  \}</span>

@SpringBootApplication //@EnableZipkinServer //this is used by interface receive trace info @EnableZipkinStreamServer //can be used kafka,rabbit public class ZkingApplication { public static void main(String[] args) { SpringApplication.run(ZkingApplication.class, args); } }

**五、Demo DownLoad**

**[click me][]**

![Center][]

by the way,spring cloud is a pretty boy,i like its combination of terseness and elegance

六、补充

如果kafka没有启动，spring boot会启动失败，这个异常处理设计的真是缺德

/\*\*  
 \* 1、修改背景  
 \* 因kafka节点没有启动 在spring boot启动时初始化outputBindingLifecycle、inputBindingLifecycle  
 \* 两个bean时候连接kafka失败，向外抛出了异常直到EmbeddedWebApplicationContext类  
 \* 捕获处理，处理方式为：stopAndReleaseEmbeddedServletContainer()导致整个应用停止启动  
 \* 2、修改方案  
 \* 干预上面两个bean的初始化，在连接kafka异常时，将异常处理掉，不向上层抛出  
 \* 3、修改步骤  
 \* 3.1、使用自定义MyBindingLifecycle的bean将BindingServiceConfiguration中的两个bean初始化替换掉  
 \* 3.2、在自定bean中启动线程MyBindingThread来控制两个bean的初始化  
 \* 4、解决启动问题之后，实际上kafka还是没有连接的，此时向kafka发送span时会失败，默认的处理方案是捕获到异常之后使用  
 \*   handleError处理，再次发送新的span，这就导致循环发送  
 \*   参见：ErrorHandlingTaskExecutor中的execute方法  
 \*   catch (Throwable t)  
 \*   \{  
 \*        ErrorHandlingTaskExecutor.this.errorHandler.handleError(t);  
 \*     \}  
 \* 5、解决方案  
 \* 重写ErrorHandler的handleError方法  
 \* 6、跟踪代码发现  
 \* 跟踪发现ErrorHandler对线对象是在SourcePollingChannelAdapterFactoryBean初始化时候设置的  
 \* spca.setErrorHandler(this.pollerMetadata.getErrorHandler());  
 \* 进一步发现是在pollerMetadata对象中，所以需要在pollerMetadata对象初始化时候做修改  
 \* 7、修改步骤  
 \* 自定义MyPollerMetadata且需要@Configuration，重写handleError方法如下  
 \* @author zhangdingxin、yangxi  
 \*/

[SouthEast]: /images/20220522/44340eb6c4184a28a21bfb91a2b5f580.png
[SouthEast 1]: /images/20220522/1c022387fc90490ba3023bb270445d00.png
[SouthEast 2]: /images/20220522/0f7ea49efbb643429e06bba6afcf85f7.png
[SouthEast 3]: /images/20220522/4dfd020b087642a79dfcc40016cc1a98.png
[SouthEast 4]: /images/20220522/77ab28e7dd504c02a35045a6d06930a9.png
[view plain]: https://blog.csdn.net/qq_15138455/article/details/72956232#
[click me]: http://download.csdn.net/detail/qq_15138455/9866125
[Center]: /images/20220522/6ac94c6df8ee49e39953a92b7a6fc222.png