Zipkin使用SpringCloud Stream以及Elasticsearch

我不是女神ヾ 2024-04-18 20:20 69阅读 0赞

![640?wx\_fmt=gif][640_wx_fmt_gif]

学习更多Java干货，戳上面的

蓝色字题

关注我！

在前面的文章中，我们已经成功的使用Zipkin收集了项目的调用链日志。但是呢，由于我们收集链路信息时采用的是http请求方式收集的，而且链路信息没有进行保存，ZipkinServer一旦重启后就会所有信息都会消失了。基于性能的考虑，我们可以对它进行改造，使用SpringCloud Stream进行消息传递，使用Elasticsearch进行消息的存储。

#### 参考文章 ####

Zipkin全链路监控  
  
SpringCloud-Stream整合RabbitMQ

#### 改造ZipkinServer ####

##### 1. 增加依赖 #####

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 10 </pre></td> 
 <td><pre>&lt;dependency&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&lt;groupId&gt;io.zipkin.java&lt;/groupId&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&lt;artifactId&gt;zipkin-autoconfigure-collector-rabbitmq&lt;/artifactId&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&lt;version&gt;2.11.8&lt;/version&gt; &nbsp; &nbsp; &nbsp; &nbsp;&lt;/dependency&gt; &nbsp; &nbsp; &nbsp; &nbsp;&lt;dependency&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&lt;groupId&gt;io.zipkin.java&lt;/groupId&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&lt;artifactId&gt;zipkin-autoconfigure-storage-elasticsearch-http&lt;/artifactId&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;&lt;version&gt;2.8.4&lt;/version&gt; &nbsp; &nbsp; &nbsp; &nbsp;&lt;/dependency&gt; </pre></td> 
 </tr> 
 </tbody> 
</table>

##### 2. 配置文件 #####

增加rabbit和es的相关配置

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 </pre></td> 
 <td><pre>zipkin: &nbsp;collector: &nbsp; &nbsp;rabbitmq: &nbsp; &nbsp; &nbsp;addresses: 10.0.20.132 &nbsp; &nbsp; &nbsp;port: 5672 &nbsp; &nbsp; &nbsp;username: root &nbsp; &nbsp; &nbsp;password: root &nbsp; &nbsp; &nbsp;virtual-host: /unicode-pay &nbsp; &nbsp; &nbsp;queue: zipkin &nbsp;storage: &nbsp; &nbsp;StorageComponent: elasticsearch &nbsp; &nbsp;type: elasticsearch &nbsp; &nbsp;elasticsearch: &nbsp; &nbsp; &nbsp;hosts: 10.0.20.25:9200 &nbsp; &nbsp; &nbsp;cluster: elasticsearch &nbsp; &nbsp; &nbsp;index: zipkin &nbsp; &nbsp; &nbsp;index-shards: 5 &nbsp; &nbsp; &nbsp;index-replicas: 1 </pre></td> 
 </tr> 
 </tbody> 
</table>

至此ZipkinServer的配置就搞定了。

##### 3. 客户端增加依赖 #####

以下两个依赖任选其一就可以

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 </pre></td> 
 <td><pre>&lt;dependency&gt; 			&lt;groupId&gt;org.springframework.amqp&lt;/groupId&gt; 			&lt;artifactId&gt;spring-rabbit&lt;/artifactId&gt; 		&lt;/dependency&gt; </pre></td> 
 </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 </pre></td> 
 <td><pre>&lt;dependency&gt; 			&lt;groupId&gt;org.springframework.boot&lt;/groupId&gt; 			&lt;artifactId&gt;spring-boot-starter-amqp&lt;/artifactId&gt; 		&lt;/dependency&gt; </pre></td> 
 </tr> 
 </tbody> 
</table>

##### 4. 客户端增加mq的相关配置 #####

注意要把以下配置去掉哦

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 </pre></td> 
 <td><pre>spring: &nbsp;zipkin: &nbsp; &nbsp;base-url: http://localhost:19411 &nbsp; &nbsp;sender: &nbsp; &nbsp; &nbsp;type: web </pre></td> 
 </tr> 
 </tbody> 
</table>

现在环境已经搭建完毕了，根据你的采样频率看一看结果如何吧

点击下方“阅读原文”查看源码！！！

![640?wx\_fmt=gif][640_wx_fmt_gif 1]

![640?wx\_fmt=jpeg][640_wx_fmt_jpeg]

点赞收藏转发好看再走呗!

![640?wx\_fmt=gif][640_wx_fmt_gif 2]

[640_wx_fmt_gif]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/aa4158b069294298a66f514492cada2b.gif
[640_wx_fmt_gif 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/38e775b47f534a8f8ad5182a7b6fba7a.gif
[640_wx_fmt_jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/f3bc2dcdce294af380423a527a91cd6e.png
[640_wx_fmt_gif 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/18/bd0e7029687f4a1fbcd42fb6fc340042.gif