SkyWalking 源码分析 Collector 存储 Trace 数据

1. 概述

分布式链路追踪系统，链路的追踪大体流程如下：

1、 Agent收集Trace数据；
2、 Agent发送Trace数据给Collector；
3、 Collector接收Trace数据；
4、 Collector存储Trace数据到存储器，例如，数据库；

本文主要分享【第四部分】 SkyWalking Collector 存储 Trace 数据。

> 友情提示：Collector 接收到 TraceSegment 的数据，对应的类是 Protobuf 生成的。考虑到更加易读易懂，本文使用 TraceSegment 相关的原始类。

Collector 在接收到 Trace 数据后，经过流式处理，最终存储到存储器。如下图，红圈部分，为本文分享的内容：

2. SpanListener

在 《SkyWalking 源码分析 —— Collector 接收 Trace 数据》 一文中，我们看到 SegmentParse#parse(UpstreamSegment, Source) 方法中：

• 在 #preBuild(List<UniqueId>, SegmentDecorator) 方法中，预构建的过程中，使用 Span 监听器们，从 TraceSegment 解析出不同的数据。