目录
master
分支1
标签0
+ 疑修
Web IDE
yinggan
优化启动脚本，增加部分文档
27天前4次提交
README.md

T-Block-Operation-System (TBOS)

系统简介

TBOS是腾讯自研的机房动环监控系统，采用微服务架构设计，包含边缘采集、数据处理、告警计算、配置管理等多个核心模块，支持大规模机房的统一监控管理。

适用场景

  • 数据中心动环监控：电力系统、空调系统、环境监测
  • 工业设备采集：支持 Modbus RTU/TCP、SNMP 等工业协议
  • 分布式边缘采集：边缘-云端协同架构，支持离线缓存
  • 实时告警管理：毫秒级告警响应，支持复杂策略表达式

核心特性

特性 说明
🔌 多协议采集 支持 Modbus RTU/TCP、SNMP、DIO 等多种工业协议，可扩展驱动插件
⚡ 实时告警 毫秒级告警响应，支持实时告警(1秒)、延时告警(3秒)、虚拟测点告警(2秒)
🎯 TNQL表达式引擎 支持复杂逻辑、比较、算术运算，内置 DelayEQ/Rise/Fall/InRange 等函数
🔄 分布式架构 支持水平扩展，高可用部署，主备 Kafka 双活自动切换
📊 标准化测点 统一的测点体系，支持虚拟测点计算和表达式求值
📡 WebSocket推送 实时告警推送，无需轮询，前端自动重连
🌐 边云协同 边缘采集器与云端服务协同工作，支持配置本地缓存兜底
⚖️ 智能调度 基于计算复杂度的负载均衡任务调度，增量下发减少开销
🔥 配置热更新 支持运行时动态更新采集配置和告警策略，无需重启服务

系统架构

整体架构图

arch.png

数据流简图

                          ┌──────────────────────────────────────────────────────────────┐
                          │                      配置流                                   │
                          │  Web → CGI → CMDB → MySQL ← Scheduler                        │
                          │                              ↓                               │
                          │              ┌───────────────┼───────────────┐               │
                          │              ↓               ↓               ↓               │
                          │          Agent-GW      Data-Compute    Alarm-Compute         │
                          └──────────────────────────────────────────────────────────────┘
                          
                          ┌──────────────────────────────────────────────────────────────┐
                          │                      数据流                                   │
                          │  物理设备 → Agent → Collector → Kafka → Data-Cache/Store      │
                          │                                 ↑           ↓                │
                          │        Data-Compute (读取Data-Cache计算)   Data-Query         │
                          └──────────────────────────────────────────────────────────────┘
                          
                          ┌──────────────────────────────────────────────────────────────┐
                          │                      告警流                                   │
                          │  Alarm-Compute (读取Query) → Kafka(告警+日志)                  │
                          │                                    ↓                         │
                          │                        ┌───────────┴───────────┐             │
                          │                        ↓                       ↓             │
                          │               Alarm-Manage(入库)        Alarm-Server(生效率)  │
                          └──────────────────────────────────────────────────────────────┘

技术栈

类别 技术
后端语言 Go 1.22+ (推荐 1.23-1.24)
RPC框架 etrpc-go (基于 trpc-go 的增强框架)
前端框架 Vue 2 + TypeScript
构建工具 TNWeb Fusion 构建系统
消息队列 Kafka (支持主备双活)
时序数据库 InfluxDB 1.8+
关系数据库 MySQL 5.7+
缓存 Redis 6.0+
容器化 Docker
Web服务器 Nginx (前端路由支持)

模块说明

核心服务模块

模块 说明 主要能力
etrpc-go 基础RPC框架 配置加载/热更新、数据库客户端封装、日志增强、指标上报、HTTP响应包装
agent 边缘采集器/云端网关 Modbus/SNMP/DIO多协议采集、虚拟测点计算、标准测点映射、配置热更新。Agent和Agent-GW是同一套代码，通过配置决定任务获取方式
scheduler 调度中心 监听MySQL配置变化、负载均衡任务分配、增量下发、Agent-GW/Data-Compute/Alarm-Compute任务调度
alarm-compute 告警计算引擎 接收Scheduler调度任务、读取Data-Query获取测点数据、TNQL表达式计算、告警消息写入Kafka、计算日志写入Kafka
alarm-manage 告警管理 消费Kafka告警消息、告警去重指纹、雪花ID生成、告警持久化到MySQL
alarm-server 告警服务 告警查询/统计/趋势、读取Kafka日志计算告警生效率、告警诊断
cmdb 配置管理 设备/测点/模板/策略配置、配置持久化到MySQL、配置导出ZIP
collector 配置收集器 读取CMDB配置、本地配置缓存兜底、接收Agent数据、数据转发到Kafka
data-cache 数据缓存 消费Kafka测点数据、循环窗口内存缓存(10分钟)、为Data-Query提供实时数据
data-compute 数据计算 接收Scheduler调度任务、读取Data-Cache测点数据、标准测点表达式计算、计算结果写入Kafka
data-query 数据查询 从Data-Cache读取实时数据、从InfluxDB读取历史数据、为Alarm-Compute提供测点查询
data-store 数据存储 消费Kafka测点数据、数据持久化到InfluxDB
cgi API网关 HTTP/WebSocket接口、配置导入到CMDB、实时告警推送、对接Web前端
common 公共模块 实体定义、常量定义、表达式引擎、分布式锁工具
dac 门禁/安防服务 门禁事件采集与上报、设备接入、安防数据查询，对外路径 /api/dcos/tdac-cgi/
web 前端应用 监控大屏、管理界面

