Spring Boot进阶(93)：体验式教程：手把手教你整合Spring Boot和Zipkin

📣前言

  分布式系统开发中，服务治理是一个比较重要的问题。为了更好地实现服务治理，需要解决服务跟踪问题，即如何对分布式系统中的服务进行监控和追踪。本文将介绍如何使用Zipkin进行服务跟踪，并结合Spring Boot进行整合和应用。

  那么，具体如何实现呢？这将又会是干货满满的一期，全程无尿点不废话只抓重点教，具有非常好的学习效果，拿好小板凳准备就坐！希望学习的过程中大家认真听好好学，学习的途中有任何不清楚或疑问的地方皆可评论区留言或私信，bug菌将第一时间给予解惑，那么废话不多说，直接开整！Fighting！！

🌊环境说明

开发工具：IDEA 2021.3
JDK版本： JDK 1.8
Spring Boot版本：2.3.1 RELEASE
Maven版本：3.8.2

🏆本文收录于《Spring Boot从入门到精通》，专门攻坚指数提升，2023 年国内最系统+最强（更新中）。

本专栏致力打造最硬核 Spring Boot 从零基础到进阶系列学习内容，🚀均为全网独家首发，打造精品专栏，专栏持续更新中…欢迎大家订阅持续学习。 如果想快速定位学习，可以看这篇【SpringBoot教程导航帖】,你想学习的都被收集在内，快速投入学习！！两不误。

🌊摘要

本文将简要介绍Zipkin的基本概念及其在服务跟踪中的应用，并详细讲解如何使用Spring Boot进行Zipkin的集成和应用，以及将Zipkin与ELK等技术进行整合。同时，本文还将分析Zipkin的优缺点，并提供测试用例和总结结论。

🌊正文

概述

  Zipkin是一个开源的分布式跟踪系统。它可以帮助开发人员更好地实现服务跟踪，并对于服务之间的调用关系和性能进行监控和追踪。Zipkin支持多种语言和框架，并且具有开箱即用的设计，使得它成为开发人员首选的服务跟踪工具。

搭建Spring Boot应用

  首先，我们先创建个基础的Spring Boot项目，如果还不会点这里，此处就不详细赘述啦。

Spring Boot集成教学

  Spring Boot与Zipkin的集成非常的简单，只需要进行以下几个步骤即可：

  1. 添加相关依赖
   <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-zipkin</artifactId></dependency>
  1. 在application.yml或者application.properties中添加相关配置
   spring.zipkin.base-url=http://localhost:9411

  在这里，我们将Zipkin Server的地址设置为本地地址：http://localhost:9411，这是Zipkin Server的默认地址，也是我们在本地测试中常用的地址。

  1. 添加注解@EnableZipkinServer或者@EnableZipkinStreamServer
   @SpringBootApplication@EnableZipkinServerpublic class ZipkinServerApplication {public static void main(String[] args) {SpringApplication.run(ZipkinServerApplication.class, args);}}

  这里我们使用的是@EnableZipkinServer注解，表示我们正在启用Zipkin Server。如果你想采用Zipkin Stream方式，则可以使用@EnableZipkinStreamServer注解替代。

  在完成以上步骤后，我们就可以启动Zipkin Server并将其集成到Spring Boot应用中了。

应用场景案例

  下面我们以微服务环境下用户服务调用订单服务为例，介绍Zipkin在服务跟踪中的应用。

  当用户请求用户服务的时候，如果需要调用订单服务，则用户服务将向Zipkin提交一个Span，表示这是一个新的跟踪点。当用户服务完成对订单服务的调用后，会再次向Zipkin提交一个Span，表示这个跟踪点已经结束。这样，我们就可以在Zipkin中很方便地进行服务跟踪，并查看服务之间的调用关系。

  通过Zipkin，我们可以清晰地查看服务之间的调用关系，并方便地定位服务问题。

