好网站的建设标准,建设一个网站需要什么安全设备,网站空间购买费用,盐步网站制作通过上一篇《分布式服务跟踪#xff08;整合logstash#xff09;》#xff0c;我们虽然已经能够利用ELK平台提供的收集、存储、搜索等强大功能#xff0c;对跟踪信息的管理和使用已经变得非常便利。但是#xff0c;在ELK平台中的数据分析维度缺少对请求链路中各阶段时间延… 通过上一篇《分布式服务跟踪整合logstash》我们虽然已经能够利用ELK平台提供的收集、存储、搜索等强大功能对跟踪信息的管理和使用已经变得非常便利。但是在ELK平台中的数据分析维度缺少对请求链路中各阶段时间延迟的关注很多时候我们追溯请求链路的一个原因是为了找出整个调用链路中出现延迟过高的瓶颈源亦或是为了实现对分布式系统做延迟监控等与时间消耗相关的需求这时候类似ELK这样的日志分析系统就显得有些乏力了。对于这样的问题我们就可以引入Zipkin来得以轻松解决。 Zipkin简介
Zipkin是Twitter的一个开源项目它基于Google Dapper实现。我们可以使用它来收集各个服务器上请求链路的跟踪数据并通过它提供的REST API接口来辅助我们查询跟踪数据以实现对分布式系统的监控程序从而及时地发现系统中出现的延迟升高问题并找出系统性能瓶颈的根源。除了面向开发的API接口之外它也提供了方便的UI组件来帮助我们直观的搜索跟踪信息和分析请求链路明细比如可以查询某段时间内各用户请求的处理时间等。 上图展示了Zipkin的基础架构它主要有4个核心组件构成
Collector收集器组件它主要用于处理从外部系统发送过来的跟踪信息将这些信息转换为Zipkin内部处理的Span格式以支持后续的存储、分析、展示等功能。Storage存储组件它主要对处理收集器接收到的跟踪信息默认会将这些信息存储在内存中我们也可以修改此存储策略通过使用其他存储组件将跟踪信息存储到数据库中。RESTful APIAPI组件它主要用来提供外部访问接口。比如给客户端展示跟踪信息或是外接系统访问以实现监控等。Web UIUI组件基于API组件实现的上层应用。通过UI组件用户可以方便而有直观地查询和分析跟踪信息。
HTTP收集
在Spring Cloud Sleuth中对Zipkin的整合进行了自动化配置的封装所以我们可以很轻松的引入和使用它下面我们来详细介绍一下Sleuth与Zipkin的基础整合过程。主要分为两步
第一步搭建Zipkin Server
创建一个基础的Spring Boot应用命名为zipkin-server并在pom.xml中引入Zipkin Server的相关依赖具体如下
parent groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-parent/artifactId version1.5.10.RELEASE/version relativePath//parentdependencies dependency groupIdio.zipkin.java/groupId artifactIdzipkin-server/artifactId /dependency dependency groupIdio.zipkin.java/groupId artifactIdzipkin-autoconfigure-ui/artifactId /dependency/dependenciesdependencyManagement dependencies dependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-dependencies/artifactId versionDalston.SR5/version typepom/type scopeimport/scope /dependency /dependencies/dependencyManagement创建应用主类ZipkinApplication使用EnableZipkinServer注解来启动Zipkin Server具体如下
EnableZipkinServerSpringBootApplicationpublic class ZipkinApplication { public static void main(String[] args) { SpringApplication.run(ZipkinApplication.class, args); }}在application.properties中做一些简单配置比如设置服务端口号为9411客户端整合时候自动化配置会连接9411端口所以在服务端设置了端口为9411的话客户端可以省去这个配置。
spring.application.namezipkin-serverserver.port9411创建完上述工程之后我们将其启动起来并访问http://localhost:9411/我们可以看到如下图所示的Zipkin管理页面 第二步为应用引入和配置Zipkin服务
在完成了Zipkin Server的搭建之后我们还需要对应用做一些配置以实现将跟踪信息输出到Zipkin Server。我们以之前实现的trace-1和trace-2为例对它们做以下改造内容
在trace-1和trace-2的pom.xml中引入spring-cloud-sleuth-zipkin依赖具体如下所示。
dependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-sleuth-zipkin/artifactId/dependency在trace-1和trace-2的application.properties中增加Zipkin Server的配置信息具体如下所示如果在zip-server应用中我们将其端口设置为9411并且均在本地调试的话该参数也可以不配置因为默认值就是http://localhost:9411。
spring.zipkin.base-urlhttp://localhost:9411测试与分析
到这里我们已经完成了接入Zipkin Server的所有基本工作我们可以继续将eureka-server、trace-1和trace-2启动起来然后我们做一些测试实验以对它的运行机制有一些初步的理解。
我们先来向trace-1的接口发送几个请求http://localhost:9101/trace-1当我们在日志中出现跟踪信息的最后一个值为true的时候说明该跟踪信息会输出给Zipkin Server所以此时我们可以去Zipkin Server的管理页面中选择合适的查询条件后点击Find Traces就可以查询出刚才在日志中出现的跟踪信息了也可以根据日志中的Trace ID在页面的右上角输入框中来搜索具体如下页面所示 点击下方trace-1端点的跟踪信息我们还可以得到Sleuth收集到的跟踪到详细信息其中包括了我们关注的请求时间消耗等。 点击导航栏中的Dependencies菜单我们还可以查看Zipkin Server根据跟踪信息分析生成的系统请求链路依赖关系图 消息中间件收集
Spring Cloud Sleuth在整合Zipkin时不仅实现了以HTTP的方式收集跟踪信息还实现了通过消息中间件来对跟踪信息进行异步收集的封装。通过结合Spring Cloud Stream我们可以非常轻松的让应用客户端将跟踪信息输出到消息中间件上同时Zipkin服务端从消息中间件上异步地消费这些跟踪信息。
接下来我们基于之前实现的trace-1和trace-2应用以及zipkin-server服务端做一些改造以实现通过消息中间件来收集跟踪信息。改造的内容非常简单只需要我们做项目依赖和配置文件做一些调整就能马上实现下面我们分别对客户端和服务端的改造内容做详细说明
第一步修改客户端trace-1和trace-2
为了让trace-1和trace-2在产生跟踪信息之后能够将抽样记录输出到消息中间件中我们除了需要之前引入的spring-cloud-starter-sleuth依赖之外还需要引入zipkin对Spring Cloud Stream的扩展依赖spring-cloud-sleuth-stream以及基于Spring Cloud Stream实现的消息中间件绑定器依赖以使用RabbitMQ为例我们可以加入如下依赖
dependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-sleuth-stream/artifactId/dependencydependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-starter-stream-rabbit/artifactId/dependency在application.properties配置中去掉HTTP方式实现时使用的spring.zipkin.base-url参数并根据实际部署情况增加消息中间件的相关配置比如下面这些关于RabbitMQ的配置信息
spring.rabbitmq.hostlocalhostspring.rabbitmq.port5672spring.rabbitmq.usernamespringcloudspring.rabbitmq.password123456第二步修改zipkin-server服务端
为了让zipkin-server服务端能够从消息中间件中获取跟踪信息我们只需要在pom.xml中引入针对消息中间件收集封装的服务端依赖spring-cloud-sleuth-zipkin-stream同时为了支持具体使用的消息中间件我们还需要引入针对消息中间件的绑定器实现比如以使用RabbitMQ为例我们可以在依赖中增加如下内容
dependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-sleuth-zipkin-stream/artifactId/dependencydependency groupIdorg.springframework.cloud/groupId artifactIdspring-cloud-starter-stream-rabbit/artifactId/dependencydependency groupIdio.zipkin.java/groupId artifactIdzipkin-autoconfigure-ui/artifactId/dependency其中spring-cloud-sleuth-zipkin-stream依赖是实现从消息中间件收集跟踪信息的核心封装其中包含了用于整合消息中间件的核心依赖、zipkin服务端的核心依赖、以及一些其他通常会被使用的依赖比如用于扩展数据存储的依赖、用于支持测试的依赖等。但是需要注意的是这个包里并没有引入zipkin的前端依赖zipkin-autoconfigure-ui为了方便使用我们在这里也引用了它。
测试与分析
在完成了上述改造内容之后我们继续将eureka-server、trace-1和trace-2、zipkin-server都启动起来同时确保RabbitMQ也处于运行状态。此时我们可以在RabbitMQ的控制页面中看到一个名为sleuth的交换器它就是zipkin的消息中间件收集器实现使用的默认主题。 最后我们使用之前的验证方法通过向trace-1的接口发送几个请求http://localhost:9101/trace-1当有被抽样收集的跟踪信息时调试时我们可以设置AlwaysSampler抽样机制来让每个跟踪信息都被收集我们可以在RabbitMQ的控制页面中发现有消息被发送到了sleuth交换器中同时我们再到zipkin服务端的Web页面中也能够搜索到相应的跟踪信息那么我们使用消息中间件来收集跟踪信息的任务到这里就完成了。
完整示例
读者可以根据喜好选择下面的两个仓库中查看trace-1和trace-2两个项目
Githubhttps://github.com/dyc87112/SpringCloud-Learning/Giteehttps://gitee.com/didispace/SpringCloud-Learning/
如果您对这些感兴趣欢迎star、follow、收藏、转发给予支持
本文内容部分节选自我的《Spring Cloud微服务实战》但对依赖的Spring Boot和Spring Cloud版本做了升级。
