XuJiacheng
910f1c353f
- 新增Redis集成模块，支持心跳写入与控制台日志队列 - 优化Kafka消费者实现，支持多实例与自动重连 - 改进消息处理器，支持批量处理与多层解码 - 更新数据库表结构，调整字段类型与约束 - 添加Redis与Kafka的配置项和环境变量支持 - 补充测试用例和文档说明
76 lines
1.7 KiB
Markdown
76 lines
1.7 KiB
Markdown
# Web_BLS_Heartbeat_Server
|
||
|
||
BLS心跳接收端，用于接收并处理Kafka队列中的心跳数据，经过解包处理后写入PostgreSQL数据库。
|
||
|
||
## 功能介绍
|
||
|
||
- 从Kafka队列接收心跳数据
|
||
- 解包和验证心跳数据格式
|
||
- 批量处理心跳数据，提高处理效率
|
||
- 将处理后的数据写入PostgreSQL数据库
|
||
- 支持高并发和自动重连机制
|
||
|
||
## 技术栈
|
||
|
||
- **Node.js** (JavaScript) - 运行环境
|
||
- **Vite** - 构建工具
|
||
- **Kafka** - 消息队列
|
||
- **PostgreSQL** - 数据库
|
||
|
||
## 快速开始
|
||
|
||
### 安装依赖
|
||
|
||
```bash
|
||
npm install
|
||
```
|
||
|
||
### 配置
|
||
|
||
复制配置文件模板并根据环境需求修改：
|
||
|
||
```bash
|
||
cp src/config/config.example.js src/config/config.js
|
||
```
|
||
|
||
### 构建
|
||
|
||
```bash
|
||
npm run build
|
||
```
|
||
|
||
### 运行
|
||
|
||
```bash
|
||
# 启动后端（Kafka consumer + DB + Redis）
|
||
npm run start
|
||
|
||
# 注意：npm run dev 是 Vite 开发服务器，不会启动 Kafka consumer
|
||
# npm run dev
|
||
```
|
||
|
||
## 项目结构
|
||
|
||
```
|
||
├── src/ # 源代码目录
|
||
│ ├── config/ # 配置文件
|
||
│ ├── kafka/ # Kafka消息处理
|
||
│ ├── processor/ # 心跳数据处理
|
||
│ ├── db/ # 数据库操作
|
||
│ └── index.js # 项目入口
|
||
├── openspec/ # OpenSpec规范文档
|
||
├── package.json # 项目依赖
|
||
├── vite.config.js # Vite配置
|
||
└── README.md # 项目说明
|
||
```
|
||
|
||
## 开发命令
|
||
|
||
| 命令 | 描述 |
|
||
|------|------|
|
||
| `npm install` | 安装项目依赖 |
|
||
| `npm run build` | 构建项目 |
|
||
| `npm run dev` | 启动开发服务器 |
|
||
| `npm run test` | 运行测试 |
|
||
| `npm run lint` | 代码检查 |
|