Zipkin 实践

上篇文章带领大家了解了 Zipkin 的基本概念，以及 Zipkin 中环境的搭建，现在是万事俱备只欠东风了，本文就来和大家聊一下这搭好的环境要如何使用。

创建 provider

要演示链路追踪，我需要提前准备好两个微服务，两个服务之间互相调用，然后我们来观察链路追踪情况。因此需要首先创建一个名为 zipkin 的 maven 父工程，然后在 zipkin 项目中创建一个名为 provider 的 module ，创建时分别添加 Web、Sleuth、RabbitMQ、Spring Cloud Stream 以及 Zipkin 依赖，如下：
图片描述

工程创建完成后，pom.xml 文件核心依赖如下：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-sleuth</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-stream-binder-rabbit</artifactId>
</dependency>

创建完成后，我们首先在 application.properties 中添加 stream、zipkin 以及 rabbitmq 相关的配置：

spring.application.name=provider
spring.sleuth.web.client.enabled=true
spring.sleuth.sampler.probability=1
spring.zipkin.base-url=http://localhost:9411
spring.zipkin.enabled=true
spring.zipkin.sender.type=rabbit
spring.rabbitmq.addresses=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
server.port=8080

这些配置有一些是大家面熟的，也有一些可能是第一次接触到的，主要是 sleuth 和 zipkin 的配置可能第一次接触，我这里就主要来介绍一下这两个相关的配置的含义吧：

spring.sleuth.web.client.enabled 表示开启链路追踪；
spring.sleuth.sampler.probability 表示追踪信息导出到 zipkin 的比例，这里默认是 0.1 ，即 10% 的追踪信息导出到 zipkin ，我们这里将之配置为 1 ；
spring.zipkin.base-url 表示指定 zipkin server 的地址；
spring.zipkin.base-url 表示开启 zipkin ；
spring.zipkin.sender.type 表示设置追踪信息的发送类型。

配置完成后，我们再添加一个 HelloController ，提供一个测试接口，如下：

@RestController
public class HelloController {
    @GetMapping("/hello")
    public String hello(String name) {
        return "hello " + name + " !";
    }
}

接下来我们就可以启动 provider 了。provider 启动成功之后，先放着，我们再来看 consumer 的创建。

创建 consumer

consumer 的创建和 provider 的步骤基本一致，需要添加的依赖以及 application.properties 中的配置都是一样的（除了项目启动端口不一致），因此这个步骤我就不再赘述，当 application.properties 配置完成后，我们在 consumer 中首先配置一个 RestTemplate 的 Bean ，如下：

@SpringBootApplication
public class ConsumerApplication {

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

    @Bean
    RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

注意，这里的 RestTemplate 的实例我没有开启负载均衡功能，所以这里主要是给大家展示链路追踪的用法，没有引入服务注册中心，因此也没有引入负载均衡的注解。最后再添加一个 Controller 去消费 provider 中提供的接口，如下：

@RestController
public class UseHelloController {
    @Autowired
    RestTemplate restTemplate;
    @GetMapping("/sayhello")
    public void hello() {
        String s = restTemplate.getForObject("http://localhost:8080/hello?name={1}", String.class, "javaboy");
        System.out.println(s);
    }
        
}