零延迟监控！DouyinLiveRecorder直播录制与智能通知全攻略

你是否曾错过心仪主播的精彩直播？是否因手动录制操作繁琐而放弃收藏珍贵内容？DouyinLiveRecorder作为一款开源直播录制工具，支持抖音、TikTok等国内外30+直播平台，通过自动化监控与多渠道通知功能，让你轻松捕获每一场重要直播。本文将详解其核心功能实现，从配置到录制全流程指南，助你打造专属直播收藏系统。

核心功能架构解析

DouyinLiveRecorder采用模块化设计，主要包含四大功能模块：直播状态监测、多平台协议解析、视频流录制与转码、消息推送系统。系统架构如下：

graph TD
    A[配置模块<br>config/config.ini] -->|读取参数| B[直播监测<br>main.py:464]
    B -->|调用API| C[平台协议解析<br>douyinliverecorder/stream.py]
    C -->|返回流地址| D[录制引擎<br>main.py:382]
    D -->|完成录制| E[转码处理<br>main.py:217]
    D -->|状态变更| F[消息推送<br>msg_push.py]
    F --> G{推送渠道<br>钉钉/微信/Bark}

配置模块通过config/config.ini文件管理录制参数，包括视频质量（原画/超清）、分段时长（默认1800秒）、代理设置等。监测模块通过多线程定期检查直播间状态，当检测到开播时，调用对应平台的协议解析器获取直播流地址，随后启动FFmpeg进程进行录制。

直播通知系统配置指南

通知系统是不错过直播的关键，支持钉钉、微信、Bark等6种推送渠道。配置步骤如下：

1. 启用推送功能
   编辑config/config.ini，在[推送配置] section设置推送渠道：

   [推送配置]
   直播状态推送渠道 = 钉钉,微信,bark
   钉钉推送接口链接 = https://oapi.dingtalk.com/robot/send?access_token=XXX
   微信推送接口链接 = https://xizhi.qqoq.net/XXX.send
   bark推送接口链接 = https://api.day.app/XXX/
   

2. 自定义通知内容
   系统支持自定义开播/关播通知模板，默认模板在main.py的push_message()函数（325行）定义。如需修改通知格式，可调整：

   msg_title = push_message_title.strip() or "直播间状态更新通知"
   content = f"{record_name} 已开播！\n直播地址: {live_url}"
   

3. 多渠道推送实现
   消息推送逻辑在msg_push.py中实现，支持同时向多个渠道发送通知。以钉钉推送为例，核心代码：

   def dingtalk(url: str, content: str, number: str = None, is_atall: bool = False):
       json_data = {
           'msgtype': 'text',
           'text': {'content': content},
           "at": {"atMobiles": [number], "isAtAll": is_atall}
       }
       # 发送HTTP请求...
   

智能录制功能详解

录制模块支持原画/超清等多画质选择、分段录制、自动转码等高级功能，满足不同场景需求。

录制参数配置

通过config/config.ini设置录制核心参数：

[录制设置]
视频保存格式ts|mkv|flv|mp4|mp3音频|m4a音频 = ts
原画|超清|高清|标清|流畅 = 原画
分段录制是否开启 = 是
视频分段时间(秒) = 1800
录制完成后自动转为mp4格式 = 是

多平台录制实现

以抖音直播为例，douyinliverecorder/stream.py的get_douyin_stream_url()函数（26行）处理协议解析：

def get_douyin_stream_url(json_data: dict, video_quality: str) -> dict:
    status = json_data.get("status", 4)  # 2=直播中,4=未开播
    if status == 2:
        flv_url_dict = json_data['stream_url']['flv_pull_url']
        # 根据画质选择对应流地址...
        return {"is_live": True, "record_url": selected_url}

系统通过分析不同平台的API响应结构，提取FLV或HLS流地址，再调用main.py的check_subprocess()函数（382行）启动FFmpeg录制：

def check_subprocess(record_name: str, record_url: str, ffmpeg_command: list):
    process = subprocess.Popen(ffmpeg_command, stderr=subprocess.STDOUT)
    # 监控录制进程...

高级录制功能

• 分段录制：开启后按设定时长（默认30分钟）自动分割视频，避免单个文件过大
• 自动转码：录制完成后自动将TS格式转为MP4（main.py:217）
• 时间字幕：启用后生成含录制时间的字幕文件（需在配置中设置生成时间字幕文件 = 是）

跨平台录制与代理设置

针对TikTok、Twitch等海外平台，需配置代理支持：

1. 代理参数配置
   在config/config.ini中设置代理服务器及目标平台：

   [录制设置]
   是否使用代理ip(是/否) = 是
   代理地址 = socks5://127.0.0.1:1080
   使用代理录制的平台 = tiktok,sooplive,twitch
   

2. 代理切换逻辑
   代理检测在main.py的start_record()函数（476行）实现，根据域名自动匹配代理规则：

   if proxy_addr:
       for platform in enable_proxy_platform_list:
           if platform in record_url:
               proxy_address = proxy_addr
               break
   

常见问题解决方案

1. 录制失败/无响应

• 检查config/config.ini中的Cookie配置，部分平台（如抖音）需要登录Cookie才能获取直播流
• 查看日志输出，默认日志在控制台显示，关键错误信息在douyinliverecorder/utils.py的logger中定义

2. 推送通知不生效

• 验证推送渠道接口地址是否正确，可通过msg_push.py的测试代码单独测试：

  if __name__ == '__main__':
      send_content = '测试通知'
      xizhi_api = 'https://xizhi.qqoq.net/XXX.send'
      xizhi(xizhi_api, "测试标题", send_content)
  

3. 海外平台无法访问

• 确认代理服务器正常工作，可通过curl --proxy socks5://127.0.0.1:1080 https://www.tiktok.com测试连通性
• 检查config/config.ini中的使用代理录制的平台是否包含目标平台

扩展与二次开发

项目提供灵活的扩展接口，支持添加新平台协议或自定义处理逻辑：

1. 添加新平台支持
   需实现两个核心函数：获取直播间状态（在spider.py）和解析流地址（在stream.py）

2. 自定义录制后操作
   通过配置自定义脚本执行命令，可在录制完成后自动上传云端或进行视频剪辑：

   [录制设置]
   是否录制完成后执行自定义脚本 = 是
   自定义脚本执行命令 = python /path/to/upload.py {save_file_path}
   

项目源码结构清晰，核心模块包括：

• 协议解析：douyinliverecorder/stream.py
• 录制控制：main.py
• 工具函数：douyinliverecorder/utils.py

通过本文指南，你已掌握DouyinLiveRecorder的核心功能配置与使用方法。项目持续更新支持新平台，更多功能请参考README.md。建议定期同步代码更新，以获取最新平台协议支持。