本文采用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彻底相同,只有修改对应的依赖包和配置就能够了,这里就不在演示。