# control-center

**Repository Path**: SeasonMay/control-center

## Basic Information

- **Project Name**: control-center
- **Description**: 中控端
- **Primary Language**: Unknown
- **License**: Not specified
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 0
- **Forks**: 0
- **Created**: 2026-03-27
- **Last Updated**: 2026-03-30

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# control-center

中控端原型工程，面向微服务数据安全风险分析场景，当前采用 Maven 多模块方式组织，包含统一汇集入口、采集控制、异常检测、服务拓扑识别、敏感数据分析五类服务。

## 模块说明

- `cc-common`：共享消息模型、Kafka topic 常量等公共代码。
- `cc-ingest-service`：中控统一入口，提供 `/center/ingress` 接口，负责接收上行消息并分流到 Kafka。
- `cc-control-service`：消费 `STAT / ACK / ERR`，提供控制命令、节点状态、控制事件查询接口。
- `cc-anomaly-service`：消费 `DATA`，预留异常分析能力，当前提供占位结果查询接口。
- `cc-topology-service`：消费 `DATA`，预留服务依赖与接口识别能力，当前提供占位关系查询接口。
- `cc-sensitive-service`：消费 `DATA`，预留敏感数据识别与追踪能力，当前提供占位发现查询接口。
- `cc-gateway`：网关模块，当前保留基础 Spring Cloud Gateway 骨架。

## 运行依赖

- JDK 21
- Maven 3.9+
- Nacos：`localhost:8848`
- Kafka：`localhost:9092`

Kafka 当前使用的 topic：

- `center.stat.events`
- `center.data.events`
- `center.ctrl.ack`
- `center.ctrl.err`

`cc-ingest-service` 启动时会自动创建以上 topic。

## 构建与启动

构建全部模块：

```powershell
powershell -ExecutionPolicy Bypass -File .\scripts\build-all.ps1 -SkipTests
```

启动全部服务：

```powershell
powershell -ExecutionPolicy Bypass -File .\scripts\start-all.ps1
```

停止全部服务：

```powershell
powershell -ExecutionPolicy Bypass -File .\scripts\stop-all.ps1
```

单独启动某个服务：

```powershell
powershell -ExecutionPolicy Bypass -File .\scripts\run-service.ps1 -Service cc-control-service
```

## 当前接口

- `POST /center/ingress`
- `GET /center/events/recent`
- `GET /center/topics`
- `POST /api/control/commands`
- `GET /api/control/nodes`
- `GET /api/control/events`
- `GET /api/anomalies/events`
- `GET /api/topology/relations`
- `GET /api/sensitive/findings`

## 手动联调示例

发送一条 `DATA` 消息：

```bash
curl -X POST http://localhost:9001/center/ingress -H "Content-Type: application/json" -d "{\"msgType\":\"DATA\",\"traceId\":\"t1\",\"nodeId\":\"n1\",\"body\":{\"protocol\":\"HTTP\",\"src\":\"10.0.0.1\",\"dst\":\"10.0.0.2\"}}"
```

查看对应日志：

- `logs\cc-ingest-service.out.log`
- `logs\cc-control-service.out.log`
- `logs\cc-anomaly-service.out.log`
- `logs\cc-topology-service.out.log`
- `logs\cc-sensitive-service.out.log`

## 当前状态

当前仓库已完成：

- 多服务基础骨架搭建
- Kafka 消息接入与消费骨架
- Nacos 服务注册发现
- 基础 Controller / DTO / Application Service / 内存存储占位

当前仍待补充：

- 控制下行链路
- 真正的异常检测、拓扑建模、敏感数据分析逻辑
- 数据库持久化
- 结果 topic、告警中心和可视化页面