乐趣区

spring-cloud-2x版本-SleuthZipkin分布式链路追踪补充内容rabbitmq日志收集

jiezi

前言 

 本文采用 Spring cloud 本文为 2.1.8RELEASE，version=Greenwich.SR3

本文基于前两篇文章 eureka-server、eureka-client、eureka-ribbon 和 spring-gateway 的实现。
参考

  • eureka-server
  • eureka-client
  • eureka-ribbon
  • spring-gateway

概述

前一篇文章讲述了 Sleuth 链路追踪的 http 的日志收集的搭建过程，这篇文章补充一下 rabbitmq 日志收集机制的搭建过程。
http 方式存在的问题，如果应用服务与 zipkin 服务端网络不通或者闪断的情况下，这种情况是无法正常收集的，而且 zipkin 默认是将数据存储在内存当中的，如果服务端重启或者宕机，数据就会丢失。
rabbitmq 的方式完美的解决了这种问题（用消息中间件的好处我这里就不过多阐述）。

1. 对原有应用进行改造

1.1 增加 pom 依赖

在 eureka-client、eureka-ribbon、spring-gateway 对应的 pom.xml 增加如下依赖：

<dependency>
    <groupId>org.springframework.amqp</groupId>
    <artifactId>spring-rabbit</artifactId>
</dependency>

说明：
最新官网已经不推荐使用 spring-cloud-sleuth-stream，而推荐使用 spring-rabbit。

  • 引用官网原文：spring-cloud-sleuth-stream is deprecated and incompatible with these destinations.

1.2 修改 application.yml 文件

修改 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/ 配置。

1.3 启动服务

启动 rabbitmq 和 zipkin 服务，这里需要说明的是, 启动 zipkin 服务输入如下命令启动：

    1. $ java -jar zipkin.jar --zipkin.collector.rabbitmq.addresses=localhost，
 默认 guest 账户。
    1. $ 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 方式相同的结果，如下图所示：

这时候我们访问 rabbitmq 的后台管理地址：http://localhost:15672, 可以在管理页面中的 Queues 中看到如下显示：
，说明 zipkin 服务帮我创建了一个名称为 zipkin 的 Queues。而 Exchanges 则默认使用的是 AMQP default，如下图所示：
、

至此，Sleuth+ZipKin 的 rabbitmq 的方式收集就搭建完成。

1.4 小结

Spring cloud Sleuth 分布式链路追踪不仅支持 rabbitmq，还支持 kafaka，实现过程和 rabbitmq 完全相同，只有修改对应的依赖包和配置就可以了，这里就不在演示。

代码地址

gitHub 地址

<center><font color=red>《Srping Cloud 2.X 小白教程》目录 </font></center>

  • spring cloud 2.x 版本 Eureka Server 服务注册中心教程
  • spring cloud 2.x 版本 Eureka Client 服务提供者教程
  • spring cloud 2.x 版本 Ribbon 服务发现教程 (内含集成 Hystrix 熔断机制)
  • spring cloud 2.x 版本 Feign 服务发现教程 (内含集成 Hystrix 熔断机制)
  • spring cloud 2.x 版本 Zuul 路由网关教程
  • spring cloud 2.x 版本 config 分布式配置中心教程
  • spring cloud 2.x 版本 Hystrix Dashboard 断路器教程
  • spring cloud 2.x 版本 Gateway 路由网关教程
  • spring cloud 2.x 版本 Gateway 自定义过滤器教程
  • spring cloud 2.x 版本 Gateway 熔断、限流教程
  • spring cloud 2.x 版本 Gateway 动态路由教程
  • spring cloud 2.x 版本 Sleuth+Zipkin 分布式链路追踪
  • spring cloud 2.x 版本 Sleuth+Zipkin 分布式链路追踪补充内容（rabbitmq 日志收集）
  • 写作不易，转载请注明出处，喜欢的小伙伴可以关注公众号查看更多喜欢的文章。
  • 联系方式：4272231@163.com

退出移动版