Zipkin链路追踪HTTP与RabbitMQ方式

作者: Vernon | 来源:发表于2020-01-14 18:16 被阅读0次

Zipkin链路追踪HTTP与RabbitMQ方式
集成 zipkin 链路追踪
zipKin链路调用追踪
链路追踪sleuth and zipkin
SpringCloud-笔记11-Sleuth链路监控&Zipk
php zipkin客户端和阿里云链路追踪的使用
SpringCloud Sleuth Zipkin
链路追踪工具Zipkin整合
分布式链路追踪实践(二) - 基于 OpenTracing 设计
kubernetes---Jaeger部署

背景

上一篇只是单纯的从原理上以及控制台上去实践系统之间的打通，但是如果能从页面上去看每一个请求日志的链路情况就更好了。其实zipkin是提供了一个UI后台管理给到我们的。

注意点：关于 Zipkin 的服务端，在使用 Spring Boot 2.x 版本后，官方就不推荐自行定制编译了，反而是直接提供了编译好的 jar 包来给我们使用。具体请查阅：https://zipkin.io/pages/quickstart.html （最直接、权威的就是阅读官方网站）

curl -sSL https://zipkin.io/quickstart.sh | bash -s
java -jar zipkin.jar

快速上手

Zipkin 分为两端，一个是 Zipkin 服务端，一个是 Zipkin 客户端，客户端也就是微服务的应用。
客户端会配置服务端的 URL 地址，一旦发生服务间的调用的时候，会被配置在微服务里面的 Sleuth 的监听器监听，并生成相应的 Trace 和 Span 信息发送给服务端。
发送的方式主要有两种，一种是 HTTP 报文的方式，还有一种是消息总线的方式如 RabbitMQ。

不论哪种方式，我们都需要：

一个 Eureka 服务注册中心，这里我们就用之前的 eureka 项目来当注册中心。
一个 Zipkin 服务端。
三个微服务应用，trace-a 和 trace-b 和 trace-c，其中 trace-a 中有一个 REST 接口 /trace-a，调用该接口后将触发对 trace-b 应用的调用，最后调用trace-c。其实2个服务就够了~

环境说明

也是因为一些环境问题，总是导致ui后管一直没有数据，这次参考了很多文章一级官网网址来操作的，才得以显示数据。

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.2.RELEASE</version>
</parent>

<properties>
    <spring-cloud-dependencies.version>Finchley.RELEASE</spring-cloud-dependencies.version>
</properties>

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-dependencies</artifactId>
            <version>${spring-cloud-dependencies.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

方式一：通过HTTP

客户端的pom文件内容如下：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

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

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-logging</artifactId>
    </dependency>

    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
</dependencies>

客户端的properties文件内容如下：

spring.application.name=trace-a
server.port=10001

eureka.client.serviceUrl.defaultZone=http://localhost:8001/eureka/

spring.sleuth.web.client.enabled=true
spring.sleuth.sampler.probability=1.0
spring.zipkin.base-url=http://localhost:9411

# log trace detail
logging.level.org.springframework.web.servlet.DispatcherServlet=DEBUG

访问层部分Java代码如下：

package com.allei;

import java.util.concurrent.TimeUnit;

import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
@RestController
@EnableDiscoveryClient
@SpringBootApplication
@Slf4j
public class TraceAApplication {
    @Bean
    @LoadBalanced
    RestTemplate restTemplate() {
        return new RestTemplate();
    }

    @RequestMapping(value = "/trace-a", method = RequestMethod.GET)
    public String trace() throws InterruptedException {
        log.info("call trace-a----->");
        TimeUnit.SECONDS.sleep(1l);
        return restTemplate().getForEntity("http://trace-b/trace-b", String.class).getBody();
    }

    public static void main(String[] args) {
        SpringApplication.run(TraceAApplication.class, args);
    }
}

还是确定一下注册中心，保证服务都有起来。

http://static.cyblogs.com/WX20200113-155940@2x.png

通过上面的脚本拉取最新的zipkin服务，此时的版本是：2.19.2

➜  Desktop  curl -sSL https://zipkin.io/quickstart.sh | bash -s
Thank you for trying Zipkin!
This installer is provided as a quick-start helper, so you can try Zipkin out
without a lengthy installation process.

Fetching version number of latest io.zipkin:zipkin-server release...
Latest release of io.zipkin:zipkin-server seems to be 2.19.2

Downloading io.zipkin:zipkin-server:2.19.2:exec to zipkin.jar...

并且启动服务：嗯~ logo已经更换的更加的骚气~

➜  Desktop  java -jar zipkin.jar

                  oo
                 oooo
                oooooo
               oooooooo
              oooooooooo
             oooooooooooo
           ooooooo  ooooooo
          oooooo     ooooooo
         oooooo       ooooooo
        oooooo   o  o   oooooo
       oooooo   oo  oo   oooooo
     ooooooo  oooo  oooo  ooooooo
    oooooo   ooooo  ooooo  ooooooo
   oooooo   oooooo  oooooo  ooooooo
  oooooooo      oo  oo      oooooooo
  ooooooooooooo oo  oo ooooooooooooo
      oooooooooooo  oooooooooooo
          oooooooo  oooooooo
              oooo  oooo

     ________ ____  _  _____ _   _
    |__  /_ _|  _ \| |/ /_ _| \ | |
      / / | || |_) | ' / | ||  \| |
     / /_ | ||  __/| . \ | || |\  |
    |____|___|_|   |_|\_\___|_| \_|

