AnyLab Studio

LatencyWatch

在您的服务器上部署 Agent。通过 Kafka 采集延迟数据。存储和查询于 ClickHouse。通过单一管理平台管理一切。

系统架构图

架构组件

Agent (Rust)

通过 libpcap 进行 TCP 报文抓取、ICMP 探测、本地缓冲、Kafka 生产者和 gRPC 反向隧道客户端。

Analytics (Rust)

Kafka 消费者,支持 IP 地理位置增强(IPInfo + IP2Location,LRU 缓存)和 ClickHouse 批量写入。

Tunnel Gateway (Rust)

基于 Tokio + tonic 的 gRPC 反向隧道,用于 Agent 管理和心跳检测。

Backend (Go)

基于 GIN 的 REST API,用于节点管理、ClickHouse 查询代理,支持 JWT 认证和 RBAC。

Frontend (React)

基于 Vite + React 的管理界面,使用 TanStack Router 和数据可视化。

Storage

Kafka 用于流缓冲,ClickHouse 用于时序数据,MySQL 用于元数据。