实战教学

  接下来我们就来介绍如何在Spring Boot应用中实现Zipkin的服务跟踪。我们将采用上述的用户服务和订单服务的例子进行说明。

创建Spring Boot应用

首先，我们需要创建一个Spring Boot应用，以用户服务为例。

@SpringBootApplication
@RestController
public class UserServiceApplication {@Autowiredprivate RestTemplate restTemplate;private static final Logger LOG = LoggerFactory.getLogger(UserServiceApplication.class);@RequestMapping("/getUserInfo")public String getUserInfo() {LOG.info("Get user info...");String orderServiceUrl = "http://localhost:8082/getOrderInfo";String response = restTemplate.getForObject(orderServiceUrl, String.class);return "user service response: " + response;}public static void main(String[] args) {SpringApplication.run(UserServiceApplication.class, args);}
}

  在上述代码中，我们创建了一个名为UserServiceApplication的Spring Boot应用，用于返回用户信息。在getUserInfo方法中，我们使用RestTemplate对象调用订单服务，获取订单信息。需要注意的是，此处我们只是简单的调用了订单服务，没有涉及任何服务跟踪的操作。

集成Zipkin

  在完成用户服务的创建后，我们需要集成Zipkin，以便进行服务跟踪。按照Spring Boot集成教学中的步骤，我们可以很方便地集成Zipkin。

在application.yml中添加以下配置：

spring.application.name=user-service
spring.zipkin.base-url=http://localhost:9411

  这里我们指定了应用名称和Zipkin Server的地址，以便Zipkin能够正确地将服务跟踪到当前的应用中。

  接下来，我们需要创建一个RestTemplate实例，并使用Zipkin将其进行包装。

@Bean
public RestTemplate restTemplate() {return new RestTemplate(new OkHttp3ClientHttpRequestFactory()).builder().additionalInterceptor(new TraceIdRequestInterceptor()).additionalInterceptor(new TraceRequestInterceptor()).build();
}

  在这里，我们创建了一个RestTemplate实例，并使用TraceIdRequestInterceptor和TraceRequestInterceptor对其进行包装。这两个拦截器的作用是在进行服务调用的时候，向Zipkin Server进行跟踪并生成Span。

public class TraceIdRequestInterceptor implements ClientHttpRequestInterceptor {@Overridepublic ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {request.getHeaders().add("X-B3-TraceId", String.valueOf(Tracing.currentTracer().getCurrentSpan().context().traceId()));return execution.execute(request, body);}
}public class TraceRequestInterceptor implements ClientHttpRequestInterceptor {@Overridepublic ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {Span span = Tracing.currentTracer().nextSpan();span.name(request.getURI().toString());try (Tracer.SpanInScope ws = Tracing.currentTracer().withSpanInScope(span)) {span.start();request.getHeaders().add("X-B3-SpanId", String.valueOf(span.context().spanId()));ClientHttpResponse response = execution.execute(request, body);span.finish();return response;} catch (RuntimeException | IOException | Error e) {span.error(e);throw e;}}
}

  在上述代码中，TraceIdRequestInterceptor用于生成TraceId，并将其添加到请求头中；TraceRequestInterceptor用于生成Span，并在Span范围内执行请求。

  最后，我们需要添加@EnableZipkinTracing注解，以启用Zipkin跟踪。

@SpringBootApplication
@RestController
@EnableZipkinTracing
public class UserServiceApplication {...}

  这样，我们就可以在Spring Boot应用中进行Zipkin服务跟踪了。

测试服务跟踪

  在完成用户服务的创建和Zipkin集成后，我们需要进行测试，看看Zipkin是否能够正确地跟踪服务。

在完成服务启动后，我们可以通过浏览器的方式进行测试。

访问：http://localhost:8081/getUserInfo

具体操作

  在上述教学中，我们已经介绍了如何在Spring Boot应用中集成Zipkin，并进行服务跟踪。但是，在实际的应用中，我们还需要更加完善的操作，以便更好地使用Zipkin进行服务治理。

