Spring Cloud Sleuth Zipkin 升级使用
2017-12-18 09:34
881 查看
在之前的文章中我们是通过Http的方式来发送追踪的信息到ZipKin中,ZipKin中也是把数据存储在内存中做展示,党服务重启之后这些数据就没了,这边我们将介绍如何将数据存储起来,以及用消息队列来实现跟踪数据的发送,在高并发的环境下,使用http来发送数据会影响性能。
ZipKin的存储支持多种方式,Mysql, ES, 在数据量大的情况下我建议还是用ES进行存储,消息队列我们用RabbitMQ
首先改造我们的ZipKin Server项目,增加依赖,总的pom内容如下:
然后在启动类上加上@EnableZipkinStreamServer注解,把之前的@EnableZipkinServer去掉
配置里面增加ES和MQ的配置信息, ES用的2.4.1版本,RabbitMQ用的3.6.14
重新启动即可。
接下来我们就需要改造需要跟踪的具体服务了,也是要加入MQ的依赖信息,采用MQ来替换之前的http发送数据的方式
依赖如下:
配置中增加mq的配置即可
最后重启服务,然后调用接口,会发现数据已经到了ZipKin中,我们也可以通过查看ES中的数据来确认数据有没有存储成功
访问ES的地址查看当前所有的索引信息:
http://localhost:9200/_cat/indices
可以看到有一个zikin的索引,是按天来的
查询这个索引下的数据看看有没有数据:http://localhost:9200/zipkin-2017-11-30/_search
具体代码可以参考我的github:
https://github.com/yinjihuan/spring-cloud
ZipKin的存储支持多种方式,Mysql, ES, 在数据量大的情况下我建议还是用ES进行存储,消息队列我们用RabbitMQ
首先改造我们的ZipKin Server项目,增加依赖,总的pom内容如下:
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-stream-rabbit</artifactId> </dependency> <dependency> <groupId>io.zipkin.java</groupId> <artifactId>zipkin-server</artifactId> </dependency> <dependency> <groupId>io.zipkin.java</groupId> <artifactId>zipkin-autoconfigure-ui</artifactId> </dependency> <dependency> <groupId>io.zipkin.java</groupId> <artifactId>zipkin-autoconfigure-storage-elasticsearch-http</artifactId> <version>1.24.0</version> <optional>true</optional> </dependency>
然后在启动类上加上@EnableZipkinStreamServer注解,把之前的@EnableZipkinServer去掉
配置里面增加ES和MQ的配置信息, ES用的2.4.1版本,RabbitMQ用的3.6.14
zipkin.storage.StorageComponent=elasticsearch zipkin.storage.type=elasticsearch zipkin.storage.elasticsearch.cluster=elasticsearch-zipkin-cluster zipkin.storage.elasticsearch.hosts=127.0.0.1:9300 zipkin.storage.elasticsearch.max-requests=64 zipkin.storage.elasticsearch.index=zipkin zipkin.storage.elasticsearch.index-shards=5 zipkin.storage.elasticsearch.index-replicas=1 # rabbitmq配置 spring.rabbitmq.addresses=amqp://192.168.10.47:5672 spring.rabbitmq.username=yinjihuan spring.rabbitmq.password=123456
重新启动即可。
接下来我们就需要改造需要跟踪的具体服务了,也是要加入MQ的依赖信息,采用MQ来替换之前的http发送数据的方式
依赖如下:
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-sleuth-zipkin-stream</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-stream-rabbit</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-binder-rabbit</artifactId> </dependency>
配置中增加mq的配置即可
# rabbitmq配置 spring.rabbitmq.addresses=amqp://192.168.10.47:5672 spring.rabbitmq.username=yinjihuan spring.rabbitmq.password=123456
最后重启服务,然后调用接口,会发现数据已经到了ZipKin中,我们也可以通过查看ES中的数据来确认数据有没有存储成功
访问ES的地址查看当前所有的索引信息:
http://localhost:9200/_cat/indices
yellow open fangjia 5 1 35303 6463 72mb 72mb yellow open zipkin-2017-11-30 5 1 47 1 35.7kb 35.7kb
可以看到有一个zikin的索引,是按天来的
查询这个索引下的数据看看有没有数据:http://localhost:9200/zipkin-2017-11-30/_search
具体代码可以参考我的github:
https://github.com/yinjihuan/spring-cloud
相关文章推荐
- Spring Cloud Sleuth Zipkin 升级使用
- Spring Cloud Edgware新特性之九:Sleuth使用MQ方式整合Zipkin
- springcloud(十二):使用Spring Cloud Sleuth和Zipkin进行分布式链路跟踪
- springcloud(十二):使用Spring Cloud Sleuth和Zipkin进行分布式链路跟踪
- 使用Spring Cloud Sleuth和Zipkin进行分布式链路跟踪
- Spring Cloud搭建微服务架构----使用Zipkin做服务链路追踪
- 使用Spring Cloud Sleuth实现链路监控
- 使用Spring Cloud Sleuth实现链路监控
- springcloud 分布式服务跟踪sleuth+zipkin
- Spring Cloud Sleuth+Zipkin实践
- Spring Cloud(六):链路追踪Sleuth与Zipkin结合
- SpringCloud Sleuth 使用
- SpringCloud学习之sleuth&zipkin
- spring cloud学习进阶篇:Spring Cloud Sleuth + Zipkin 实现分布式跟踪解决方案
- springcloud+sleuth+zipkin+kafka+es
- SpringCloud sleuth一直为false,zipkin没有记录显示
- SpringCloud学习之sleuth&zipkin【二】
- Spring Cloud Sleuth服务链路追踪(zipkin)(转)
- spring-cloud-sleuth+zipkin追踪服务实现
- Spring Cloud Sleuth与Zipkin整合时遇到的问题记录