本文采用Spring cloud本文爲2.1.8RELEASE,version=Greenwich.SR3 java
本文基於前兩篇文章eureka-server、eureka-client、eureka-ribbon和spring-gateway的實現。 參考git
前一篇文章講述了Sleuth鏈路追蹤的http的日誌收集的搭建過程,這篇文章補充一下rabbitmq日誌收集機制的搭建過程。 http方式存在的問題,若是應用服務與zipkin服務端網絡不通或者閃斷的狀況下,這種狀況是沒法正常收集的,並且zipkin默認是將數據存儲在內存當中的,若是服務端重啓或者宕機,數據就會丟失。 rabbitmq的方式完美的解決了這種問題(用消息中間件的好處我這裏就不過多闡述)。github
在eureka-client、eureka-ribbon、spring-gateway對應的pom.xml增長以下依賴:web
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
</dependency>
複製代碼
說明: 最新官網已經不推薦使用
spring-cloud-sleuth-stream
,而推薦使用spring-rabbit
。spring
- 引用官網原文:
spring-cloud-sleuth-stream is deprecated and incompatible with these destinations.
修改eureka-client、eureka-ribbon、spring-gateway應用對應的application.yml配置文件,參考以下配置:網絡
spring:
sleuth:
sampler:
probability: 1
web:
enabled: true
zipkin:
sender:
type: rabbit
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
複製代碼
要刪除http方式的
zipkin.base-url: http://localhost:9411/
配置。app
啓動rabbitmq和zipkin服務,這裏須要說明的是,啓動zipkin服務輸入以下命令啓動:分佈式
$ java -jar zipkin.jar --zipkin.collector.rabbitmq.addresses=localhost
, 默認guest帳戶。
$ java -jar zipkin.jar --zipkin.collector.rabbitmq.addresses=localhost --zipkin.collector.rabbitmq.username=xxx --zipkin.collector.rabbitmq.password=xxx
,啓動自定義用戶名和密碼。
而後順序啓動eureka-client、eureka-ribbon、spring-gateway應用服務。 訪問http://localhost:8100/ribbon/sayHello
, 能夠多刷新幾回,而後咱們能夠訪問http://localhost:9411/zipkin
,點擊查詢能夠到和http方式相同的結果,以下圖所示:post
這時候咱們訪問rabbitmq的後臺管理地址:http://localhost:15672
, 能夠在管理頁面中的Queues中看到以下顯示: url
AMQP default
,以下圖所示: 、
至此,Sleuth+ZipKin的rabbitmq的方式收集就搭建完成。
Spring cloud Sleuth分佈式鏈路追蹤不只支持rabbitmq,還支持kafaka,實現過程和rabbitmq徹底相同,只有修改對應的依賴包和配置就能夠了,這裏就不在演示。