:: version 2.19.2 :: commit 56d907b ::

当浏览器访问trace-a服务的时候，去后管页面查看就能看到服务列表以及日志情况。

图一：

http://static.cyblogs.com/WX20200113-145151@2x.png

图二：

http://static.cyblogs.com/WX20200113-145220@2x.png

方式二：RabbitMQ

安装RabbitMQ

➜  ~  brew install rabbitmq
Updating Homebrew...
==> Auto-updated Homebrew!
Updated 4 taps (homebrew/cask, caskroom/versions, caskroom/cask and adoptopenjdk/openjdk).

==> Downloading https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.8.0/rabbitmq-server-generic-unix-3.8.0.tar.xz
==> Downloading from https://github-production-release-asset-2e65be.s3.amazonaws.com/924551/71891480-e44b-11e9-80fd-c06739f04c5e?X-Amz-Algorith
######################################################################## 100.0%
==> /usr/bin/unzip -qq -j /usr/local/Cellar/rabbitmq/3.8.0/plugins/rabbitmq_management-3.8.0.ez rabbitmq_management-3.8.0/priv/www/cli/rabbitmq
==> Caveats
Management Plugin enabled by default at http://localhost:15672

Bash completion has been installed to:
  /usr/local/etc/bash_completion.d

To have launchd start rabbitmq now and restart at login:
  brew services start rabbitmq
Or, if you don't want/need a background service you can just run:
  rabbitmq-server
==> Summary
🍺  /usr/local/Cellar/rabbitmq/3.8.0: 277 files, 18.2MB, built in 34 seconds
==> `brew cleanup` has not been run in 30 days, running now...
Removing: /usr/local/Cellar/jpeg/9b... (20 files, 724KB)
Removing: /usr/local/Cellar/libpng/1.6.34... (26 files, 1.2MB)
Removing: /usr/local/Cellar/libtiff/4.0.8_5... (245 files, 3.4MB)
Removing: /usr/local/Cellar/wxmac/3.0.3.1_1... (810 files, 24.3MB)
Removing: /Users/chenyuan/Library/Caches/Homebrew/Cask/minikube--0.25.0... (41.3MB)
Removing: /Users/chenyuan/Library/Logs/Homebrew/go... (64B)
Removing: /Users/chenyuan/Library/Logs/Homebrew/readline... (64B)
Removing: /Users/chenyuan/Library/Logs/Homebrew/sqlite... (64B)
Removing: /Users/chenyuan/Library/Logs/Homebrew/kubernetes-cli... (64B)
Pruned 0 symbolic links and 2 directories from /usr/local

安装的路径在：/usr/local/Cellar/rabbitmq/3.8.0，利用brew安装软件速度可能会很慢，大家可以去更换一下源就变好了。但这个其实也不一定。

启动RabbitMQ

➜  sbin  rabbitmq-server

  ##  ##      RabbitMQ 3.8.0
  ##  ##
  ##########  Copyright (C) 2007-2019 Pivotal Software, Inc.
  ######  ##
  ##########  Licensed under the MPL.  See https://www.rabbitmq.com/

  Doc guides: https://rabbitmq.com/documentation.html
  Support:    https://rabbitmq.com/contact.html
  Tutorials:  https://rabbitmq.com/getstarted.html
  Monitoring: https://rabbitmq.com/monitoring.html

  Logs: /usr/local/var/log/rabbitmq/rabbit@localhost.log
        /usr/local/var/log/rabbitmq/rabbit@localhost_upgrade.log

  Config file(s): (none)

  Starting broker... completed with 6 plugins.

http://static.cyblogs.com/WX20200111-064208@2x.png

默认密码账号为guest/guest。登录进入后就能看到界面了。

http://static.cyblogs.com/WX20200111-064349@2x.png

配置客户端pom文件：

# 新加入
<dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
 </dependency>

为了觉得不是http的模式导致的数据，故意让地址写错