1. 使用Feign进行服务调用

  上述教学中，我们使用的是RestTemplate进行服务调用。但是，在Spring Cloud中，我们推荐使用Feign进行服务调用，因为Feign具有更加简单、直观和方便的服务调用方式。

使用Feign进行服务调用非常简单，只需要添加以下依赖：

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

  然后，在应用启动类上添加@EnableFeignClients注解即可。接下来，我们需要创建一个Feign客户端，用于调用订单服务：

@FeignClient(name = "order-service")
public interface OrderServiceClient {@GetMapping("/getOrderInfo")String getOrderInfo();}

  在上述代码中，我们创建了一个名为OrderServiceClient的Feign客户端，并使用@GetMapping注解指定了调用的地址。接下来，在用户服务中调用该服务：

@Autowired
private OrderServiceClient orderServiceClient;@RequestMapping("/getUserInfo")
public String getUserInfo() {LOG.info("Get user info...");String response = orderServiceClient.getOrderInfo();return "user service response: " + response;
}

  这样，我们就使用了Feign进行服务调用。因为Feign已经集成了Zipkin，所以我们无需进行任何额外的配置即可实现服务跟踪。

2. Zipkin数据持久化

  在使用Zipkin进行服务跟踪的同时，我们还需要进行数据的持久化操作。Zipkin支持多种数据存储方式，包括In-Memory、MySql、Elasticsearch等。在本教学中，我们将使用Elasticsearch进行数据持久化。

首先，我们需要添加以下依赖：

<dependency><groupId>io.zipkin.java</groupId><artifactId>zipkin-autoconfigure-storage-elasticsearch-http</artifactId><version>${zipkin.version}</version>
</dependency>

然后，在application.yml中添加以下配置：

spring.zipkin.storage.type: elasticsearch
spring.zipkin.storage.elasticsearch.base-url: http://localhost:9200

这里我们指定了Zipkin存储数据的方式为Elasticsearch，并指定了Elasticsearch的地址。

最后，我们还需要添加数据存储的索引：

curl -XPUT 'http://localhost:9200/zipkin' -d '{"settings":{"index":{"number_of_shards":1,"number_of_replicas":0}}
}'

这样，我们就完成了Zipkin数据持久化的操作。

拓展操作

1. 将Zipkin与ELK整合

  除了使用Elasticsearch对Zipkin进行数据持久化外，我们还可以将Zipkin与ELK进行整合，以便实现更好的服务跟踪和日志分析功能。

首先，我们需要添加以下依赖：

<dependency><groupId>io.zipkin.java</groupId><artifactId>zipkin-autoconfigure-ui</artifactId><scope>runtime</scope>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-zipkin-elasticsearch</artifactId>
</dependency>

然后，在application.yml中添加以下配置：

spring.cloud.stream.kafka.binder.zkNodes: localhost:2181
spring.cloud.stream.bindings.zipkinStream.group: zipkin
spring.zipkin.sender.type: rabbit
spring.zipkin.sender.rabbitmq.addresses: localhost:5672
spring.zipkin.sender.rabbitmq.username: guest
spring.zipkin.sender.rabbitmq.password: guest
spring.zipkin.collector.rabbitmq.queue: zipkin
spring.zipkin.collector.rabbitmq.connection-timeout: 5000
spring.zipkin.collector.rabbitmq.concurrency: 1
spring.zipkin.collector.rabbitmq.exchange: zipkin-exchange
spring.zipkin.collector.rabbitmq.routing-key: zipkinzipkin.storage.type: elasticsearch
zipkin.storage.elasticsearch.hosts: http://localhost:9200
zipkin.ui.static.queries: classpath:/zipkin-elasticsearch-queries.json

  在这里，我们指定了Zipkin数据的发送方式为RabbitMQ，并将Zipkin数据发送至Elasticsearch中进行存储。同时，我们还指定了Zipkin UI的静态查询文件。

  接下来，我们需要在ELK中创建相应的索引。以Logstash为例，我们可以使用以下的配置:

