Zipkin实现基于RabbitMQ存储链路信息至ELasticsearch

• 1、启动Elasticsearch集群
• 2、部署Zipkin服务端
• 3、查看索引库
• 4、客户端添加依赖
• 5、客户端配置文件
• 6、测试

1、启动Elasticsearch集群

本文使用的Elasticsearch集群地址为：

• 192.168.10.101:9200
• 192.168.10.102:9200
• 192.168.10.103:9200

启动集群，访问：http://192.168.10.101:9200/_cluster/health?pretty 结果如下：
 

 
 
启动head插件，访问：http://192.168.10.101:9200/ 结果如下：
 

 

2、部署Zipkin服务端

添加启动参数，重新部署服务端

官网地址：https://github.com/openzipkin/zipkin/blob/master/zipkin-server/src/main/resources/zipkin-server-shared.yml
 

java -jar zipkin-server-2.20.1-exec.jar --STORAGE_TYPE=elasticsearch --ES_HOSTS=http://192.168.10.101:9200/,http://192.168.10.102:9200/,http://192.168.10.103:9200/ --RABBIT_ADDRESSES=192.168.10.101:5672 --RABBIT_USER=guest --RABBIT_PASSWORD=guest --RABBIT_VIRTUAL_HOST=/ --RABBIT_QUEUE=zipkin

启动参数中包含Elasticsearch和RabbitMQ的配置，实现基于MQ并存储链路信息至Elasticsearch
 

3、查看索引库

访问：http://192.168.10.101:9200/ 可以看到已经创建好了 zipkin索引库。
 

 

4、客户端添加依赖

官网文档：https://cloud.spring.io/spring-cloud-static/spring-cloud-sleuth/2.2.1.RELEASE/reference/html/#sleuth-with-zipkin-over-rabbitmq-or-kafka
 

    org.springframework.cloud
    spring-cloud-starter-zipkin



    org.springframework.amqp
    spring-rabbit

5、客户端配置文件

6、测试

访问：http://localhost:9000/order-service/order/1 查看索引库结果如下：