快速开始

环境要求

组件 版本要求 备注
Go 1.22+ (推荐 1.23-1.24) 后端服务编译必需
Node.js 14+ (推荐 16+) 前端构建必需
Nginx 1.18+ 前端路由支持（本地部署必需）
Docker & Docker Compose Latest 容器化部署推荐
MySQL 5.7+ 配置和告警数据存储
Redis 6.0+ 缓存和会话管理
Kafka 2.8+ 消息队列和数据流处理
InfluxDB 1.8+ 时序数据存储

最小化部署

硬件要求

配置项 要求
CPU 8核心
内存 32 GB
存储 200 GB

备注：单模组总资源不低于 52核心，资源规划建议 CPU:内存 = 1:4

操作系统

  • Ubuntu 16.04/18.04 LTS (64-bit) 以上
  • CentOS Linux 7.6 (64-bit) 以上
  • Tencent Linux 2.2 以上

部署运行

部署方式对比

部署方式 适用场景 复杂度 自动化程度 依赖说明
本地部署 开发测试、功能验证 中等 中等 需自行安装中间件（MySQL/Redis/Kafka/InfluxDB）及Nginx
Docker部署 初次体验、学习演示 低 高 无需额外依赖，一键部署所有组件
分布式部署 大规模生产、高可用 高 低 依赖Kubernetes集群及镜像仓库

本地部署（开发环境）

适用于开发测试环境，需要手动安装依赖和配置。

# 1. 克隆项目
git clone <repository_url>
cd tbos

# 2. 编译所有服务
./tbos.sh build

# 3. 初始化数据库
mysql -u root -p < ddl.sql

# 4. 启动所有服务
./tbos.sh start

# 访问Web界面：http://localhost:8080

前置要求：

  • 确保已安装所有环境要求中的组件
  • Nginx 用于前端路由（必需）
  • 中间件（MySQL/Redis/Kafka/InfluxDB）需手动安装配置

依赖说明：

  • 开发工具：Go 1.22+、Node.js 14+、Git
  • 中间件：MySQL 5.7+、Redis 6.0+、Kafka 2.8+、InfluxDB 1.8+
  • Web服务器：Nginx 1.18+（前端路由必需）
  • 系统依赖：Linux/Unix环境，支持Docker（可选）

Docker部署（初次体验）

适用于初次体验和功能演示，自动化程度最高。不建议在生产环境使用。

# 1. 构建所有镜像
./tbos_docker.sh build

# 2. 安装TBOS系统（包含中间件和业务服务）
./tbos_docker.sh install

# 3. 启动所有服务
./tbos_docker.sh start

# 访问Web界面：http://服务器IP:8080

优势：

  • 自动安装所有依赖中间件
  • 自动初始化数据库
  • 一键启动所有服务
  • 容器化隔离，便于维护

依赖说明：

  • 必需依赖：Docker Engine 20.10+、Docker Compose 2.0+
  • 系统要求：Linux内核4.15+，支持容器运行时
  • 资源要求：至少4GB空闲内存，20GB磁盘空间

注意事项：

  • 仅适用于体验和学习目的
  • 生产环境建议使用分布式部署
  • 可能存在性能瓶颈，不适合高并发场景

分布式部署

适用于大规模生产环境，支持高可用和水平扩展。

部署方式：采用Kubernetes进行容器编排部署

  • 中间件集群：自行部署MySQL、Redis、Kafka、InfluxDB等中间件的分布式集群
  • 服务镜像：为每个微服务单独构建Docker镜像
  • 编排部署：使用Kubernetes编排镜像，配置服务发现、负载均衡、自动扩缩容

注意事项：

  • 镜像仓库：k8s读取镜像需要镜像仓库的支持，可以使用公开的镜像仓库或者私有化部署自己的镜像仓库
  • 服务配置：环境变量的配置可以通过k8s注入，也可以修改etrpc-go框架支持从配置中心获取配置

配置说明

环境变量配置

编辑 server.cfg 文件配置环境变量：

# 数据库配置
MYSQL_HOST=localhost
MYSQL_PORT=3306
MYSQL_USER=root
MYSQL_PASSWORD=password
MYSQL_DATABASE=tbos
MYSQL_ADDR=${MYSQL_HOST}:${MYSQL_PORT}