spring.zipkin.base-url=http://localhost:9412

然后客户端就什么都不用管了。但是服务端因为是下载的Jar的方式，让其支持RabbitMQ只能通过环境变量的方式来启动。

RABBIT_ADDRESSES=localhost java -jar zipkin.jar

这个时候会发现RabbitMQ会有一个zipkin的队列。

http://static.cyblogs.com/WX20200113-150636@2x.png

可配置的环境变量如下表所示：

属性	环境变量	描述
`zipkin.collector.rabbitmq.concurrency`	`RABBIT_CONCURRENCY`	并发消费者数量，默认为 `1`
`zipkin.collector.rabbitmq.connection-timeout`	`RABBIT_CONNECTION_TIMEOUT`	建立连接时的超时时间，默认为 `60000` 毫秒，即 1 分钟
`zipkin.collector.rabbitmq.queue`	`RABBIT_QUEUE`	从中获取 span 信息的队列，默认为 `zipkin`
`zipkin.collector.rabbitmq.uri`	`RABBIT_URI`	符合 RabbitMQ URI 规范的 URI，例如 `amqp://user:pass@host:10000/vhost`

如果设置了 URI，则以下属性将被忽略。

属性	环境变量	描述
`zipkin.collector.rabbitmq.addresses`	`RABBIT_ADDRESSES`	用逗号分隔的 RabbitMQ 地址列表，例如 `localhost:5672,localhost:5673`
`zipkin.collector.rabbitmq.password`	`RABBIT_PASSWORD`	连接到 RabbitMQ 时使用的密码，默认为 `guest`
`zipkin.collector.rabbitmq.username`	`RABBIT_USER`	连接到 RabbitMQ 时使用的用户名，默认为 `guest`
`zipkin.collector.rabbitmq.virtual-host`	`RABBIT_VIRTUAL_HOST`	使用的 RabbitMQ virtual host，默认为 `/`
`zipkin.collector.rabbitmq.use-ssl`	`RABBIT_USE_SSL`	设置为 `true` 则用 SSL 的方式与 RabbitMQ 建立链接

然后访问 http://localhost:10001/trace-a 并刷新 Zipkin UI，看到如下内容，就说明 Sleuth+Zipkin+RabbitMQ 整合成功了。

http://static.cyblogs.com/WX20200113-150738@2x.png

参考地址

https://www.cnblogs.com/mxmbk/p/9820936.html
https://juejin.im/post/5c3d4df0f265da61307517ad
https://github.com/openzipkin/zipkin
https://www.cnblogs.com/sxdcgaq8080/p/10007735.html
https://blog.csdn.net/u010046908/article/details/54773323
https://windmt.com/2018/04/24/spring-cloud-12-sleuth-zipkin/
https://zipkin.io/pages/quickstart.html
如果大家喜欢我的文章，可以关注个人订阅号。欢迎随时留言、交流。
简栈文化服务订阅号

Zipkin链路追踪HTTP与RabbitMQ方式
背景上一篇只是单纯的从原理上以及控制台上去实践系统之间的打通，但是如果能从页面上去看每一个请求日志的链路情况就更...
集成 zipkin 链路追踪
部署 server 端运行 jar 包启动, java 环境需要1.8以上使用 docker 端方式然后访问...
zipKin链路调用追踪
具体的链路调用追踪原理及实现这里就不说了，可以自行百度，这里简单记录下看源码的理解，方便日后回忆。首先介绍个概念...
链路追踪sleuth and zipkin
1/ sleuth 入门（1）修改微服务工程引入Sleuth依赖 <...
SpringCloud-笔记11-Sleuth链路监控&Zipk
Sleuth Zipkin查看链路情况分布式追踪系统数据采集数据存储数据展示 OpenTrace优势介绍 ...
php zipkin客户端和阿里云链路追踪的使用
选用阿里云的链路追踪优势在于不用自己搭建和维护这套系统，且支持jaeger、zipkin、skywalking客户...
SpringCloud Sleuth Zipkin
Zipkin Zipkin是一种分布式链路追踪系统。它有助于收集解决微服务架构中的延迟问题所需的时序数据。它管...
链路追踪工具Zipkin整合
前言 Zipkin 是一个开放源代码分布式的跟踪系统，每个服务向zipkin报告计时数据，zipkin会根据调用关...
分布式链路追踪实践(二) - 基于 OpenTracing 设计
上一章中有对分布式追踪链路方案 (Jaeger, Zipkin, SkyWalking 等) 进行了介绍，不同的方...
kubernetes---Jaeger部署
JaegerJaeger是Uber推出的一款调用链追踪系统，类似于Zipkin和Dapper，为微服务调用追踪而生...