基于 Node.js + Express 的直播录制服务器，支持自动监控、弹幕采集、视频转码和自动投稿。
- 直播录制：使用 FFmpeg 作为下载引擎，支持分段录制（可配置时长）
- 弹幕采集与压制：通过 Chrome 扩展采集弹幕（JSONL），生成 ASS 字幕，FFmpeg 渲染弹幕到视频
- 弹幕工具箱：独立的 Web 界面，管理弹幕采集状态、批量压制、产物播放和下载
- 自动转码：边下边转码（TS → MP4），转码队列 + 并发控制
- HLS 生成：自动为转码后的 MP4 生成 HLS 分片，支持在线播放
- 直播轮询：策略模式支持多平台（虎牙已实现），检测到开播自动触发录制
- 自动投稿：录制完成自动调用 biliup 投稿到 Bilibili，支持模板化投稿
- 看门狗：自动扫描录制目录，跟踪文件状态，清理孤立文件
- 通知系统：录制开始/结束/投稿等事件推送通知（飞书 Webhook / Gotify）
- NAS 备份：支持将录制文件自动备份到 NAS 目录
- Docker 部署：提供 Dockerfile，支持容器化部署
# 安装依赖
npm install
# 开发模式（端口 3001，自动重启）
npm run dev
# 生产模式（端口 1123）
npm start
# 停止服务（pm2）
npm run stop本地配置在 .env 中，参考 .env.example 文件。
| 配置项 | 说明 | 默认值 |
|---|---|---|
| DB_HOST | 数据库主机 | localhost |
| DB_PORT | 数据库端口 | 5432 |
| DB_NAME | 数据库名称 | ks_live_recorder |
| DB_USER | 数据库用户名 | postgres |
| DB_PASSWORD | 数据库密码 | - |
| DB_POOL_MAX | 连接池最大连接数 | 20 |
| DB_POOL_MIN | 连接池最小连接数 | 2 |
| DB_IDLE_TIMEOUT | 连接空闲超时(ms) | 30000 |
| 配置项 | 说明 | 默认值 |
|---|---|---|
| REDIS_HOST | Redis 主机 | localhost |
| REDIS_PORT | Redis 端口 | 6379 |
| REDIS_PASSWORD | Redis 密码 | - |
| REDIS_DB | Redis 数据库编号 | 1 |
| 配置项 | 说明 | 默认值 |
|---|---|---|
| VIDEO_DOWNLOAD_DIR | 录制文件输出根目录（必需） | - |
| DANMAKU_OUTPUT_DIR | 弹幕压制产物独立输出目录 | ${VIDEO_DOWNLOAD_DIR}/../danmaku_output |
| PORT | 服务端口 | 1123（生产）/ 3001（开发） |
| BILIUP_PATH | biliup 可执行文件路径 | biliup |
| BILIUP_WORK_DIR | biliup 工作目录 | $HOME |
| MESSAGE_FEISHU_WEBHOOK | 飞书通知 Webhook URL | - |
| MESSAGE_GOTIFY_SERVER | Gotify 服务器地址 | - |
| MESSAGE_GOTIFY_TOKEN | Gotify 应用 Token | - |
├── app.js # 主入口文件（启动编排）
├── config/ # 配置
│ ├── env.js # 环境变量加载（dotenv quiet 模式）
│ └── config.js # 应用配置（类型常量、输出路径函数）
├── middleware/ # Express 中间件
│ ├── access-log.js # Morgan access log
│ └── view-locals.js # 模板上下文（res.locals）
├── lib/core/ # 核心功能模块
│ ├── logger.js # 日志系统（console 包装、轮转流）
│ ├── lifecycle.js # 启动/关闭生命周期（DB 迁移、服务初始化）
│ ├── RecordingManager.js # 录制进程管理（会话创建/恢复/分段时间追踪）
│ ├── downloaders/ # 下载引擎
│ │ ├── DownloaderFactory.js # 工厂模式（返回 FFmpeg 实例）
│ │ ├── DownloaderInterface.js # 下载器接口（buildArgs/spawn/stop/pause/resume）
│ │ └── FFmpegDownloader.js # FFmpeg 下载引擎（TS 输出、分段检测）
│ ├── danmaku/ # 弹幕采集与字幕生成
│ │ ├── DanmakuRecorder.js # 弹幕采集器（JSONL 写入 danmaku/ 子目录）
│ │ └── DanmakuAssGenerator.js # ASS 字幕生成器（会话级 + 分段级）
│ ├── DanmakuBurnQueue.js # 弹幕压制队列（Redis 队列，独立于转码）
│ ├── danmaku-burner.js # FFmpeg 弹幕压制（ASS 滤镜渲染）
│ ├── polling/ # 直播轮询检测
│ │ ├── PlatformChecker.js # 平台检查器基类（策略模式）
│ │ ├── HuyaChecker.js # 虎牙平台检查器
│ │ └── PollingManager.js # 轮询管理器（定时调度、状态转换检测）
│ ├── TranscodeQueue.js # 转码队列（Redis 队列 + 并发控制）
│ ├── transcoder.js # 视频转码（FFmpeg -c copy TS → MP4）
│ ├── hls-generator.js # HLS 分片生成
│ ├── watchdog.js # 看门狗（文件扫描、状态同步、分段时间补充）
│ ├── scan-files.js # 文件扫描工具
│ ├── backup.js # NAS 备份
│ ├── notify.js # 通知服务（飞书 / Gotify）
│ └── proc-log.js # 进程日志（ffmpeg/biliup 输出捕获）
├── services/ # 业务服务层
│ ├── DataService.js # 公共数据查询（rooms/sessions/settings/files）
│ ├── RecorderService.js # 录制服务（启动/停止/会话完成处理）
│ ├── RoomService.js # 直播间管理（CRUD、暂停/恢复）
│ ├── UploadService.js # 投稿服务（biliup 调用）
│ └── LogCleanupService.js # 日志清理服务（定期清理过期日志）
├── router/ # 路由层（API + 页面渲染）
│ ├── index.js # 统一路由挂载
│ ├── html.js # 页面路由（EJS 渲染）
│ └── danmaku.js # 弹幕相关 API
├── db/ # 数据库
│ ├── index.js # PostgreSQL 连接池
│ ├── migrate.js # 数据库迁移（自动建表/加列）
│ └── redis.js # Redis 客户端
├── views/ # EJS 模板
│ ├── danmaku-toolbox.ejs # 弹幕工具箱页面
│ ├── sessions.ejs # 录制会话列表
│ ├── session-danmaku.ejs # 会话弹幕详情（只读）
│ ├── settings.ejs # 全局设置
│ └── partials/ # 公共模板片段
├── public/ # 静态资源（CSS/JS）
├── scripts/ # 工具脚本
├── logs/ # 应用日志
├── docs/ # 项目文档
│ ├── DB.md # 数据库表结构文档
│ ├── API.md # API 接口文档
│ ├── ARCHITECTURE.md # 系统架构文档
│ ├── DEV.md # 开发指南
│ ├── TEST.md # 测试文档
│ └── todo/ # 开发计划文档
└── test/ # Jest 测试（267 个用例）
弹幕功能已从录制流程中完全解耦，作为独立的工具箱功能运行：
录制流程 弹幕工具箱（独立）
───────── ─────────────────
FFmpeg 录制直播流 Chrome 扩展采集弹幕
↓ ↓
分段文件 (.ts) JSONL → danmaku/danmaku.jsonl
↓ ↓
转码队列 → MP4 ASS 生成 → danmaku/danmaku.ass
↓ ↓
HLS 生成 → 在线播放 分段 ASS → danmaku/segments/*.ass
↓
压制队列 → DANMAKU_OUTPUT_DIR/
↓
弹幕视频 (.mp4) + 日志
目录隔离：弹幕数据存放在 会话目录/danmaku/ 子目录，压制产物输出到独立的 DANMAKU_OUTPUT_DIR/，与录制文件完全隔离。
操作入口：所有弹幕操作（生成 ASS、批量压制、产物管理）统一在「弹幕工具箱」页面（/danmaku-toolbox）完成，录制会话页面仅提供只读状态展示。
# 运行所有测试（267 个用例）
npm test
# 监听模式
npm run test:watch
# 覆盖率报告
npm run test:coverage# ESLint 检查（v9 flat config）
npm run lint
# Prettier 格式化（单引号、2空格缩进）
npm run format
# 提交前建议执行
npm run lint && npm run format && npm test- 运行时：Node.js + Express 5（CommonJS）
- 模板：EJS
- 数据库：PostgreSQL（pg 模块，启动时自动迁移）
- 缓存：Redis（瞬时状态 + 任务队列）
- 下载引擎：FFmpeg（TS 输出、分段录制）
- 弹幕渲染：FFmpeg ASS 滤镜
- 投稿：biliup CLI
- 测试：Jest（v30，单元测试 + API 集成测试）
.env已被 gitignore —— 切勿提交凭据- 模块系统为 CommonJS（
require） - FFmpeg 和 biliup 需单独安装，非 Node 依赖
- 全局设置存储于
settings表，启动时自动插入默认值 - 设计原则：保持轻量，避免引入 chokidar / Worker Thread / 复杂状态机
- Chrome 扩展（弹幕采集 + 直播监听）：
../chrome_live_listener/