input {rabbitmq {host => "localhost"queue => "zipkin"durable => trueexclusive => falseauto_delete => falseuser => "guest"password => "guest"codec => "json"exchange => "zipkin-exchange"key => "zipkin"heartbeat => 10add_field => {"[@metadata][routing_key]" => "%{routing_key}"}}
}
filter {json {source => "message"add_field => {"[@metadata][collector_timestamp]" => "%{timestamp}"}}date {match => ["[@metadata][collector_timestamp]", "UNIX_MS"]target => "@timestamp"}
}output {if [@metadata][routing_key] == "zipkin" {elasticsearch {hosts => ["http://localhost:9200"]manage_template => falseindex => "zipkin-%{+YYYY.MM.dd}"document_type => "span"}}
}

  在完成以上配置后，我们就可以通过ELK实现更好的服务跟踪和日志分析功能。

2. 使用Zipkin进行性能监控

  除了服务跟踪和日志分析外，Zipkin还可以用于性能监控。我们可以通过Zipkin记录服务调用时间和性能瓶颈，从而找出服务的性能问题并进行优化。

  具体操作非常简单，只需要在Zipkin中查看服务调用耗时和性能瓶颈即可。在Zipkin的UI中，我们可以点击Span，并查看其下方的Timing和Dependencies选项卡，以便获得更多的性能信息。

总结

  本文主要介绍了如何使用Spring Boot进行Zipkin集成和应用，以及将Zipkin与ELK等技术进行整合。通过本文的学习，我们可以掌握Zipkin的基本概念和操作，从而更好地实现服务跟踪、性能监控和日志分析等功能。

… …

  ok，以上就是我这期的全部内容啦，如果还想学习更多，你可以看看如下的往期热文推荐哦，每天积累一个奇淫小知识，日积月累下去，你一定能成为令人敬仰的大佬。

「赠人玫瑰，手留余香」，咱们下期拜拜~~

🌊 热文推荐

滴~如下推荐【Spring Boot 进阶篇】的学习大纲，请小伙伴们注意查收。

Spring Boot进阶(01)：Spring Boot 集成 Redis，实现缓存自由

Spring Boot进阶(02)：使用Validation进行参数校验

Spring Boot进阶(03)：如何使用MyBatis-Plus实现字段的自动填充

Spring Boot进阶(04)：如何使用MyBatis-Plus快速实现自定义sql分页

Spring Boot进阶(05)：Spring Boot 整合RabbitMq，实现消息队列服务

Spring Boot进阶(06)：Windows10系统搭建 RabbitMq Server 服务端

Spring Boot进阶(07)：集成EasyPoi，实现Excel/Word的导入导出

Spring Boot进阶(08)：集成EasyPoi，实现Excel/Word携带图片导出

Spring Boot进阶(09)：集成EasyPoi，实现Excel文件多sheet导入导出

Spring Boot进阶(10)：集成EasyPoi，实现Excel模板导出成PDF文件

Spring Boot进阶(11)：Spring Boot 如何实现纯文本转成.csv格式文件？

Spring Boot进阶(12)：Spring Boot 如何获取Excel sheet页的数量？

Spring Boot进阶(13)：Spring Boot 如何获取@ApiModelProperty(value = “序列号“, name = “uuid“)中的value值name值？

Spring Boot进阶(14)：Spring Boot 如何手动连接库并获取指定表结构？一文教会你

Spring Boot进阶(15)：根据数据库连接信息指定分页查询表结构信息

Spring Boot进阶(16)：Spring Boot 如何通过Redis实现手机号验证码功能？

Spring Boot进阶(17)：Spring Boot如何在swagger2中配置header请求头等参数信息

Spring Boot进阶(18)：SpringBoot如何使用@Scheduled创建定时任务？

Spring Boot进阶(19)：Spring Boot 整合ElasticSearch

Spring Boot进阶(20)：配置Jetty容器

