【Springboot】实例讲解Springboot整合OpenTracing分布式链路追踪系统(Jaeger和Zipkin)
南瓜慢说 人气:0
# 1 分布式追踪系统
随着大量公司把单体应用重构为微服务,对于运维人员的责任就更加重大了。架构更复杂、应用更多,要从中快速诊断出问题、找到性能瓶颈,并不是一件容易的事。因此,也随着诞生了一系列面向`DevOps`的诊断与分析系统,主要是以下三个系统:
- 集中式日志系统(Logging)
- 集中式度量系统(Metrics)
- 分布式追踪系统(Tracing)
三者相互交织重叠如下:
![loggin_metrics_tracing](https://img2020.cnblogs.com/other/946674/202004/946674-20200405181335625-467469877.jpg)
技术栈上的成熟框架有,
Logging:Log4j、ELK等,
Metrics:Prometheus、InfluxDB、Grafana等
Tracing:Jaeger和Zipkin等。
分布式追踪系统在Google发表一篇文章[Dapper, a Large-Scale Distributed Systems Tracing Infrastructure](https://research.google.com/pubs/pub36356.html?spm=a2c4e.10696291.0.0.335419a4mTcu58)后快速发展。Tracing系统一般核心步骤有三个:代码埋点、数据存储、查询展示。
历史洪流滚滚向前,大浪淘沙,现在比较流行的有`Jaeger`和`Zipkin`。
# 2 OpenTracing
由于`Tracing`的技术发展迅速,为了解决兼容性问题,有了[OpenTracing](https://opentracing.io/)规范。它是一个轻量级的标准化层,连接应用、类库和追踪系统。
![interface](https://img2020.cnblogs.com/other/946674/202004/946674-20200405181336774-1678233158.jpg)
OpenTracing的优势:
(1)OpenTracing已经进入`CNCF`(云原生计算基金会,口号是坚持和整合开源技术来编排容器作为微服务架构的一部分),正在为全球的分布式追踪,提供统一的概念和数据标准。
(2)OpenTracing通过提供平台无关、厂商无关的`API`,使得开发人员能够方便添加和更换追踪系统的实现。
## 2.1 相关概念
`Trace`:贯穿一个分布式系统的事务追踪描述,其实就是由许多个`Span`组成的有向无环图。
`Span`:被命名的与记录时间的调用操作,如一个Http GET请求;`Span`有嵌套关系,如果一个请求会调用其它服务,就会生成子`Span`。
`Tag`:一组由键值对构成的标签集合,键值类型必须为字符串。它可以带上许多有用信息,如请求方法、请求URL、返回状态码等。
`Log`:一组`Span`的日志集合。
## 2.2 OpenTracing的实现
`Jaeger`是`Uber`推出的一款开源分布式追踪系统,兼容`OpenTracing API`。架构如下:
![Jaeger Architecture](https://img2020.cnblogs.com/other/946674/202004/946674-20200405181340611-1315311683.jpg)
`Zipkin`是由`Twitter`推出的开源的分布式追踪系统,架构图如下:
![Zipkin architecture](https://img2020.cnblogs.com/other/946674/202004/946674-20200405181347816-1718860451.jpg)
# 3 实战整合
本文以Springboot为Web项目,分别整合`Jaeger`和`Zipkin`。
## 3.1 Springboot项目准备
项目中的`Controller`,提供了两个Endpoint,`tracing`和`open`;在访问`open`时,代码会调用`tracing`。
```java
@RestController
public class TracingController {
@Autowired
private RestTemplate restTemplate;
@Value("${server.port}")
private int port;
@RequestMapping("/tracing")
public String tracing() throws InterruptedException {
Thread.sleep(100);
return "tracing";
}
@RequestMapping("/open")
public String open() throws InterruptedException {
ResponseEntity
加载全部内容