链路追踪

文章40 |   阅读 30627 |   点赞0

来源:https://blog.csdn.net/weixin_42073629/category_9940428.html

SkyWalking 源码分析 —— 运维界面(三)之链路追踪视角

x33g5p2x  于2021-12-21 转载在 其他  
字(2.1k)|赞(0)|评价(0)|浏览(706)

1. 概述

本文主要分享运维界面的第三部分,链路追踪视角
SkyWalking WEBUI :https://github.com/apache/incubator-skywalking-ui

在我们打开 SkyWalking WEBUI 的 Trace Stack ( trace/trace.html ) 页时,如下图:

  • 以链路追踪为维度进行展示。
  • 红色部分,应用筛选器,调用 「2. ApplicationsGetHandler」 接口,获得应用列表。
  • 紫色部分,TraceSegment 分页列表,调用 「3. SegmentTopGetHandler」 接口,获得数据。
  • 蓝色部分,【点击单条 TraceSegment】,一次完整的分布式链路追踪记录详情,调用 「5. TraceStackGetHandler」 接口,获得数据。
  • 黄色部分,【点击单个 Span】,单条 Span 记录详情,调用 「5. SpanGetHandler」 接口,获得数据。
    基情提示:运维界面相关 HTTP 接口,逻辑简单易懂,笔者写的会比较简略一些。

2. ApplicationsGetHandler

同 《SkyWalking 源码分析 —— 运维界面(二)之应用实例视角》「3. ApplicationsGetHandler」 相同。

3. SegmentTopGetHandler

org.skywalking.apm.collector.ui.jetty.handler.SegmentTopGetHandler ,实现 JettyHandler 接口,获得 TraceSegment 分页列表的逻辑处理器。

  • #pathSpec() ,路径定义,"/segment/top" 。
  • 响应示例:

  • #doGet() 方法,代码如下:

  • 第 62 至 73 行:解析 startTime 和 endTime 参数。

  • 第 75 至 87 行:解析 from 和 limit 分页参数。

  • 第 90 至 97 行:解析 minCost 和 maxCost 参数。

  • 第 100 至 103 行:解析 globalTraceId 参数。

  • 第 106 至 109 行:解析 operationName 参数。

  • 第 112 至 117 行:解析 applicationId 参数。

  • 第 120 至 132 行:解析 error 参数。

  • 第 135 至 141 行:解析 sort 排序参数,倒序。

  • 第 73 行:调用 SegmentTopService#load(...) 方法,,获得 TraceSegment 分页列表。代码如下:

  • 第 59 至 62 行:若存在 globalTraceId 参数,调用 GlobalTraceEsUIDAO#getSegmentIds(globalTraceId) 方法,查询对应的 TraceSegment 编号数组。为什么需要这么查询呢?在下面,我们会看到,实际查询的是 SegmentCost 表,该表不存在 global_trace_id ,所以需要查询到 segment_id 数组,作为查询条件。

  • 第 65 行:调用 SegmentCostEsUIDAO#loadTop(...) 方法,查询 SegmentCost 数组。

  • 第 68 至 77 行:循环 SegmentCost 数组,调用 GlobalTraceEsUIDAO#getGlobalTraceId(segmentId) 方法,获得每个 SegmentCost 对应的 global_trace_id 属性,并设置返回。

4. TraceStackGetHandler

org.skywalking.apm.collector.ui.jetty.handler.TraceStackGetHandler ,实现 JettyHandler 接口,获取一次分布式链路追踪记录详情的逻辑处理器。

  • #pathSpec() ,路径定义,"/traceStack/globalTraceId" 。
  • 响应示例:

  • #doGet() 方法,代码如下:

  • 第 73 行:调用 TraceStackService#load(globalTraceId) 方法,基 GlobalTrace 和 Segment 表,获取一次分布式链路追踪记录详情的逻辑处理器。逻辑较为繁琐,笔者已经添加注释,胖友调试一下,很容易明白滴。

5. SpanGetHandler

org.skywalking.apm.collector.ui.jetty.handler.SpanGetHandler ,实现 JettyHandler 接口,获得 TraceSegment 单个 Span 详细的逻辑处理器。

  • #pathSpec() ,路径定义,"/span/spanId" 。
  • 响应示例:

  • #doGet() 方法,代码如下:

  • 第 52 行:解析 segmentId 参数。

  • 第 55 至 62 行:解析 spanId 参数。

  • 第 73 行:调用 SpanService#load(segmentId, spanId) 方法,获得 TraceSegment 单个 Span 详细。代码如下:

  • 第 44 行:调用 SegmentEsUIDAO#load(segmentId) 方法,获得 TraceSegment 。

  • 第 58 至 139 行:循环获得的 TraceSegment 的 Span 数组,找到对应的 Span 记录,设置后返回。

相关文章