Spring Boot进阶(21)：配置Undertow容器

Spring Boot进阶(22)：Tomcat与Undertow容器性能对比分析

Spring Boot进阶(23)：实现文件上传

Spring Boot进阶(24)：如何快速实现多文件上传？

Spring Boot进阶(25)：文件上传的单元测试怎么写?

Spring Boot进阶(26)：Mybatis 中 resultType、resultMap详解及实战教学

Spring Boot进阶(27)：Spring Boot 整合 kafka(环境搭建+演示)

Spring Boot进阶(28)：Jar包Linux后台启动部署及滚动日志查看，日志输出至实体文件保存

Spring Boot进阶(29)：如何正确使用@PathVariable，@RequestParam、@RequestBody等注解？不会我教你，结合Postman演示

Spring Boot进阶(30)：@RestController和@Controller 注解使用区别，实战演示

… …

  若想系统完整的从0到1的学习，可以参考这篇专栏总结《2023最新首发，全网最全 Spring Boot 学习宝典(附思维导图)》，本专栏致力打造最硬核 Spring Boot 进阶系列学习内容，🚀均为全网独家首发，打造精品专栏，专栏持续更新中。欢迎大家订阅持续学习。

  如果想快速定位学习，可以看这篇【教程导航帖】导航目录,你想学习的都被收集在内，快速投入学习！！两不误。

  在入门及进阶之途，我必助你一臂之力，系统性学习，从入门到精通，带你不走弯路，直奔终点；投资自己，永远性价比最高，都这么说了，你还不赶紧来学？？

  本文涉及所有源代码，均已上传至GitHub开源，供同学们一对一参考 GitHub传送门，同时，原创开源不易，欢迎给个star🌟，想体验下被🌟的感jio，非常感谢❗

📣文末

我是bug菌，CSDN | 阿里云 | 华为云 | 51CTO 等社区博客专家，历届博客之星Top30，掘金年度人气作者Top40，51CTO年度博主Top12，掘金 | InfoQ | 51CTO等社区优质创作者，全网粉丝合计15w+ ；硬核微信公众号「猿圈奇妙屋」，欢迎你的加入！免费白嫖最新BAT互联网公司面试题、4000G pdf电子书籍、简历模板等海量资料。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/151936.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

docker - win10 家庭版 开始虚拟化

docker - win10 家庭版 开始虚拟化

文章目录 前言docker - win10 家庭版 开始虚拟化 前言 如果您觉得有用的话&#xff0c;记得给博主点个赞&#xff0c;评论&#xff0c;收藏一键三连啊&#xff0c;写作不易啊^ _ ^。   而且听说点赞的人每天的运气都不会太差&#xff0c;实在白嫖的话&#xff0c;那欢迎常来啊…
阅读更多...
Servlet 与Spring对比！

Servlet 与Spring对比！

前言&#xff1a; Spring相关的框架知识&#xff0c;算是目前公司在用的前沿知识了&#xff0c;很重要&#xff01;&#xff01; 那么以Spring为基础的框架有几个&#xff1f; 以Spring为基础的框架包括若干模块&#xff0c;其中主要的有Spring Framework、Spring Boot、Spring…
阅读更多...
mysql数据库和sql语句

mysql数据库和sql语句

数据库概念 数据&#xff1a;数字信息 据&#xff1a;对一系列对象具体属性的描述的集合 数据库&#xff1a;数据库就是用来组织&#xff08;各个数据之间有联系&#xff0c;是按照改规则组织起来的&#xff09;&#xff0c;存储和管理&#xff08;对数据库的增删改查&#xf…
阅读更多...
从工厂到社会：探索如何应用设计模式工厂模式

从工厂到社会：探索如何应用设计模式工厂模式

文章目录 &#x1f31f; 将设计模式工厂模式运用到社会当中&#x1f34a; 工厂模式在社会中的应用&#x1f389; 工厂&#x1f389; 餐厅&#x1f389; 运输 &#x1f34a; 工厂模式的优势&#x1f389; 代码简洁&#x1f389; 扩展性强&#x1f389; 便于维护和管理 &#x1f…
阅读更多...
APP自动化测试 ---- Appium介绍及运行原理

