跳到主要内容

SkyWalking 源码分析 Agent 发送 Trace 数据

1. 概述​

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

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

本文主要分享【第二部分】 SkyWalking Agent 发送 Trace 数据。

考虑到减少外部组件的依赖，Agent 收集到 Trace 数据后，不是写入外部消息队列( 例如，Kafka )或者日志文件，而是 Agent 写入内存消息队列，后台线程【异步】发送给 Collector 。

本文涉及的类非常少，如下图所示：

 

2. TraceSegmentServiceClient​

org.skywalking.apm.agent.core.remote.TraceSegmentServiceClient ，TraceSegment 发送服务客户端。它是一个服务，也是一个客户端，负责将 TraceSegment 异步发送到 Collector 。

我们先来看看 TraceSegmentServiceClient 的属性：

  • TIMEOUT 静态属性，发送等待超时时长，单位：毫秒。
  • lastLogTime 属性，最后打印日志时间。该属性主要用于开发调试。
  • segmentUplinkedCounter 属性，TraceSegment 发送数量。