跳到主要内容

SkyWalking 源码分析 Collector Remote 远程通信服务

1. 概述​

本文主要分享 SkyWalking Collector Remote 远程通信服务。该服务用于 Collector 集群内部通信。

 

目前集群内部通信的目的，跨节点的流式处理。Remote Module 应用在 SkyWalking 架构图如下位置( 红框 ) ：

> FROM https://github.com/apache/incubating-skywalking > >  

下面我们来看看整体的项目结构，如下图所示 ：

 

  • collector-remote-define ：定义远程通信接口。
  • collector-remote-kafka-provider ：基于 Kafka 的远程通信实现。目前暂未完成。
  • collector-remote-grpc-provider ：基于 Google gRPC 的远程通信实现。生产环境目前使用

下面，我们从接口到实现的顺序进行分享。

2. collector-remote-define​

collector-remote-define ：定义远程通信接口。项目结构如下 ：