必要性:
由客户端发起的请求会形成链路,任何一环出现问题,可能导致失败。我们需要快速的观测、定位和解决问题。
- 概述
- ZipKin
- Micromete+ZipKin搭建链路控制案例
概述
为什么需要分布式链路技术
在微服务框架中,一个由客户端发起的请求在后端系统中会经过多个不同的的服务节点调用来协同产生最后的请求结果,每一个前段请求都会形成一条复杂的分布式服务调用链路,链路中的任何一环出现高延时或错误都会引起整个请求最后的失败。
在分布式与微服务场景下,我们需要解决如下问题:
- 在大规模分布式与微服务集群下,如何实时观测系统的整体调用链路情况。
- 在大规模分布式与微服务集群下,如何快速发现并定位到问题。
- 在大规模分布式与微服务集群下,如何尽可能精确的判断故障对系统的影响范围与影响程度。
- 在大规模分布式与微服务集群下,如何尽可能精确的梳理出服务之间的依赖关系,并判断出服务之间的依赖关系是否合理。
- 在大规模分布式与微服务集群下,如何尽可能精确的分析整个系统调用链路的性能与瓶颈点。
- 在大规模分布式与微服务集群下,如何尽可能精确的分析系统的存储瓶颈与容量规划
分布式链路追踪技术要解决的问题,分布式链路追踪(Distributed Tracing),就是将一次分布式请求还原成调用链路,进行日志记录,性能监控并将一次分布式请求的调用情况集中展示。比如各个服务节点上的耗时、请求具体到达哪台机器上、每个服务节点的请求状态等等。
Sleuth官宣进入维护模式
Seleuth官宣进入维护模式,Sleuth未来的地带方法micrometer.io
。
行业内比较常见的技术方案如下:
Zipkin
概述
官网(我用火狐浏览器没有打开,用其他浏览器打开了): https://zipkin.io/
Zipkin分布式链路跟踪系统化图形化工具。Zipkin 是 Twitter 开源的分布式跟踪系统,能够收集微服务运行过程中的实时调用链路信息,并能够将这些调用链路信息展示到Web图形化界面上供开发人员分析,开发人员能够从ZipKin中分析出调用链路中的性能瓶颈,识别出存在问题的应用程序,进而定位问题和解决问题。
只有日志没有图,观察不方便,不美观。引入Zipkin链路监控后能更好的观察。
下载+安装+ 运行
下载地址:https://zipkin.io/pages/quickstart.html
支持三种Java、Docker和运行源码这三种使用方式。这里,我们运行Jar包。
打开下载的jar包,运行jarjava -jar zipkin-server-3.0.0-rc0-exec.jar
运行控制台:浏览器输入地址http://localhost:9411/zipkin/
Micromete+ZipKin搭建链路控制案例
Micrometer 负责数据采样;ZipKin负责图形化展示。
前提:已启动consul和zipkin。
步骤
具体步骤如下:
- 父工程引入依赖
- 服务提供者8001
- PayFeign公共接口
- 服务调用者
父工程引入依赖
由于Micrometer Tracing是一个门面工具自身并没有实现完整的链路追踪系统,具体的链路追踪另外需要引入的是第三方链路追踪系统的依赖 。
序号 | 依赖 | 说明 |
---|---|---|
1 | micrometer-tracing-bom | 导入链路追踪版本中心,体系化说明 |
2 | micrometer-tracing | 指标追踪 |
3 | micrometer-tracing-bridge-brave | 一个Micrometer模块,用于与分布式跟踪工具 Brave 集成,以收集应用程序的分布式跟踪数据。Brave是一个开源的分布式跟踪工具,它可以帮助用户在分布式系统中跟踪请求的流转,它使用一种称为"跟踪上下文"的机制,将请求的跟踪信息存储在请求的头部,然后将请求传递给下一个服务。在整个请求链中,Brave会将每个服务处理请求的时间和其他信息存储到跟踪数据中,以便用户可以了解整个请求的路径和性能。 |
4 | micrometer-observation | 一个基于度量库 Micrometer的观测模块,用于收集应用程序的度量数据 |
5 | feign-micrometer | 一个Feign HTTP客户端的Micrometer模块,用于收集客户端请求的度量数 |
6 | zipkin-reporter-brave | 一个用于Brave跟踪数据报告到Zipkin跟踪系统的库。 |
打开父工程的pom.xml
文件,引入依赖。
<!--micrometer-tracing-bom导入链路追踪版本中心 1-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-tracing-bom</artifactId><version>${micrometer-tracing.version}</version><type>pom</type><scope>import</scope>
</dependency>
<!--micrometer-tracing指标追踪 2-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-tracing</artifactId><version>${micrometer-tracing.version}</version>
</dependency>
<!--micrometer-tracing-bridge-brave适配zipkin的桥接包 3-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-tracing-bridge-brave</artifactId><version>${micrometer-tracing.version}</version>
</dependency>
<!--micrometer-observation 4-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-observation</artifactId><version>${micrometer-observation.version}</version>
</dependency>
<!--feign-micrometer 5-->
<dependency><groupId>io.github.openfeign</groupId><artifactId>feign-micrometer</artifactId><version>${feign-micrometer.version}</version>
</dependency>
<!--zipkin-reporter-brave 6-->
<dependency><groupId>io.zipkin.reporter2</groupId><artifactId>zipkin-reporter-brave</artifactId><version>${zipkin-reporter-brave.version}</version>
</dependency>
例子的固定版本如下:
<micrometer-tracing.version>1.2.0</micrometer-tracing.version>
<micrometer-observation.version>1.12.0</micrometer-observation.version>
<feign-micrometer.version>12.5</feign-micrometer.version>
<zipkin-reporter-brave.version>2.17.0</zipkin-reporter-brave.version>
服务提供者8001
步骤(改POM,改YML,新建接口)
改POM,引入项目依赖。
<!--micrometer-tracing指标追踪 1-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-tracing</artifactId>
</dependency>
<!--micrometer-tracing-bridge-brave适配zipkin的桥接包 2-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-tracing-bridge-brave</artifactId>
</dependency>
<!--micrometer-observation 3-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-observation</artifactId>
</dependency>
<!--feign-micrometer 4-->
<dependency><groupId>io.github.openfeign</groupId><artifactId>feign-micrometer</artifactId>
</dependency>
<!--zipkin-reporter-brave 5-->
<dependency><groupId>io.zipkin.reporter2</groupId><artifactId>zipkin-reporter-brave</artifactId>
</dependency>
写YAML,配置连接zipkin
# ========================zipkin===================
management:zipkin:tracing:endpoint: http://localhost:9411/api/v2/spanstracing:sampling:probability: 1.0 #采样率默认为0.1(0.1就是10次只能有一次被记录下来),值越大收集越及时。
新建公共类:PayMicrometerController,用于测试测试链路的例子
/*** @Author:lyj* @Filename:PayMicrometerController*/
@RestController
public class PayMicrometerController {/*** Micrometer(Sleuth)进行链路监控的例子* @param id* @return*/@GetMapping(value = "/pay/micrometer/{id}")public ResultData<String> myMicrometer(@PathVariable("id") Integer id) {return ResultData.success( "Hello, 欢迎到来myMicrometer inputId: "+id+" \t 服务返回:" + IdUtil.simpleUUID() );}
}
PayFeign公共接口
PayFeign公共接口添加一个例子
/*** Micrometer(Sleuth)进行链路监控的例子* @param id* @return*/
@GetMapping(value = "/pay/micrometer/{id}")
public ResultData<String> myMicrometer(@PathVariable("id") Integer id);
服务调用者(cloud-consumer-feign-order80)
pom.xml
文件引入依赖
<!--micrometer-tracing指标追踪 1-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-tracing</artifactId>
</dependency>
<!--micrometer-tracing-bridge-brave适配zipkin的桥接包 2-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-tracing-bridge-brave</artifactId>
</dependency>
<!--micrometer-observation 3-->
<dependency><groupId>io.micrometer</groupId><artifactId>micrometer-observation</artifactId>
</dependency>
<!--feign-micrometer 4-->
<dependency><groupId>io.github.openfeign</groupId><artifactId>feign-micrometer</artifactId>
</dependency>
<!--zipkin-reporter-brave 5-->
<dependency><groupId>io.zipkin.reporter2</groupId><artifactId>zipkin-reporter-brave</artifactId>
</dependency>
写YML,引入zipkin地址
# zipkin图形展现地址和采样率设置
management:zipkin:tracing:endpoint: http://localhost:9411/api/v2/spanstracing:sampling:probability: 1.0 #采样率默认为0.1(0.1就是10次只能有一次被记录下来),值越大收集越及时。
新建业务类OrderMicrometerController :
@RestController
@Slf4j
public class OrderMicrometerController {@Resourceprivate PayFeignApi payFeignApi;@GetMapping(value = "/feign/micrometer/{id}")public ResultData<String> myMicrometer(@PathVariable("id") Integer id) {return payFeignApi.myMicrometer(id);}
}
测试
启动8001/8002/80 ,Zipkin
测试地址:http://localhost:80/feign/micrometer/1
浏览器打开:http://localhost:9411/
查看依赖关系