APP自动化测试 ---- Appium介绍及运行原理

在面试APP自动化时&#xff0c;有的面试官可能会问Appium的运行原理&#xff0c;以下介绍Appium运行原理。 一、Appium介绍 1.Appium概念 Appium是一个开源测试自动化框架&#xff0c;可用于原生&#xff0c;混合和移动Web应用程序测试。它使用WebDriver协议驱动IOS&#xf…
阅读更多...
2.Vue — 模板语法、数据绑定、el与data的写法、数据代理

2.Vue — 模板语法、数据绑定、el与data的写法、数据代理

文章目录 一、模板语法1.1 插值语法1.2指令语法 二、数据绑定语法2.1 单向数据绑定2.2 双向数据绑定 三、el与data的两种写法3.1 el3.2 data 四、数据代理4.1 Object.defineProperty4.2 Vue数据代理4.2.1 展示数据代理4.2.2 Vue数据代理 一、模板语法 root容器里面的代码被称为…
阅读更多...
C++入门精讲——入门看完这一篇就够了

C++入门精讲——入门看完这一篇就够了

文章目录 前言1. C发展历史2. 关键字3. 命名空间3.1 命名空间的概念3.2 命名空间的定义3.3 命名空间的使用 4. C输入、输出5. 缺省参数5.1 全缺省5.2 半缺省 6. 函数重载6.1 几种不同类型的函数重载6.2 函数重载的原理——名字修饰(name Mangling)6.2.1 C程序为什么不支持函数重…
阅读更多...
Python爬虫基础之Requests详解

Python爬虫基础之Requests详解

目录 1. 简介2. 安装3. 发送请求4. 处理响应5. IP代理6. Cookie登录参考文献 原文地址&#xff1a;https://program-park.top/2023/10/27/reptile_4/ 本文章中所有内容仅供学习交流使用&#xff0c;不用于其他任何目的&#xff0c;严禁用于商业用途和非法用途&#xff0c;否则由…
阅读更多...
如何使用gpt提高效率

如何使用gpt提高效率

如何使用gpt提高效率 自动化替代人力工作减少创意工作需求技术依赖风险实际应用领域内容生成自动回答问题自动化编程个性化推荐 博主 默语带您 Go to New World. ✍ 个人主页—— 默语 的博客&#x1f466;&#x1f3fb; 《java 面试题大全》 &#x1f369;惟余辈才疏学浅&…
阅读更多...
Android [SPI,AutoSerivce,ServiceLoader]

Android [SPI,AutoSerivce,ServiceLoader]

记录一下在Android中使用SPI的过程。 1.项目gralde文件。 plugins {id kotlin-kapt } dependencies {implementation com.google.auto.service:auto-service:1.0-rc7 kapt "com.google.auto.service:auto-service:1.0-rc7" } 这个AutoServ…
阅读更多...
基于51单片机的温度测量报警系统的设计与制作

基于51单片机的温度测量报警系统的设计与制作

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、实习目的二、实习任务2.1 设计温度测量报警系统硬件电路2.2 温度测量报警系统软件编程、仿真与调试&#xff1b;2.3 完成温度测量报警系统的实物制作与调试…
阅读更多...
LVS-DR模式+keepalived+nginx+tomcat实现动静分离、负载均衡、高可用实验

LVS-DR模式+keepalived+nginx+tomcat实现动静分离、负载均衡、高可用实验

实验条件&#xff1a; test2——20.0.0.20——主服务器——ipvsadm、keepalived服务 test3——20.0.0.30——备服务器——ipvsadm、keepalived服务 nginx5——20.0.0.51——后端真实服务器1&#xff08;tomcat的代理服务器&#xff09;——nginx服务 nginx6——20.0.0.61—…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023