# Redis配置
REDIS_HOST=localhost
REDIS_PORT=6379
REDIS_PASSWORD=
REDIS_ADDR=${REDIS_HOST}:${REDIS_PORT}

# Kafka配置
KAFKA_HOST=localhost
KAFKA_PORT=9092
KAFKA_ADDR=${KAFKA_HOST}:${KAFKA_PORT}
KAFKA_POINT_TOPIC=tbos_point_data
KAFKA_ALARM_TOPIC=tbos_alarm_msg

# InfluxDB配置
INFLUXDB_HOST=localhost
INFLUXDB_PORT=8086
INFLUXDB_USER=admin
INFLUXDB_PASSWORD=password
INFLUXDB_DBNAME=tbos
INFLUXDB_ADDR=${INFLUXDB_HOST}:${INFLUXDB_PORT}
INFLUXDB_POINT_MEASUREMENT=points

# 本机IP
LOCAL_IP=127.0.0.1

# 服务端口
PORT_AGENT=9100
PORT_COLLECTOR=9101
PORT_CMDB=9102
PORT_SCHEDULER=9103
PORT_DATA_COMPUTE=9104
PORT_DATA_CACHE=9105
PORT_DATA_STORE=9106
PORT_DATA_QUERY=9107
PORT_ALARM_COMPUTE=9108
PORT_ALARM_MANAGE=9109
PORT_ALARM_SERVER=9110
PORT_CGI=9111

服务配置文件

每个服务目录下的 trpc_go.yaml 为服务配置文件，包含：

配置项 说明
etrpc 服务名称、端口配置
global 全局配置（命名空间、本机IP等）
server.service 服务监听配置（协议、端口）
client.service 客户端配置（数据库、Redis、Kafka、RPC调用）
plugins 插件配置（日志、监控等）

服务端口分配

服务 默认端口 协议 说明
CGI 9111 HTTP API网关服务
Scheduler 9103 HTTP 调度中心
Alarm-Compute 9108 HTTP 告警计算引擎
Alarm-Manage 9109 HTTP 告警管理服务
Data-Cache 9105 HTTP 数据缓存服务
Data-Store 9106 HTTP 数据存储服务
Alarm-Server 9110 HTTP 告警服务
CMDB 9102 HTTP 配置管理服务
Collector 9101 HTTP 数据收集器
Data-Compute 9104 HTTP 数据计算服务
Data-Query 9107 HTTP 数据查询服务
Agent 9100 HTTP 边缘采集器
Web前端 8080 HTTP 前端界面（Nginx）

故障排除

常见构建问题

Go 版本不兼容

# 错误：go: requires go1.24.0
# 解决方案：升级 Go 版本
brew upgrade go  # macOS
sudo apt update && sudo apt upgrade golang  # Ubuntu

前端构建失败

# 错误：Node.js 版本过低
# 解决方案：使用 nvm 管理 Node.js 版本
nvm install 16  # 安装 Node.js 16
nvm use 16      # 切换到 Node.js 16

Nginx 配置问题

# 检查配置语法
nginx -t

# 查看错误日志
tail -f /var/log/nginx/error.log  # 系统日志
tail -f target/web/error.log      # 项目日志

常见启动问题

端口冲突

# 检查端口占用
netstat -tlnp | grep 8080

# 解决方案：停止冲突进程或修改配置
kill -9 <pid>  # 停止占用进程

数据库连接失败

# 检查数据库服务
systemctl status mysql  # 或 service mysql status

# 验证连接
mysql -u root -p -h localhost -P 3306

前端路由不生效

# 检查 Nginx 是否安装
which nginx

# 检查 Nginx 进程
ps aux | grep nginx

# 重新启动 Nginx
nginx -s stop
nginx -c target/web/nginx.conf

数据库说明

初始化

使用 ddl.sql 初始化数据库：

mysql -u root -p < ddl.sql

核心表说明

表名 说明
t_alarm_active 活动告警表，存储当前未恢复的告警
t_alarm_history 历史告警表，存储已恢复的告警
t_alarm_strategy 告警策略表，包含告警/恢复表达式、级别、内容模板
t_alarm_worker 告警Worker表，用于雪花算法分布式协调
t_collector_device 采集设备表，包含设备GID、通道、模板等
t_collector_template 采集模版表，包含协议类型、版本、设备型号
t_collector_template_point 模版测点表，包含测点定义、协议定义
t_device_entity 设备实体表，包含设备GID、名称、所属模组
t_device_point 设备测点表，包含测点表达式、映射关系
t_mozu_info 模组信息表，包含模组ID、名称、发布版本

```

关于
govuejavascript
README.md
80.6 MB
邀请码
    Gitlink（确实开源）
  • 加入我们
  • 官网邮箱：gitlink@ccf.org.cn
    • QQ群
  • QQ群
    • 公众号
  • 公众号

版权所有：中国计算机学会技术支持：开源发展技术委员会
京ICP备13000930号-9 京公网安备 11010802047560号