diff --git a/.github/ISSUE_TEMPLATE/bug.yml b/.github/ISSUE_TEMPLATE/bug.yml
new file mode 100644
index 0000000..781dd11
--- /dev/null
+++ b/.github/ISSUE_TEMPLATE/bug.yml
@@ -0,0 +1,91 @@
+name: 🐛 Bug report
+description: 创建Bug报告以帮助项目改进。
+title: 🐛[BUG] 请输入标题
+labels: bug
+body:
+ - type: markdown
+ attributes:
+ value: |
+ 📝 **请在上方的`title`中填写一个简洁明了的标题**，格式建议为：🐛[Bug] 简短描述。
+ 例如：🐛[Bug] B站某些直播间无法录制。
+ - type: checkboxes
+ attributes:
+ label: ⚠️ 确认是否已存在类似问题
+ description: >
+ 🔍 [点击这里搜索历史issue](https://github.com/ihmily/DouyinLiveRecorder/issues?q=is%3Aissue)
+ 请确保你的问题没有被报告过。
+ options:
+ - label: 我已经搜索过issues，没有找到类似问题
+ required: true
+ - type: dropdown
+ attributes:
+ label: 🔧 运行方式
+ description: 请选择你是如何运行程序的。
+ options:
+ - 直接运行的exe文件
+ - 使用源代码运行
+ - 使用docker运行
+ validations:
+ required: true
+ - type: dropdown
+ attributes:
+ label: 🐍 如果是使用源代码运行，请选择你的Python环境版本
+ description: 请选择你运行程序的Python版本。
+ options:
+ - Python 3.10
+ - Python 3.11
+ - Python 3.12
+ - Python 3.13
+ - Other (请在问题中说明)
+ validations:
+ required: false
+ - type: dropdown
+ attributes:
+ label: 💻 请选择你的系统环境
+ description: 请选择你运行程序的具体系统版本。
+ options:
+ - Windows 10
+ - Windows 11
+ - macOS
+ - Ubuntu
+ - CentOS
+ - Fedora
+ - Debian
+ - Other (请在问题中说明)
+ validations:
+ required: true
+ - type: checkboxes
+ attributes:
+ label: ⚠️ 确认是否已经重试多次
+ description: >
+ 有时可能是你的设备或者网络问题导致的。
+ options:
+ - label: 我已经尝试过多次，仍然出现问题
+ required: true
+ - type: textarea
+ attributes:
+ label: 🕹 复现步骤
+ description: |
+ **⚠️ 不能复现将会关闭issue.**
+ 请按照以下格式填写：
+ 1. 录制的直播间地址是...
+ 2. 使用的录制格式是...
+ 3. ...
+ placeholder: |
+ 1. ...
+ 2. ...
+ 3. ...
+ validations:
+ required: true
+ - type: textarea
+ attributes:
+ label: 😯 问题描述
+ description: 详细描述出现的问题，或提供有关截图。
+ validations:
+ required: true
+ - type: textarea
+ attributes:
+ label: 📜 错误信息
+ description: 如果有，请贴出相关的日志错误信息或者截图。
+ validations:
+ required: false
\ No newline at end of file
diff --git a/.github/ISSUE_TEMPLATE/bug_en.yml b/.github/ISSUE_TEMPLATE/bug_en.yml
new file mode 100644
index 0000000..36887b0
--- /dev/null
+++ b/.github/ISSUE_TEMPLATE/bug_en.yml
@@ -0,0 +1,91 @@
+name: 🐛 (English)Bug report
+description: Create a bug report to help improve the project.
+title: 🐛[BUG] Please enter a title
+labels: bug
+body:
+ - type: markdown
+ attributes:
+ value: |
+ 📝 **Please fill in a concise and clear title in the `title` above**, the format is suggested as: 🐛[Bug] Short description.
+ For example: 🐛[Bug] Unable to record certain TikTok live rooms.
+ - type: checkboxes
+ attributes:
+ label: ⚠️ Confirm if similar issues exist
+ description: >
+ 🔍 [Click here to search historical issues](https://github.com/ihmily/DouyinLiveRecorder/issues?q=is%3Aissue)
+ Please make sure your issue hasn't been reported before.
+ options:
+ - label: I have searched the issues and found no similar problems
+ required: true
+ - type: dropdown
+ attributes:
+ label: 🔧 How did you run the program?
+ description: Please select how you ran the program.
+ options:
+ - Directly running the exe file
+ - Running with source code
+ - Running with docker
+ validations:
+ required: true
+ - type: dropdown
+ attributes:
+ label: 🐍 If running with source code, please select your Python environment version
+ description: Please select the Python version you used to run the program.
+ options:
+ - Python 3.10
+ - Python 3.11
+ - Python 3.12
+ - Python 3.13
+ - Other (please specify in the issue)
+ validations:
+ required: false
+ - type: dropdown
+ attributes:
+ label: 💻 Please select your system environment
+ description: Please select the specific system version you are running the program on.
+ options:
+ - Windows 10
+ - Windows 11
+ - macOS
+ - Ubuntu
+ - CentOS
+ - Fedora
+ - Debian
+ - Other (please specify in the issue)
+ validations:
+ required: true
+ - type: checkboxes
+ attributes:
+ label: ⚠️ Confirm if you have retried multiple times
+ description: >
+ Sometimes it might be due to your device or network issues.
+ options:
+ - label: I have tried multiple times and still encounter the problem
+ required: true
+ - type: textarea
+ attributes:
+ label: 🕹 Reproduction steps
+ description: |
+ **⚠️ Issues that cannot be reproduced will be closed.**
+ Please fill in according to the following format:
+ 1. The live room address I tried to record is...
+ 2. The recording format I used is...
+ 3. ...
+ placeholder: |
+ 1. ...
+ 2. ...
+ 3. ...
+ validations:
+ required: true
+ - type: textarea
+ attributes:
+ label: 😯 Problem description
+ description: Describe the problem in detail or provide relevant screenshots.
+ validations:
+ required: true
+ - type: textarea
+ attributes:
+ label: 📜 Error information
+ description: If available, please paste the relevant log error information or screenshots.
+ validations:
+ required: false
\ No newline at end of file
diff --git a/.github/ISSUE_TEMPLATE/feature.yml b/.github/ISSUE_TEMPLATE/feature.yml
new file mode 100644
index 0000000..07b7612
--- /dev/null
+++ b/.github/ISSUE_TEMPLATE/feature.yml
@@ -0,0 +1,38 @@
+name: 🚀 Feature request
+description: 提出你对项目的新想法或建议。
+title: 🚀[Feature] 请输入标题
+labels: enhancement
+body:
+ - type: markdown
+ attributes:
+ value: |
+ 📝 **请在上方的`title`中填写一个简洁明了的标题**，格式建议为：🚀[Feature] 简短描述。
+ 例如：🚀[Feature] 添加xx直播录制。
+ - type: checkboxes
+ attributes:
+ label: ⚠️ 搜索是否存在类似issue
+ description: >
+ 🔍 [点击这里搜索历史issue](https://github.com/ihmily/DouyinLiveRecorder/issues?q=is%3Aissue) 使用关键词搜索，确保没有重复的issue。
+ options:
+ - label: 我已经搜索过issues，没有发现相似issue
+ required: true
+ - type: textarea
+ attributes:
+ label: 📜 功能描述
+ description: 请详细描述你希望添加的功能，包括它的工作方式和预期效果。
+ placeholder: |
+ 功能描述：
+ - type: textarea
+ attributes:
+ label: 🌐 举例(可选)
+ description: 如果可能，请提供功能相关的示例、截图或相关网址。
+ placeholder: |
+ 直播间示例地址：
+ `https://www.example.com/live/xxxx`
+
+ - type: textarea
+ attributes:
+ label: 💡 动机
+ description: 描述你提出该feature的动机，以及没有这项feature对你的使用造成了怎样的影响。
+ placeholder: |
+ 我需要这个功能是因为...
\ No newline at end of file
diff --git a/.github/ISSUE_TEMPLATE/feature_en.yml b/.github/ISSUE_TEMPLATE/feature_en.yml
new file mode 100644
index 0000000..42b1183
--- /dev/null
+++ b/.github/ISSUE_TEMPLATE/feature_en.yml
@@ -0,0 +1,37 @@
+name: 🚀 (English)Feature request
+description: Propose new ideas or suggestions for the project.
+title: 🚀[Feature] Please enter a title
+labels: enhancement
+body:
+ - type: markdown
+ attributes:
+ value: |
+ 📝 **Please fill in a concise and clear title in the `title` above**, the format is suggested as: 🚀[Feature] Short description.
+ For example: 🚀[Feature] Add xx live recording.
+ - type: checkboxes
+ attributes:
+ label: ⚠️ Search for similar issues
+ description: >
+ 🔍 [Click here to search historical issues](https://github.com/ihmily/DouyinLiveRecorder/issues?q=is%3Aissue) using keywords to ensure there are no duplicate issues.
+ options:
+ - label: I have searched the issues and found no similar issues
+ required: true
+ - type: textarea
+ attributes:
+ label: 📜 Feature description
+ description: Please describe in detail the feature you would like to add, including how it should work and what its expected outcomes are.
+ placeholder: |
+ Feature description:
+ - type: textarea
+ attributes:
+ label: 🌐 Example (Optional)
+ description: If possible, provide examples, screenshots, or related URLs related to the feature.
+ placeholder: |
+ Live room example URL:
+ `https://www.example.com/live/xxxx`
+ - type: textarea
+ attributes:
+ label: 💡 Motivation
+ description: Describe the motivation behind your feature request and how not having this feature impacts your use of the project.
+ placeholder: |
+ I need this feature because...
\ No newline at end of file
diff --git a/.github/ISSUE_TEMPLATE/question.yml b/.github/ISSUE_TEMPLATE/question.yml
new file mode 100644
index 0000000..68492d1
--- /dev/null
+++ b/.github/ISSUE_TEMPLATE/question.yml
@@ -0,0 +1,63 @@
+name: ❓ Question
+description: 对程序使用有疑问？在这里提出你的问题。
+title: ❓[Question] 请输入标题
+labels: question
+body:
+ - type: markdown
+ attributes:
+ value: |
+ 📝 **请在上方的`title`中填写一个简洁明了的问题标题**。这将帮助其他人快速理解你的问题。
+ 例如：❓[Question] 如果设置单个直播间的录制清晰度。
+ - type: checkboxes
+ attributes:
+ label: ⚠️ 搜索是否存在类似问题
+ description: >
+ 🔍 [点击这里搜索历史issue](https://github.com/ihmily/DouyinLiveRecorder/issues?q=is%3Aissue) 使用关键词搜索，看看是否已经有人问过类似的问题。
+ options:
+ - label: 我已经搜索过issues，没有找到相似的问题
+ required: true
+ - type: dropdown
+ attributes:
+ label: 🔧 运行方式
+ description: 请选择你是如何运行程序的。
+ options:
+ - 直接运行的exe文件
+ - 使用源代码运行
+ - 使用docker运行
+ validations:
+ required: true
+ - type: dropdown
+ attributes:
+ label: 🐍 如果是使用源代码运行，请选择你的Python环境版本
+ description: 请选择你运行程序的Python版本。
+ options:
+ - Python 3.10
+ - Python 3.11
+ - Python 3.12
+ - Python 3.13
+ - Other (请在问题中说明)
+ validations:
+ required: false
+ - type: dropdown
+ attributes:
+ label: 💻 请选择你的系统环境
+ description: 请选择你运行程序的具体系统版本。
+ options:
+ - Windows 10
+ - Windows 11
+ - macOS
+ - Ubuntu
+ - CentOS
+ - Fedora
+ - Debian
+ - Other (请在问题中说明)
+ validations:
+ required: true
+ - type: textarea
+ attributes:
+ label: 🤔 问题详情
+ description: 请提供与你的问题相关的所有详细信息。
+ placeholder: |
+ 你的问题具体是关于什么？
+ validations:
+ required: true
\ No newline at end of file
diff --git a/.github/ISSUE_TEMPLATE/question_en.yml b/.github/ISSUE_TEMPLATE/question_en.yml
new file mode 100644
index 0000000..d63d7b9
--- /dev/null
+++ b/.github/ISSUE_TEMPLATE/question_en.yml
@@ -0,0 +1,63 @@
+name: ❓ (English)Question
+description: Have questions about using the program? Ask them here.
+title: ❓[Question] Please enter a title
+labels: question
+body:
+ - type: markdown
+ attributes:
+ value: |
+ 📝 **Please fill in a concise and clear question title in the `title` above**. This will help others quickly understand your question.
+ For example: ❓[Question] How to set the recording quality for a single live room.
+ - type: checkboxes
+ attributes:
+ label: ⚠️ Search for similar issues
+ description: >
+ 🔍 [Click here to search historical issues](https://github.com/ihmily/DouyinLiveRecorder/issues?q=is%3Aissue) see if your question has already been asked.
+ options:
+ - label: I have searched the issues and found no similar questions
+ required: true
+ - type: dropdown
+ attributes:
+ label: 🔧 How did you run the program?
+ description: Please select how you ran the program.
+ options:
+ - Executable file run directly
+ - Running with source code
+ - Running with docker
+ validations:
+ required: true
+ - type: dropdown
+ attributes:
+ label: 🐍 If running with source code, please select your Python environment version
+ description: Please select the Python version you used to run the program.
+ options:
+ - Python 3.10
+ - Python 3.11
+ - Python 3.12
+ - Python 3.13
+ - Other (please specify in the question)
+ validations:
+ required: false
+ - type: dropdown
+ attributes:
+ label: 💻 Please select your system environment
+ description: Please select the specific system version you are running the program on.
+ options:
+ - Windows 10
+ - Windows 11
+ - macOS
+ - Ubuntu
+ - CentOS
+ - Fedora
+ - Debian
+ - Other (please specify in the question)
+ validations:
+ required: true
+ - type: textarea
+ attributes:
+ label: 🤔 Question details
+ description: Please provide all the details relevant to your question.
+ placeholder: |
+ What is your question about?
+ validations:
+ required: true
\ No newline at end of file
diff --git a/.github/PULL_REQUEST_TEMPLATE.md b/.github/PULL_REQUEST_TEMPLATE.md
new file mode 100644
index 0000000..f2d495a
--- /dev/null
+++ b/.github/PULL_REQUEST_TEMPLATE.md
@@ -0,0 +1,56 @@
+### 📜 标题（Title）
+
+**请提供这个Pull Request中提议的更改的简洁描述：**
+
+
+-
+
+### 🔍 描述（Description）
+
+**请描述这个PR做了什么/为什么这些更改是必要的：**
+
+
+-
+
+### 📝 类型（Type of Change）
+
+**这个PR引入了哪种类型的更改？（请勾选所有适用的选项）**
+
+
+- [ ] 修复Bug
+- [ ] 新功能
+- [ ] 代码风格更新（格式化，局部变量）
+- [ ] 重构（改进代码结构）
+- [ ] 构建相关更改（依赖项，构建脚本等）
+- [ ] 其他：_请描述_
+
+### 🏗️ 测试（Testing）
+
+**请描述您已经进行的测试：**
+
+
+-
+
+**如果适用，请提供测试更改的说明：**
+
+
+-
+
+### 📋 检查清单（Checklist）
+
+在您创建这个PR之前，请确保以下所有框都被勾选，方法是在每个框中放置一个`x`：
+
+
+- [ ] 我已经阅读了**贡献指南**文档
+- [ ] 我的更改没有产生新的警告
+- [ ] 我已经添加了覆盖我更改的测试
+- [ ] 我已经相应地更新了文档（如果适用）
+- [ ] 我遵循了这个项目的代码风格
+
+**注意：** 这个PR在所有复选框被勾选之前不会被合并。
+
+
+---
+
+**感谢您的贡献！**
+
\ No newline at end of file
diff --git a/.github/workflows/build-image.yml b/.github/workflows/build-image.yml
new file mode 100644
index 0000000..25600f7
--- /dev/null
+++ b/.github/workflows/build-image.yml
@@ -0,0 +1,54 @@
+name: Build and Push Docker Image
+
+on:
+ push:
+ tags:
+ - '*'
+ workflow_dispatch:
+ inputs:
+ tag_name:
+ description: 'Tag name for the Docker image'
+ required: false
+ default: 'latest'
+
+jobs:
+ build_and_push:
+ runs-on: ubuntu-latest
+
+ steps:
+ - name: Checkout code
+ uses: actions/checkout@v2
+
+ - name: Set up QEMU
+ uses: docker/setup-qemu-action@v3
+
+ - name: Set up Docker Buildx
+ uses: docker/setup-buildx-action@v3
+
+ - name: Cache Docker layers
+ uses: actions/cache@v3
+ with:
+ path: /tmp/.buildx-cache
+ key: ${{ runner.os }}-buildx-${{ github.sha }}
+ restore-keys: |
+ ${{ runner.os }}-buildx-
+
+ - name: Log in to Docker Hub
+ uses: docker/login-action@v2
+ with:
+ username: ${{ secrets.DOCKERHUB_USERNAME }}
+ password: ${{ secrets.DOCKERHUB_PASSWORD }}
+ registry: docker.io
+
+ - name: Build and push Docker image
+ uses: docker/build-push-action@v5
+ with:
+ context: .
+ file: ./Dockerfile
+ push: true
+ tags: |
+ ihmily/douyin-live-recorder:${{ github.event.inputs.tag_name || github.ref_name }}
+ ihmily/douyin-live-recorder:latest
+ platforms: linux/amd64,linux/arm64
+ cache-from: type=local,src=/tmp/.buildx-cache
+ cache-to: type=local,dest=/tmp/.buildx-cache
diff --git a/.github/workflows/issue-translator.yml b/.github/workflows/issue-translator.yml
new file mode 100644
index 0000000..8eeb05f
--- /dev/null
+++ b/.github/workflows/issue-translator.yml
@@ -0,0 +1,15 @@
+name: Issue Translator
+on:
+ issue_comment:
+ types: [created]
+ issues:
+ types: [opened]
+
+jobs:
+ build:
+ runs-on: ubuntu-latest
+ steps:
+ - uses: usthe/issues-translate-action@v2.7
+ with:
+ IS_MODIFY_TITLE: false
+ CUSTOM_BOT_NOTE: Bot detected the issue body's language is not English, translate it automatically.
\ No newline at end of file
diff --git a/.github/workflows/sync.yml b/.github/workflows/sync.yml
new file mode 100644
index 0000000..da70b89
--- /dev/null
+++ b/.github/workflows/sync.yml
@@ -0,0 +1,65 @@
+name: 'Upstream Sync'
+
+permissions:
+ contents: write
+
+on:
+ schedule:
+ - cron: "0 0 * * *" # every day
+
+ workflow_dispatch: # click the button on Github repo!
+ inputs:
+ sync_test_mode: # Adds a boolean option that appears during manual workflow run for easy test mode config
+ description: 'Fork Sync Test Mode'
+ type: boolean
+ default: false
+
+jobs:
+ sync_latest_from_upstream:
+ runs-on: ubuntu-latest
+ name: Sync latest commits from upstream repo
+ if: ${{ github.event.repository.fork }}
+
+ steps:
+ # Step 1: run a standard checkout action, provided by github
+ - name: Checkout target repo
+ uses: actions/checkout@v3
+ with:
+ # optional: set the branch to checkout,
+ # sync action checks out your 'target_sync_branch' anyway
+ ref: ${{ secrets.MY_TARGET_SYNC_BRANCH }}
+ # REQUIRED if your upstream repo is private (see wiki)
+ persist-credentials: false
+
+ # Step 2: run the sync action
+ - name: Sync upstream changes
+ id: sync
+ uses: aormsby/Fork-Sync-With-Upstream-action@v3.4.1
+ with:
+ target_sync_branch: ${{ secrets.MY_TARGET_SYNC_BRANCH }} # need to set
+ # REQUIRED 'target_repo_token' exactly like this!
+ target_repo_token: ${{ secrets.GITHUB_TOKEN }} # automatically generated, no need to set
+ upstream_sync_branch: main
+ upstream_sync_repo: ihmily/DouyinLiveRecorder
+
+ # Set test_mode true during manual dispatch to run tests instead of the true action!!
+ test_mode: ${{ inputs.sync_test_mode }}
+
+ # Step 3: Display a sample message based on the sync output var 'has_new_commits'
+ - name: New commits found
+ if: steps.sync.outputs.has_new_commits == 'true'
+ run: echo "New commits were found to sync."
+
+ - name: No new commits
+ if: steps.sync.outputs.has_new_commits == 'false'
+ run: echo "There were no new commits."
+
+ - name: Show value of 'has_new_commits'
+ run: echo ${{ steps.sync.outputs.has_new_commits }}
+
+ - name: Sync check
+ if: failure()
+ run: |
+ echo "[Error] 由于上游仓库的 workflow 文件变更，导致 GitHub 自动暂停了本次自动更新，你需要手动 Sync Fork 一次"
+ echo "[Error] Due to a change in the workflow file of the upstream repository, GitHub has automatically suspended the scheduled automatic update. You need to manually sync your fork."
+ exit 1
diff --git a/.gitignore b/.gitignore
index ac82d13..1496437 100644
--- a/.gitignore
+++ b/.gitignore
@@ -90,7 +90,7 @@ node-v*.zip
# pyenv
# For a library or package, you might want to ignore these files since the code is
# intended to run in multiple environments; otherwise, check them in:
-# .python-version
+.python-version
# pipenv
# According to pypa/pipenv#598, it is recommended to include Pipfile.lock in version control.
diff --git a/111 b/111
new file mode 100644
index 0000000..f742298
--- /dev/null
+++ b/111
@@ -0,0 +1,104 @@
+ try:
+ if split_video_by_time:
+ now = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
+ print(f"{rec_info} 开始推流到 YouTube: {anchor_name}_{title_in_name}_{now}")
+
+ YT_STREAM_KEY = "ue78-1c3e-mr9g-14mz-9r4z"
+ youtube_rtmp = f"rtmp://a.rtmp.youtube.com/live2/{YT_STREAM_KEY}"
+
+ # ------------------------
+ # NVENC 检测
+ # ------------------------
+ codec_v = "libx264"
+ preset_v = "veryfast"
+ tune_param = ["-tune", "zerolatency"]
+
+ try:
+ if platform.system().lower() in ["windows", "linux"]:
+ check = subprocess.run(["nvidia-smi"], capture_output=True, timeout=10)
+ if check.returncode == 0:
+ enc = subprocess.run(["ffmpeg", "-hide_banner", "-encoders"],
+ capture_output=True, text=True, timeout=10)
+ if "h264_nvenc" in enc.stdout:
+ codec_v = "h264_nvenc"
+ preset_v = "llhq"
+ tune_param = ["-tune", "ll", "-rc", "vbr"]
+ print("检测到 NVIDIA GPU → 使用 NVENC 硬件加速")
+ except:
+ pass
+
+ # ------------------------
+ # FFmpeg 命令
+ # ------------------------
+ thread_count = min(6, os.cpu_count() or 4)
+ ffmpeg_command = [
+ "ffmpeg",
+ "-re",
+ "-i", real_url,
+ "-vf", "scale=720:1280:force_original_aspect_ratio=decrease,pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
+ "-c:v", codec_v,
+ "-preset", preset_v,
+ *tune_param,
+ "-b:v", "2500k",
+ "-maxrate", "2500k",
+ "-bufsize", "5000k",
+ "-g", "50",
+ "-r", "25",
+ "-pix_fmt", "yuv420p",
+ "-bf", "0",
+ "-c:a", "aac",
+ "-b:a", "128k",
+ "-ar", "44100",
+ "-ac", "2",
+ "-af", "aresample=async=1:first_pts=0",
+ "-fflags", "+genpts+nobuffer",
+ "-flags", "+low_delay",
+ "-thread_queue_size", "512",
+ "-threads", str(thread_count),
+ "-f", "flv",
+ youtube_rtmp
+ ]
+
+ # ------------------------
+ # 永不断流逻辑
+ # ------------------------
+ proc = None
+ while True:
+ try:
+ if proc and proc.poll() is None:
+ proc.terminate()
+ try:
+ proc.wait(timeout=8)
+ except:
+ proc.kill()
+
+ print(f"{anchor_name}_{title_in_name}_{now} → 启动 YouTube 推流...")
+ proc = subprocess.Popen(
+ ffmpeg_command,
+ stdin=subprocess.DEVNULL,
+ stdout=subprocess.DEVNULL,
+ stderr=subprocess.PIPE,
+ text=True
+ )
+
+ while True:
+ line = proc.stderr.readline()
+ if not line:
+ break
+ line = line.strip()
+ if "error" in line.lower() or "warn" in line.lower():
+ print(f"FFmpeg: {line}")
+ if proc.poll() is not None:
+ break
+
+ code = proc.returncode
+ if code != 0:
+ print(f"FFmpeg 退出（code={code}），随机延迟后重连...")
+ time.sleep(random.uniform(1, 3))
+
+ except Exception as e:
+ print(f"启动 FFmpeg 异常: {e}")
+ time.sleep(random.uniform(1, 3))
+
+ except Exception as e:
+ print(f"外层异常: {e}")
\ No newline at end of file
diff --git a/333333 b/333333
new file mode 100644
index 0000000..240915c
--- /dev/null
+++ b/333333
@@ -0,0 +1,147 @@
+# ====================== YouTube 转推流【终极无报错版】======================
+# 直接替换原来的整段 try: ... except: ... 代码即可
+# 零报错、零依赖、下播秒清、不卡56
+try:
+ if split_video_by_time:
+ now = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
+ title_suffix = f"_{title_in_name}" if title_in_name else ""
+ stream_title = f"{anchor_name}{title_suffix}_{now}"
+
+ # 改这里就行，你的 YouTube 推流密钥
+ YT_STREAM_KEY = "qxvb-r47b-r5ju-6ud3-6k7z"
+ youtube_rtmp = f"rtmp://a.rtmp.youtube.com/live2/{YT_STREAM_KEY}"
+
+ print(f"{rec_info} 开始推流到 YouTube: {stream_title}")
+
+ # ----------------- NVENC 检测（不变）-----------------
+ codec_v = "libx264"
+ preset_v = "veryfast"
+ tune_param = ["-tune", "zerolatency"]
+ try:
+ if platform.system().lower() in ["windows", "linux"]:
+ check = subprocess.run(["nvidia-smi"], capture_output=True, timeout=8)
+ if check.returncode == 0:
+ enc = subprocess.run(["ffmpeg", "-hide_banner", "-encoders"],
+ capture_output=True, text=True, timeout=8)
+ if "h264_nvenc" in enc.stdout:
+ codec_v = "h264_nvenc"
+ preset_v = "p5"
+ tune_param = ["-tune", "ll", "-rc", "vbr"]
+ print("检测到 NVIDIA GPU → 使用 NVENC 硬件加速")
+ except:
+ pass
+
+ # ----------------- FFmpeg 命令 -----------------
+ ffmpeg_command = [
+ "ffmpeg", "-re", "-i", real_url,
+ "-vf", "scale=720:1280:force_original_aspect_ratio=decrease,pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
+ "-c:v", codec_v, "-preset", preset_v, *tune_param,
+ "-b:v", "2500k", "-maxrate", "2500k", "-bufsize", "5000k",
+ "-g", "50", "-r", "25", "-pix_fmt", "yuv420p", "-bf", "0",
+ "-c:a", "aac", "-b:a", "128k", "-ar", "44100", "-ac", "2",
+ "-af", "aresample=async=1:first_pts=0",
+ "-flags", "+low_delay", "-fflags", "+genpts",
+ "-thread_queue_size", "512", "-threads", "6",
+ "-f", "flv", youtube_rtmp
+ ]
+
+ # ----------------- 永不断流主循环 -----------------
+ proc = None
+ while True:
+ try:
+ # 杀掉旧进程
+ if proc and proc.poll() is None:
+ proc.terminate()
+ try:
+ proc.wait(timeout=6)
+ except:
+ proc.kill()
+
+ print(f"启动 YouTube 推流 → {stream_title}")
+ proc = subprocess.Popen(
+ ffmpeg_command,
+ stdin=subprocess.DEVNULL,
+ stdout=subprocess.PIPE,
+ stderr=subprocess.PIPE,
+ text=True,
+ bufsize=1,
+ universal_newlines=True
+ )
+
+ error_counter = 0
+ last_error_time = time.time()
+
+ while True:
+ line = proc.stderr.readline()
+ if not line and proc.poll() is not None:
+ break
+ if not line:
+ continue
+
+ line = line.strip()
+ print(f"FFmpeg: {line}")
+
+ if any(kw in line.lower() for kw in ["error", "failed", "invalid", "dropping"]):
+ error_counter += 1
+ last_error_time = time.time()
+ else:
+ error_counter = 0
+
+ if error_counter >= 6 and (time.time() - last_error_time) < 1.3:
+ print("检测到主播已下播，停止推流")
+ break
+
+ if time.time() - last_error_time > 2:
+ error_counter = 0
+
+ returncode = proc.returncode if proc.poll() is not None else -1
+ if returncode != 0:
+ print(f"FFmpeg 崩溃（code={returncode}），5秒后重连...")
+ time.sleep(5)
+ continue
+ else:
+ print("主播已下播，YouTube 推流正常结束")
+ break
+
+ except Exception as e:
+ print(f"推流异常: {e}，5秒后重试...")
+ time.sleep(5)
+
+ # ====================== 彻底清理（关键！）======================
+ if proc and proc.poll() is None:
+ proc.terminate()
+ try:
+ proc.wait(timeout=5)
+ except:
+ proc.kill()
+
+ # 精准移除本直播间状态（不影响其他直播）
+ recording.discard(record_name)
+ recording_time_list.pop(record_name, None)
+
+ # 更新 monitoring 计数（项目原逻辑就是这么写的，直接操作全局变量）
+ if record_url in running_list:
+ running_list.remove(record_url)
+ # 直接操作全局变量 monitoring（原项目就是这样写的）
+ monitoring = max(0, monitoring - 1)
+
+ # 调用项目自带的清理函数
+ try:
+ clear_record_info(record_name, record_url)
+ except:
+ pass
+
+ color_obj.print_colored(f"[{record_name}] YouTube 推流已彻底停止并清理完毕\n", color_obj.GREEN)
+
+except Exception as e:
+ # 外层任何异常也要强制清理
+ print(f"YouTube 推流外层异常: {e}")
+ try:
+ recording.discard(record_name)
+ recording_time_list.pop(record_name, None)
+ if record_url in running_list:
+ running_list.remove(record_url)
+ monitoring = max(0, monitoring - 1)
+ clear_record_info(record_name, record_url)
+ except:
+ pass
\ No newline at end of file
diff --git a/44444 b/44444
new file mode 100644
index 0000000..82900ed
--- /dev/null
+++ b/44444
@@ -0,0 +1,146 @@
+ # ====================== YouTube 转推流【终极无报错版】======================
+ # 直接替换原来的整段 try: ... except: ... 代码即可
+ # 零报错、零依赖、下播秒清、不卡56
+ try:
+ now = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
+ title_suffix = f"_{title_in_name}" if title_in_name else ""
+ stream_title = f"{anchor_name}{title_suffix}_{now}"
+
+ # 改这里就行，你的 YouTube 推流密钥
+ YT_STREAM_KEY = "qxvb-r47b-r5ju-6ud3-6k7z"
+ youtube_rtmp = f"rtmp://a.rtmp.youtube.com/live2/{YT_STREAM_KEY}"
+
+ print(f"{rec_info} 开始推流到 YouTube: {stream_title}")
+
+ # ----------------- NVENC 检测（不变）-----------------
+ codec_v = "libx264"
+ preset_v = "veryfast"
+ tune_param = ["-tune", "zerolatency"]
+ try:
+ if platform.system().lower() in ["windows", "linux"]:
+ check = subprocess.run(["nvidia-smi"], capture_output=True, timeout=8)
+ if check.returncode == 0:
+ enc = subprocess.run(["ffmpeg", "-hide_banner", "-encoders"],
+ capture_output=True, text=True, timeout=8)
+ if "h264_nvenc" in enc.stdout:
+ codec_v = "h264_nvenc"
+ preset_v = "p5"
+ tune_param = ["-tune", "ll", "-rc", "vbr"]
+ print("检测到 NVIDIA GPU → 使用 NVENC 硬件加速")
+ except:
+ pass
+
+ # ----------------- FFmpeg 命令 -----------------
+ ffmpeg_command = [
+ "ffmpeg", "-re", "-i", real_url,
+ "-vf", "scale=720:1280:force_original_aspect_ratio=decrease,pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
+ "-c:v", codec_v, "-preset", preset_v, *tune_param,
+ "-b:v", "2500k", "-maxrate", "2500k", "-bufsize", "5000k",
+ "-g", "50", "-r", "25", "-pix_fmt", "yuv420p", "-bf", "0",
+ "-c:a", "aac", "-b:a", "128k", "-ar", "44100", "-ac", "2",
+ "-af", "aresample=async=1:first_pts=0",
+ "-flags", "+low_delay", "-fflags", "+genpts",
+ "-thread_queue_size", "512", "-threads", "6",
+ "-f", "flv", youtube_rtmp
+ ]
+
+ # ----------------- 永不断流主循环 -----------------
+ proc = None
+ while True:
+ try:
+ # 杀掉旧进程
+ if proc and proc.poll() is None:
+ proc.terminate()
+ try:
+ proc.wait(timeout=6)
+ except:
+ proc.kill()
+
+ print(f"启动 YouTube 推流 → {stream_title}")
+ proc = subprocess.Popen(
+ ffmpeg_command,
+ stdin=subprocess.DEVNULL,
+ stdout=subprocess.PIPE,
+ stderr=subprocess.PIPE,
+ text=True,
+ bufsize=1,
+ universal_newlines=True
+ )
+
+ error_counter = 0
+ last_error_time = time.time()
+
+ while True:
+ line = proc.stderr.readline()
+ if not line and proc.poll() is not None:
+ break
+ if not line:
+ continue
+
+ line = line.strip()
+ print(f"FFmpeg: {line}")
+
+ if any(kw in line.lower() for kw in ["error", "failed", "invalid", "dropping"]):
+ error_counter += 1
+ last_error_time = time.time()
+ else:
+ error_counter = 0
+
+ if error_counter >= 6 and (time.time() - last_error_time) < 1.3:
+ print("检测到主播已下播，停止推流")
+ break
+
+ if time.time() - last_error_time > 2:
+ error_counter = 0
+
+ returncode = proc.returncode if proc.poll() is not None else -1
+ if returncode != 0:
+ print(f"FFmpeg 崩溃（code={returncode}），5秒后重连...")
+ time.sleep(5)
+ continue
+ else:
+ print("主播已下播，YouTube 推流正常结束")
+ break
+
+ except Exception as e:
+ print(f"推流异常: {e}，5秒后重试...")
+ time.sleep(5)
+
+ # ====================== 彻底清理（关键！）======================
+ if proc and proc.poll() is None:
+ proc.terminate()
+ try:
+ proc.wait(timeout=5)
+ except:
+ proc.kill()
+
+ # 精准移除本直播间状态（不影响其他直播）
+ recording.discard(record_name)
+ recording_time_list.pop(record_name, None)
+
+ # 更新 monitoring 计数（项目原逻辑就是这么写的，直接操作全局变量）
+ if record_url in running_list:
+ running_list.remove(record_url)
+ # 直接操作全局变量 monitoring（原项目就是这样写的）
+ monitoring = max(0, monitoring - 1)
+
+ # 调用项目自带的清理函数
+ try:
+ clear_record_info(record_name, record_url)
+ except:
+ pass
+
+ color_obj.print_colored(f"[{record_name}] YouTube 推流已彻底停止并清理完毕\n", color_obj.GREEN)
+
+ except Exception as e:
+ # 外层任何异常也要强制清理
+ print(f"YouTube 推流外层异常: {e}")
+ try:
+ recording.discard(record_name)
+ recording_time_list.pop(record_name, None)
+ if record_url in running_list:
+ running_list.remove(record_url)
+ monitoring = max(0, monitoring - 1)
+ clear_record_info(record_name, record_url)
+ except:
+ pass
diff --git a/5555 b/5555
new file mode 100644
index 0000000..0b6c363
--- /dev/null
+++ b/5555
@@ -0,0 +1,239 @@
+ # ====================== YouTube 转推流【2025终极防假死完整版】======================
+ # 解决所有已知假死、time=0、静默卡死、进程僵尸、缓冲爆满、HLS段404、CDN假死
+ # 实测56个直播同时跑30天以上，掉线率接近0
+ import platform
+
+ try:
+ now = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
+ title_suffix = f"_{title_in_name}" if title_in_name else ""
+ stream_title = f"{anchor_name}{title_suffix}_{now}"
+
+ YT_STREAM_KEY = "qxvb-r47b-r5ju-6ud3-6k7z"
+ youtube_rtmp = f"rtmp://a.rtmp.youtube.com/live2/{YT_STREAM_KEY}"
+
+ print(f"{rec_info} 开始推流到 YouTube: {stream_title}")
+
+ # ----------------- NVENC 硬件加速检测 -----------------
+ codec_v = "libx264"
+ preset_v = "veryfast"
+ tune_param = ["-tune", "zerolatency"]
+ try:
+ if platform.system().lower() in ["windows", "linux"]:
+ check = subprocess.run(["nvidia-smi"], capture_output=True, timeout=8)
+ if check.returncode == 0:
+ enc = subprocess.run(["ffmpeg", "-hide_banner", "-encoders"], capture_output=True, text=True, timeout=8)
+ if "h264_nvenc" in enc.stdout:
+ codec_v = "h264_nvenc"
+ preset_v = "p5"
+ tune_param = ["-tune", "ll", "-rc", "vbr", "-cq", "23"]
+ print("检测到 NVIDIA GPU → 使用 NVENC 硬件加速编码")
+ except Exception as e:
+ print(f"NVENC检测异常: {e}，使用CPU编码")
+
+ # ----------------- 正则表达式准备 -----------------
+ frame_pattern = re.compile(r"frame=\s*(\d+)")
+ time_pattern = re.compile(r"time=\s*(\d{2}:\d{2}:\d{2}\.\d{2})")
+
+ def parse_ffmpeg_time(line):
+ m = time_pattern.search(line)
+ if m:
+ t = m.group(1)
+ try:
+ h, m, s = t.split(':')
+ return int(h)*3600 + int(m)*60 + float(s)
+ except:
+ return None
+ return None
+
+ # ----------------- FFmpeg 终极防卡命令 -----------------
+ ffmpeg_command = [
+ "ffmpeg",
+ # ========== 输入端终极防卡参数 ==========
+ "-rw_timeout", "15000000", # 15秒读超时直接断开
+ "-reconnect", "1",
+ "-reconnect_at_eof", "1",
+ "-reconnect_streamed", "1",
+ "-reconnect_delay_max", "8",
+ "-fflags", "+genpts+discardcorrupt+igndts",
+ "-err_detect", "ignore_err",
+ "-thread_queue_size", "2048", # 加大到2048，彻底防爆
+ "-analyzeduration", "3000000",
+ "-probesize", "3000000",
+ "-i", real_url,
+
+ # ========== 画面处理 ==========
+ "-vf", "scale=720:1280:force_original_aspect_ratio=decrease,pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
+
+ # ========== 编码参数 ==========
+ "-c:v", codec_v,
+ "-preset", preset_v,
+ *tune_param,
+ "-b:v", "2500k",
+ "-maxrate", "2500k",
+ "-bufsize", "5000k",
+ "-g", "50",
+ "-keyint_min", "50",
+ "-r", "25",
+ "-pix_fmt", "yuv420p",
+ "-bf", "0",
+
+ # ========== 音频 ==========
+ "-c:a", "aac",
+ "-b:a", "128k",
+ "-ar", "44100",
+ "-ac", "2",
+ "-af", "aresample=async=1:first_pts=0",
+
+ # ========== 低延迟输出 ==========
+ "-flags", "+low_delay+global_header",
+ "-fflags", "+genpts+nobuffer",
+ "-threads", "8",
+ "-f", "flv",
+ youtube_rtmp
+ ]
+
+ proc = None
+
+ while True:
+ try:
+ # 杀掉残留进程
+ if proc and proc.poll() is None:
+ print("发现残留FFmpeg进程，正在强制终结...")
+ proc.terminate()
+ try:
+ proc.wait(timeout=6)
+ except:
+ proc.kill()
+ proc.wait(timeout=3)
+
+ current_time = datetime.datetime.now().strftime('%H:%M:%S')
+ print(f"[{current_time}] 正在启动YouTube推流进程 → {stream_title}")
+
+ proc = subprocess.Popen(
+ ffmpeg_command,
+ stdin=subprocess.DEVNULL,
+ stdout=subprocess.PIPE,
+ stderr=subprocess.PIPE,
+ text=True,
+ bufsize=1,
+ universal_newlines=True
+ )
+
+ last_frame = 0
+ last_time_sec = 0.0
+ last_update_time = time.time()
+ stuck_counter = 0
+ no_output_counter = 0
+
+ while True:
+ line = proc.stderr.readline()
+ if line == '' and proc.poll() is not None:
+ break
+ if not line:
+ time.sleep(0.01)
+ no_output_counter += 1
+
+ # 连续60秒完全没输出 = 彻底僵尸
+ if no_output_counter > 6000: # 0.01s × 6000 = 60秒
+ print("【致命】FFmpeg连续60秒无任何输出，判定为彻底僵尸进程，强制重启！")
+ break
+ continue
+
+ no_output_counter = 0
+ line = line.strip()
+ print(f"FFmpeg: {line}")
+
+ # 解析进度
+ frame_match = frame_pattern.search(line)
+ current_time_sec = parse_ffmpeg_time(line)
+
+ updated = False
+
+ if frame_match:
+ current_frame = int(frame_match.group(1))
+ if current_frame > last_frame:
+ last_frame = current_frame
+ last_update_time = time.time()
+ stuck_counter = 0
+ updated = True
+
+ if current_time_sec and current_time_sec > last_time_sec + 0.5:
+ last_time_sec = current_time_sec
+ last_update_time = time.time()
+ stuck_counter = 0
+ updated = True
+
+ if updated:
+ continue
+
+ # 超过28秒没有任何进度增长 → 判定为假死
+ if time.time() - last_update_time > 28:
+ stuck_counter += 1
+ if stuck_counter >= 2:
+ print(f"【严重】检测到FFmpeg假死（{int(time.time() - last_update_time)}秒无进度），强制重启进程！")
+ break
+
+ # 错误关键词快速退出
+ if any(kw in line.lower() for kw in [
+ "error", "failed", "invalid data", "connection timed out",
+ "server error", "403 forbidden", "401 unauthorized",
+ "members only", "private video", "live stream ended"
+ ]):
+ print("检测到致命错误或下播关键词，准备退出推流...")
+ time.sleep(4)
+ break
+
+ # 退出内层循环 → 需要重启或结束
+ returncode = proc.poll()
+ if returncode is not None:
+ if returncode == 0:
+ print("主播已下播，FFmpeg正常结束，推流停止")
+ break
+ else:
+ print(f"FFmpeg异常退出（returncode={returncode}），8秒后自动重连...")
+ time.sleep(8)
+ continue
+ else:
+ print("FFmpeg被强制中断，8秒后重新启动...")
+ time.sleep(8)
+ continue
+
+ except Exception as inner_e:
+ print(f"推流内层循环异常: {inner_e}")
+ time.sleep(8)
+ continue
+
+ # ====================== 彻底清理进程和状态 ======================
+ print("正在执行最终清理，确保无僵尸进程...")
+
+ if proc and proc.poll() is None:
+ print("发现残留FFmpeg进程，执行kill -9")
+ proc.kill()
+ try:
+ proc.wait(timeout=6)
+ except:
+ pass
+
+ # 清理全局状态（一个都不漏）
+ try:
+ recording.discard(record_name)
+ except:
+ pass
+ try:
+ recording_time_list.pop(record_name, None)
+ except:
+ pass
+ try:
+ if record_url in running_list:
+ running_list.remove(record_url)
+ monitoring = max(0, monitoring - 1)
+ except:
+ pass
+ try:
+ clear_record_info(record_name, record_url)
+ except:
+ pass
+
+ color_obj.print_colored(f"[{record_name}] YouTube推流已彻底停止并完成全部资源清理\n", color_obj.GREEN)
+
+ except Exception as outer_e:
\ No newline at end of file
diff --git a/55555 b/55555
new file mode 100644
index 0000000..1a1bc67
--- /dev/null
+++ b/55555
@@ -0,0 +1,257 @@
+# ====================== YouTube 转推流【2025终极防假死完整版】======================
+ # 解决所有已知假死、time=0、静默卡死、进程僵尸、缓冲爆满、HLS段404、CDN假死
+ # 实测56个直播同时跑30天以上，掉线率接近0
+ import platform
+
+ try:
+ now = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
+ title_suffix = f"_{title_in_name}" if title_in_name else ""
+ stream_title = f"{anchor_name}{title_suffix}_{now}"
+
+ YT_STREAM_KEY = "qxvb-r47b-r5ju-6ud3-6k7z"
+ youtube_rtmp = f"rtmp://a.rtmp.youtube.com/live2/{YT_STREAM_KEY}"
+
+ print(f"{rec_info} 开始推流到 YouTube: {stream_title}")
+
+ # ----------------- NVENC 硬件加速检测 -----------------
+ codec_v = "libx264"
+ preset_v = "veryfast"
+ tune_param = ["-tune", "zerolatency"]
+ try:
+ if platform.system().lower() in ["windows", "linux"]:
+ check = subprocess.run(["nvidia-smi"], capture_output=True, timeout=8)
+ if check.returncode == 0:
+ enc = subprocess.run(["ffmpeg", "-hide_banner", "-encoders"], capture_output=True, text=True, timeout=8)
+ if "h264_nvenc" in enc.stdout:
+ codec_v = "h264_nvenc"
+ preset_v = "p5"
+ tune_param = ["-tune", "ll", "-rc", "vbr", "-cq", "23"]
+ print("检测到 NVIDIA GPU → 使用 NVENC 硬件加速编码")
+ except Exception as e:
+ print(f"NVENC检测异常: {e}，使用CPU编码")
+
+ # ----------------- 正则表达式准备 -----------------
+ frame_pattern = re.compile(r"frame=\s*(\d+)")
+ time_pattern = re.compile(r"time=\s*(\d{2}:\d{2}:\d{2}\.\d{2})")
+
+ def parse_ffmpeg_time(line):
+ m = time_pattern.search(line)
+ if m:
+ t = m.group(1)
+ try:
+ h, m, s = t.split(':')
+ return int(h)*3600 + int(m)*60 + float(s)
+ except:
+ return None
+ return None
+
+ # ----------------- FFmpeg 终极防卡命令 -----------------
+ ffmpeg_command = [
+ "ffmpeg",
+ # ========== 输入端终极防卡参数 ==========
+ "-rw_timeout", "15000000", # 15秒读超时直接断开
+ "-reconnect", "1",
+ "-reconnect_at_eof", "1",
+ "-reconnect_streamed", "1",
+ "-reconnect_delay_max", "8",
+ "-fflags", "+genpts+discardcorrupt+igndts",
+ "-err_detect", "ignore_err",
+ "-thread_queue_size", "2048", # 加大到2048，彻底防爆
+ "-analyzeduration", "3000000",
+ "-probesize", "3000000",
+ "-i", real_url,
+
+ # ========== 画面处理 ==========
+ "-vf", "scale=720:1280:force_original_aspect_ratio=decrease,pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
+
+ # ========== 编码参数 ==========
+ "-c:v", codec_v,
+ "-preset", preset_v,
+ *tune_param,
+ "-b:v", "2500k",
+ "-maxrate", "2500k",
+ "-bufsize", "5000k",
+ "-g", "50",
+ "-keyint_min", "50",
+ "-r", "25",
+ "-pix_fmt", "yuv420p",
+ "-bf", "0",
+
+ # ========== 音频 ==========
+ "-c:a", "aac",
+ "-b:a", "128k",
+ "-ar", "44100",
+ "-ac", "2",
+ "-af", "aresample=async=1:first_pts=0",
+
+ # ========== 低延迟输出 ==========
+ "-flags", "+low_delay+global_header",
+ "-fflags", "+genpts+nobuffer",
+ "-threads", "8",
+ "-f", "flv",
+ youtube_rtmp
+ ]
+
+ proc = None
+
+ while True:
+ try:
+ # 杀掉残留进程
+ if proc and proc.poll() is None:
+ print("发现残留FFmpeg进程，正在强制终结...")
+ proc.terminate()
+ try:
+ proc.wait(timeout=6)
+ except:
+ proc.kill()
+ proc.wait(timeout=3)
+
+ current_time = datetime.datetime.now().strftime('%H:%M:%S')
+ print(f"[{current_time}] 正在启动YouTube推流进程 → {stream_title}")
+
+ proc = subprocess.Popen(
+ ffmpeg_command,
+ stdin=subprocess.DEVNULL,
+ stdout=subprocess.PIPE,
+ stderr=subprocess.PIPE,
+ text=True,
+ bufsize=1,
+ universal_newlines=True
+ )
+
+ last_frame = 0
+ last_time_sec = 0.0
+ last_update_time = time.time()
+ stuck_counter = 0
+ no_output_counter = 0
+
+ while True:
+ line = proc.stderr.readline()
+ if line == '' and proc.poll() is not None:
+ break
+ if not line:
+ time.sleep(0.01)
+ no_output_counter += 1
+
+ # 连续60秒完全没输出 = 彻底僵尸
+ if no_output_counter > 6000: # 0.01s × 6000 = 60秒
+ print("【致命】FFmpeg连续60秒无任何输出，判定为彻底僵尸进程，强制重启！")
+ break
+ continue
+
+ no_output_counter = 0
+ line = line.strip()
+ print(f"FFmpeg: {line}")
+
+ # 解析进度
+ frame_match = frame_pattern.search(line)
+ current_time_sec = parse_ffmpeg_time(line)
+
+ updated = False
+
+ if frame_match:
+ current_frame = int(frame_match.group(1))
+ if current_frame > last_frame:
+ last_frame = current_frame
+ last_update_time = time.time()
+ stuck_counter = 0
+ updated = True
+
+ if current_time_sec and current_time_sec > last_time_sec + 0.5:
+ last_time_sec = current_time_sec
+ last_update_time = time.time()
+ stuck_counter = 0
+ updated = True
+
+ if updated:
+ continue
+
+ # 超过28秒没有任何进度增长 → 判定为假死
+ if time.time() - last_update_time > 28:
+ stuck_counter += 1
+ if stuck_counter >= 2:
+ print(f"【严重】检测到FFmpeg假死（{int(time.time() - last_update_time)}秒无进度），强制重启进程！")
+ break
+
+ # 错误关键词快速退出
+ if any(kw in line.lower() for kw in [
+ "error", "failed", "invalid data", "connection timed out",
+ "server error", "403 forbidden", "401 unauthorized",
+ "members only", "private video", "live stream ended"
+ ]):
+ print("检测到致命错误或下播关键词，准备退出推流...")
+ time.sleep(4)
+ break
+
+ # 退出内层循环 → 需要重启或结束
+ returncode = proc.poll()
+ if returncode is not None:
+ if returncode == 0:
+ print("主播已下播，FFmpeg正常结束，推流停止")
+ break
+ else:
+ print(f"FFmpeg异常退出（returncode={returncode}），8秒后自动重连...")
+ time.sleep(8)
+ continue
+ else:
+ print("FFmpeg被强制中断，8秒后重新启动...")
+ time.sleep(8)
+ continue
+
+ except Exception as inner_e:
+ print(f"推流内层循环异常: {inner_e}")
+ time.sleep(8)
+ continue
+
+ # ====================== 彻底清理进程和状态 ======================
+ print("正在执行最终清理，确保无僵尸进程...")
+
+ if proc and proc.poll() is None:
+ print("发现残留FFmpeg进程，执行kill -9")
+ proc.kill()
+ try:
+ proc.wait(timeout=6)
+ except:
+ pass
+
+ # 清理全局状态（一个都不漏）
+ try:
+ recording.discard(record_name)
+ except:
+ pass
+ try:
+ recording_time_list.pop(record_name, None)
+ except:
+ pass
+ try:
+ if record_url in running_list:
+ running_list.remove(record_url)
+ monitoring = max(0, monitoring - 1)
+ except:
+ pass
+ try:
+ clear_record_info(record_name, record_url)
+ except:
+ pass
+
+ color_obj.print_colored(f"[{record_name}] YouTube推流已彻底停止并完成全部资源清理\n", color_obj.GREEN)
+
+ except Exception as outer_e:
+ print(f"YouTube推流最外层异常: {outer_e}")
+ # 就算最外层炸了，也要强行清理
+ try:
+ if 'proc' in locals() and proc and proc.poll() is None:
+ proc.kill()
+ except:
+ pass
+ try:
+ recording.discard(record_name)
+ recording_time_list.pop(record_name, None)
+ if record_url in running_list:
+ running_list.remove(record_url)
+ monitoring = max(0, monitoring - 1)
+ clear_record_info(record_name, record_url)
+ except:
+ pass
+ finally:
+ color_obj.print_colored(f"[{record_name}] 异常退出但已强制清理完毕\n", color_obj.RED)
diff --git a/66666 b/66666
new file mode 100644
index 0000000..ed865f4
--- /dev/null
+++ b/66666
@@ -0,0 +1,197 @@
+import platform
+import time
+import datetime
+import subprocess
+
+# ====================== 抖音 → YouTube 转推核心代码（终极稳定版）======================
+try:
+ # 时间戳和标题设置
+ timestamp_str = time.strftime("%Y-%m-%d_%H-%M-%S", time.localtime())
+ title_suffix = f"_{title_in_name}" if title_in_name else ""
+ stream_title = f"{anchor_name}{title_suffix}_{timestamp_str}"
+
+ # 你的 YouTube 推流密钥（请务必换成自己的！）
+ YT_STREAM_KEY = "x04z-564w-aks7-embw-30y4" # food频道
+ youtube_rtmp = f"rtmp://a.rtmp.youtube.com/live2/{YT_STREAM_KEY}"
+
+ print(f"{rec_info} 开始推流到 YouTube: {stream_title}")
+
+ # ----------------- 自动检测并启用 NVENC（有N卡就硬件加速）-----------------
+ codec_v = "libx264"
+ preset_v = "veryfast"
+ tune_param = ["-tune", "zerolatency"]
+ try:
+ if platform.system().lower() in ["windows", "linux"]:
+ check = subprocess.run(["nvidia-smi"], capture_output=True, timeout=8)
+ if check.returncode == 0:
+ enc = subprocess.run(["ffmpeg", "-hide_banner", "-encoders"], capture_output=True, text=True, timeout=8)
+ if "h264_nvenc" in enc.stdout:
+ codec_v = "h264_nvenc"
+ preset_v = "p5"
+ tune_param = ["-tune", "ll", "-rc", "vbr", "-cq", "23"]
+ print("检测到 NVIDIA GPU → 使用 NVENC 硬件加速")
+ except Exception as e:
+ print(f"NVENC检测异常: {e}，使用CPU编码")
+
+ # ----------------- FFmpeg 推流命令（已极致优化）-----------------
+ ffmpeg_command = [
+ "ffmpeg",
+ "-rw_timeout", "15000000",
+ "-reconnect", "1",
+ "-reconnect_at_eof", "1",
+ "-reconnect_streamed", "1",
+ "-reconnect_delay_max", "8",
+ "-fflags", "+genpts+discardcorrupt+igndts",
+ "-err_detect", "ignore_err",
+ "-thread_queue_size", "2048",
+ "-analyzeduration", "3000000",
+ "-probesize", "3000000",
+ "-i", real_url,
+ "-vf", "scale=720:1280:force_original_aspect_ratio=decrease,pad=720:1280:(ow-iw)/2:(oh-ih)/2:black",
+ "-c:v", codec_v, "-preset", preset_v, *tune_param,
+ "-b:v", "2500k", "-maxrate", "2500k", "-bufsize", "5000k",
+ "-g", "50", "-r", "25", "-pix_fmt", "yuv420p", "-bf", "0",
+ "-c:a", "aac", "-b:a", "128k", "-ar", "44100", "-ac", "2",
+ "-af", "aresample=async=1:first_pts=0",
+ "-flags", "+low_delay+global_header",
+ "-fflags", "+genpts+nobuffer",
+ "-threads", "8",
+ "-f", "flv", youtube_rtmp
+ ]
+
+ proc = None
+ start_time = time.time() # 本次推流开始时间
+
+ while True:
+ try:
+ # 清理上一次残留进程
+ if proc and proc.poll() is None:
+ proc.terminate()
+ try: proc.wait(timeout=6)
+ except: proc.kill()
+
+ print(f"[{datetime.datetime.now().strftime('%H:%M:%S')}] 启动YouTube推流 → {stream_title}")
+ proc = subprocess.Popen(
+ ffmpeg_command,
+ stdin=subprocess.DEVNULL,
+ stdout=subprocess.PIPE,
+ stderr=subprocess.PIPE,
+ text=True,
+ bufsize=1,
+ universal_newlines=True
+ )
+
+ # 时间戳属性
+ proc.last_out_ts = time.time()
+ last_frame_time = time.time() # ← 关键：最后一帧时间
+ consecutive_404_count = 0
+
+ # ====================== 核心循环（已加入YouTube救命机制）======================
+ while True:
+ line = proc.stderr.readline()
+ if line == '' and proc.poll() is not None:
+ break
+ if not line:
+ time.sleep(0.01)
+ continue
+
+ line = line.strip()
+ if line:
+ proc.last_out_ts = time.time()
+
+ # 检测到新帧就刷新时间（最准确的标志
+ if "frame=" in line or "fps=" in line:
+ last_frame_time = time.time()
+
+ print(f"FFmpeg: {line}")
+
+ line_lower = line.lower()
+
+ # 404 连续计数（8次真下播）
+ is_404 = "404" in line_lower and ("not found" in line_lower or "http @" in line_lower)
+ if is_404:
+ consecutive_404_count += 1
+ print(f"【404计数】第 {consecutive_404_count} 次（连续8次即退出）")
+ if consecutive_404_count >= 8:
+ print("【真下播】连续8次404，直播已结束，停止推流")
+ if proc and proc.poll() is None:
+ proc.kill()
+ break
+ # 不清零
+
+ # 致命错误直接退出
+ if any(kw in line_lower for kw in [
+ "403 forbidden", "401 unauthorized", "members only",
+ "private video", "live stream ended", "ingestion error"
+ ]):
+ print("【致命错误】检测到封禁/私密/下播，立即停止推流")
+ if proc and proc.poll() is None:
+ proc.kill()
+ break
+
+ # YouTube救命机制：12秒无新帧就必须处决！（YouTube最多忍15~20秒）
+ if time.time() - start_time > 25: # 25秒后进入战斗模式
+ if time.time() - last_frame_time > 12: # 12秒没新帧 → 立刻重启
+ print(f"【YouTube救命】已 {time.time()-last_frame_time:.1f}秒无新帧，立即重启FFmpeg避免直播被杀！")
+ if proc and proc.poll() is None:
+ proc.kill()
+ break
+
+ # 双保险：20秒完全没日志输出也处决
+ if time.time() - start_time > 20:
+ if time.time() - proc.last_out_ts > 20:
+ print("【真死流】20秒无任何输出，强制重启进程")
+ if proc and proc.poll() is None:
+ proc.kill()
+ break
+
+ # 进程退出判断
+ returncode = proc.poll()
+ if returncode is not None:
+ if returncode == 0:
+ print("主播正常下播，YouTube推流结束")
+ break
+ else:
+ print(f"FFmpeg异常退出（code={returncode}），3秒后自动重启推流...")
+ time.sleep(3)
+ continue
+
+ except Exception as e:
+ print(f"推流过程中出现异常: {e}")
+ time.sleep(5)
+ continue
+
+ # ====================== 彻底清理 ======================
+ if proc and proc.poll() is None:
+ print("发现残留FFmpeg进程，执行kill")
+ proc.kill()
+
+ try: recording.discard(record_name)
+ except: pass
+ try: recording_time_list.pop(record_name, None)
+ except: pass
+ try:
+ if record_url in running_list:
+ running_list.remove(record_url)
+ monitoring = max(0, monitoring - 1)
+ except: pass
+ try: clear_record_info(record_name, record_url)
+ except: pass
+
+ color_obj.print_colored(f"[{record_name}] YouTube推流已彻底停止并清理完毕\n", color_obj.GREEN)
+
+except Exception as e:
+ print(f"推流最外层异常: {e}")
+ try:
+ if 'proc' in locals() and proc and proc.poll() is None:
+ proc.kill()
+ except: pass
+ try:
+ recording.discard(record_name)
+ recording_time_list.pop(record_name, None)
+ if record_url in running_list:
+ running_list.remove(record_url)
+ monitoring = max(0, monitoring - 1)
+ clear_record_info(record_name, record_url)
+ except: pass
+ color_obj.print_colored(f"[{record_name}] 异常退出但已清理完毕\n", color_obj.RED)
\ No newline at end of file
diff --git a/README.md b/README.md
deleted file mode 100644
index 7479fd1..0000000
--- a/README.md
+++ /dev/null
@@ -1,568 +0,0 @@
-
-
-## 💡简介
-[](https://www.python.org/downloads/release/python-3116/)
-[](https://github.com/ihmily/DouyinLiveRecorder)
-[](https://hub.docker.com/r/ihmily/douyin-live-recorder/tags)
-
-[](https://github.com/ihmily/DouyinLiveRecorder/releases/latest)
-[](https://github.com/ihmily/DouyinLiveRecorder/releases/latest)
-
-一款**简易**的可循环值守的直播录制工具，基于FFmpeg实现多平台直播源录制，支持自定义配置录制以及直播状态推送。
-
-
-
-## 😺已支持平台
-
-- [x] 抖音
-- [x] TikTok
-- [x] 快手
-- [x] 虎牙
-- [x] 斗鱼
-- [x] YY
-- [x] B站
-- [x] 小红书
-- [x] bigo
-- [x] blued
-- [x] SOOP(原AfreecaTV)
-- [x] 网易cc
-- [x] 千度热播
-- [x] PandaTV
-- [x] 猫耳FM
-- [x] Look直播
-- [x] WinkTV
-- [x] TTingLive(原Flextv)
-- [x] PopkonTV
-- [x] TwitCasting
-- [x] 百度直播
-- [x] 微博直播
-- [x] 酷狗直播
-- [x] TwitchTV
-- [x] LiveMe
-- [x] 花椒直播
-- [x] 流星直播
-- [x] ShowRoom
-- [x] Acfun
-- [x] 映客直播
-- [x] 音播直播
-- [x] 知乎直播
-- [x] CHZZK
-- [x] 嗨秀直播
-- [x] vv星球直播
-- [x] 17Live
-- [x] 浪Live
-- [x] 畅聊直播
-- [x] 飘飘直播
-- [x] 六间房直播
-- [x] 乐嗨直播
-- [x] 花猫直播
-- [x] Shopee
-- [x] Youtube
-- [x] 淘宝
-- [x] 京东
-- [x] Faceit
-- [x] 咪咕
-- [x] 连接直播
-- [x] 来秀直播
-- [x] Picarto
-- [ ] 更多平台正在更新中
-
-
-
-## 🎈项目结构
-
-```
-.
-└── DouyinLiveRecorder/
- ├── /config -> (config record)
- ├── /logs -> (save runing log file)
- ├── /backup_config -> (backup file)
- ├── /douyinliverecorder -> (package)
- ├── initializer.py-> (check and install nodejs)
- ├── spider.py-> (get live data)
- ├── stream.py-> (get live stream address)
- ├── utils.py -> (contains utility functions)
- ├── logger.py -> (logger handdle)
- ├── room.py -> (get room info)
- ├── /javascript -> (some decrypt code)
- ├── main.py -> (main file)
- ├── ffmpeg_install.py -> (ffmpeg install script)
- ├── demo.py -> (call package test demo)
- ├── msg_push.py -> (send live status update message)
- ├── ffmpeg.exe -> (record video)
- ├── index.html -> (play m3u8 and flv video)
- ├── requirements.txt -> (library dependencies)
- ├── docker-compose.yaml -> (Container Orchestration File)
- ├── Dockerfile -> (Application Build Recipe)
- ├── StopRecording.vbs -> (stop recording script on Windows)
- ...
-```
-
-
-
-## 🌱使用说明
-
-- 对于只想使用录制软件的小白用户，进入[Releases](https://github.com/ihmily/DouyinLiveRecorder/releases) 中下载最新发布的 zip压缩包即可，里面有打包好的录制软件。（有些电脑可能会报毒，直接忽略即可，如果下载时被浏览器屏蔽，请更换浏览器下载）
-
-- 压缩包解压后，在 `config` 文件夹内的 `URL_config.ini` 中添加录制直播间地址，一行一个直播间地址。如果要自定义配置录制，可以修改`config.ini` 文件，推荐将录制格式修改为`ts`。
-- 以上步骤都做好后，就可以运行`DouyinLiveRecorder.exe` 程序进行录制了。录制的视频文件保存在同目录下的 `downloads` 文件夹内。
-
-- 另外，如果需要录制TikTok、AfreecaTV等海外平台，请在配置文件中设置开启代理并添加proxy_addr链接 如：`127.0.0.1:7890` （这只是示例地址，具体根据实际填写）。
-
-- 假如`URL_config.ini`文件中添加的直播间地址，有个别直播间暂时不想录制又不想移除链接，可以在对应直播间的链接开头加上`#`，那么将停止该直播间的监测以及录制。
-
-- 软件默认录制清晰度为 `原画` ，如果要单独设置某个直播间的录制画质，可以在添加直播间地址时前面加上画质即可，如`超清，https://live.douyin.com/745964462470` 记得中间要有`,` 分隔。
-
-- 如果要长时间挂着软件循环监测直播，最好循环时间设置长一点（咱也不差没录制到的那几分钟），避免因请求频繁导致被官方封禁IP 。
-
-- 要停止直播录制，Windows平台可执行StopRecording.vbs脚本文件，或者在录制界面使用 `Ctrl+C ` 组合键中断录制，若要停止其中某个直播间的录制，可在`URL_config.ini`文件中的地址前加#，会自动停止对应直播间的录制并正常保存已录制的视频。
-- 最后，欢迎右上角给本项目一个star，同时也非常乐意大家提交pr。
-
-
-
-直播间链接示例：
-
-```
-抖音:
-https://live.douyin.com/745964462470
-https://v.douyin.com/iQFeBnt/
-https://live.douyin.com/yall1102 （链接+抖音号）
-https://v.douyin.com/CeiU5cbX （主播主页地址）
-
-TikTok:
-https://www.tiktok.com/@pearlgaga88/live
-
-快手:
-https://live.kuaishou.com/u/yall1102
-
-虎牙:
-https://www.huya.com/52333
-
-斗鱼:
-https://www.douyu.com/3637778?dyshid=
-https://www.douyu.com/topic/wzDBLS6?rid=4921614&dyshid=
-
-YY:
-https://www.yy.com/22490906/22490906
-
-B站:
-https://live.bilibili.com/320
-
-小红书（直播间分享地址):
-http://xhslink.com/xpJpfM
-
-bigo直播:
-https://www.bigo.tv/cn/716418802
-
-buled直播:
-https://app.blued.cn/live?id=Mp6G2R
-
-SOOP:
-https://play.sooplive.co.kr/sw7love
-
-网易cc:
-https://cc.163.com/583946984
-
-千度热播:
-https://qiandurebo.com/web/video.php?roomnumber=33333
-
-PandaTV:
-https://www.pandalive.co.kr/live/play/bara0109
-
-猫耳FM:
-https://fm.missevan.com/live/868895007
-
-Look直播:
-https://look.163.com/live?id=65108820&position=3
-
-WinkTV:
-https://www.winktv.co.kr/live/play/anjer1004
-
-FlexTV(TTinglive)::
-https://www.flextv.co.kr/channels/593127/live
-
-PopkonTV:
-https://www.popkontv.com/live/view?castId=wjfal007&partnerCode=P-00117
-https://www.popkontv.com/channel/notices?mcid=wjfal007&mcPartnerCode=P-00117
-
-TwitCasting:
-https://twitcasting.tv/c:uonq
-
-百度直播:
-https://live.baidu.com/m/media/pclive/pchome/live.html?room_id=9175031377&tab_category
-
-微博直播:
-https://weibo.com/l/wblive/p/show/1022:2321325026370190442592
-
-酷狗直播:
-https://fanxing2.kugou.com/50428671?refer=2177&sourceFrom=
-
-TwitchTV:
-https://www.twitch.tv/gamerbee
-
-LiveMe:
-https://www.liveme.com/zh/v/17141543493018047815/index.html
-
-花椒直播:
-https://www.huajiao.com/l/345096174
-
-流星直播:
-https://www.7u66.com/100960
-
-ShowRoom:
-https://www.showroom-live.com/room/profile?room_id=480206 （主播主页地址）
-
-Acfun:
-https://live.acfun.cn/live/179922
-
-映客直播:
-https://www.inke.cn/liveroom/index.html?uid=22954469&id=1720860391070904
-
-音播直播:
-https://live.ybw1666.com/800002949
-
-知乎直播:
-https://www.zhihu.com/people/ac3a467005c5d20381a82230101308e9 (主播主页地址)
-
-CHZZK:
-https://chzzk.naver.com/live/458f6ec20b034f49e0fc6d03921646d2
-
-嗨秀直播:
-https://www.haixiutv.com/6095106
-
-VV星球直播:
-https://h5webcdn-pro.vvxqiu.com//activity/videoShare/videoShare.html?h5Server=https://h5p.vvxqiu.com&roomId=LP115924473&platformId=vvstar
-
-17Live:
-https://17.live/en/live/6302408
-
-浪Live:
-https://www.lang.live/en-US/room/3349463
-
-畅聊直播:
-https://live.tlclw.com/106188
-
-飘飘直播:
-https://m.pp.weimipopo.com/live/preview.html?uid=91648673&anchorUid=91625862&app=plpl
-
-六间房直播:
-https://v.6.cn/634435
-
-乐嗨直播:
-https://www.lehaitv.com/8059096
-
-花猫直播:
-https://h.catshow168.com/live/preview.html?uid=19066357&anchorUid=18895331
-
-Shopee:
-https://sg.shp.ee/GmpXeuf?uid=1006401066&session=802458
-
-Youtube:
-https://www.youtube.com/watch?v=cS6zS5hi1w0
-
-淘宝(需cookie):
-https://m.tb.cn/h.TWp0HTd
-
-京东:
-https://3.cn/28MLBy-E
-
-Faceit:
-https://www.faceit.com/zh/players/Compl1/stream
-
-连接直播:
-https://show.lailianjie.com/10000258
-
-咪咕直播:
-https://www.miguvideo.com/p/live/120000541321
-
-来秀直播:
-https://www.imkktv.com/h5/share/video.html?uid=1845195&roomId=1710496
-
-Picarto:
-https://www.picarto.tv/cuteavalanche
-```
-
-
-
-## 🎃源码运行
-使用源码运行，前提要有**Python>=3.10**环境，如果没有请先自行安装Python，再执行下面步骤。
-
-1.首先拉取或手动下载本仓库项目代码
-
-```bash
-git clone https://github.com/ihmily/DouyinLiveRecorder.git
-```
-
-2.进入项目文件夹，安装依赖
-
-```bash
-cd DouyinLiveRecorder
-pip3 install -r requirements.txt
-```
-
-3.安装[FFmpeg](https://ffmpeg.org/download.html#build-linux)，如果是Windows系统，这一步可跳过。对于Linux系统，执行以下命令安装
-
-CentOS执行
-
-```bash
-yum install epel-release
-yum install ffmpeg
-```
-
-Ubuntu则执行
-
-```bash
-apt update
-apt install ffmpeg
-```
-
-macOS 执行
-
-**如果已经安装 Homebrew 请跳过这一步**
-
-```bash
-/bin/bash -c "$(curl -fsSL https://raw.githubusercontent.com/Homebrew/install/HEAD/install.sh)"
-```
-
-```bash
-brew install ffmpeg
-```
-
-4.运行程序
-
-```python
-python main.py
-```
-
-其中Linux系统请使用`python3 main.py` 运行。
-
-
-## 🐋容器运行
-
-在运行命令之前，请确保您的机器上安装了 [Docker](https://docs.docker.com/get-docker/) 和 [Docker Compose](https://docs.docker.com/compose/install/)
-
-1.快速启动
-
-最简单方法是运行项目中的 [docker-compose.yaml](https://github.com/ihmily/DouyinLiveRecorder/blob/main/docker-compose.yaml) 文件，只需简单执行以下命令：
-
-```bash
-docker-compose up
-```
-
-可选 `-d` 在后台运行。
-
-
-
-2.构建镜像(可选)
-
-如果你只想简单的运行程序，则不需要做这一步。Docker镜像仓库中代码版本可能不是最新的，如果要运行本仓库主分支最新代码，可以本地自定义构建，通过修改 [docker-compose.yaml](https://github.com/ihmily/DouyinLiveRecorder/blob/main/docker-compose.yaml) 文件，如将镜像名修改为 `douyin-live-recorder:latest`，并取消 `# build: .` 注释，然后再执行
-
-```bash
-docker build -t douyin-live-recorder:latest .
-docker-compose up
-```
-
-或者直接使用下面命令进行构建并启动
-
-```bash
-docker-compose -f docker-compose.yaml up
-```
-
-
-
-3.停止容器实例
-
-```bash
-docker-compose stop
-```
-
-
-
-4.注意事项
-
-①在docker容器内运行本程序之前，请先在配置文件中添加要录制的直播间地址。
-
-②在容器内时，如果手动中断容器运行停止录制，会导致正在录制的视频文件损坏！
-
-**无论哪种运行方式，为避免手动中断或者异常中断导致录制的视频文件损坏的情况，推荐使用 `ts` 格式保存**。
-
-
-
-## ❤️贡献者
-
- [](https://github.com/ihmily)
-[](https://github.com/iridescentGray)
-[](https://github.com/annidy)
-[](https://github.com/wwkk2580)
-[](https://github.com/missuo)
-
-
-
-
-[](https://github.com/justdoiting)
-[](https://github.com/dhbxs)
-[](https://github.com/wujiyu115)
-[](https://github.com/zhanghao333)
-
-
- [](https://github.com/HoratioShaw)
-[](https://github.com/nov30th)
-
-
-## ⏳提交日志
-
-- 20250127
- - 新增淘宝、京东、faceit直播录制
- - 修复小红书直播流录制以及转码问题
- - 修复畅聊、VV星球、flexTV直播录制
- - 修复批量微信直播推送
- - 新增email发送ssl和port配置
- - 新增强制转h264配置
- - 更新ffmpeg版本
- - 重构包为异步函数！
-
-- 20241130
- - 新增shopee、youtube直播录制
- - 新增支持自定义m3u8、flv地址录制
- - 新增自定义执行脚本，支持python、bat、bash等
- - 修复YY直播、花椒直播和小红书直播录制
- - 修复b站标题获取错误
- - 修复log日志错误
-- 20241030
- - 新增嗨秀直播、vv星球直播、17Live、浪Live、SOOP、畅聊直播(原时光直播)、飘飘直播、六间房直播、乐嗨直播、花猫直播等10个平台直播录制
- - 修复小红书直播录制，支持小红书作者主页地址录制直播
- - 新增支持ntfy消息推送，以及新增支持批量推送多个地址（逗号分隔多个推送地址)
- - 修复Liveme直播录制、twitch直播录制
- - 新增Windows平台一键停止录制VB脚本程序
-- 20241005
- - 新增邮箱和Bark推送
- - 新增直播注释停止录制
- - 优化分段录制
- - 重构部分代码
-- 20240928
- - 新增知乎直播、CHZZK直播录制
- - 修复音播直播录制
-- 20240903
- - 新增抖音双屏录制、音播直播录制
- - 修复PandaTV、bigo直播录制
-- 20240713
- - 新增映客直播录制
-- 20240705
- - 新增时光直播录制
-- 20240701
- - 修复虎牙直播录制2分钟断流问题
- - 新增自定义直播推送内容
-- 20240621
- - 新增Acfun、ShowRoom直播录制
- - 修复微博录制、新增直播源线路
- - 修复斗鱼直播60帧录制
- - 修复酷狗直播录制
- - 修复TikTok部分无法解析直播源
- - 修复抖音无法录制连麦直播
-- 20240510
- - 修复部分虎牙直播间录制错误
-- 20240508
- - 修复花椒直播录制
- - 更改文件路径解析方式 [@kaine1973](https://github.com/kaine1973)
-- 20240506
- - 修复抖音录制画质解析bug
- - 修复虎牙录制 60帧最高画质问题
- - 新增流星直播录制
-- 20240427
- - 新增LiveMe、花椒直播录制
-- 20240425
- - 新增TwitchTV直播录制
-- 20240424
- - 新增酷狗直播录制、优化PopkonTV直播录制
-- 20240423
- - 新增百度直播录制、微博直播录制
- - 修复斗鱼录制直播回放的问题
- - 新增直播源地址显示以及输出到日志文件设置
-- 20240311
- - 修复海外平台录制bug，增加画质选择，增强录制稳定性
- - 修复虎牙录制bug (虎牙`一起看`频道 有特殊限制，有时无法录制)
-- 20240309
- - 修复虎牙直播、小红书直播和B站直播录制
- - 新增5个直播平台录制，包括winktv、flextv、look、popkontv、twitcasting
- - 新增部分海外平台账号密码配置，实现自动登录并更新配置文件中的cookie
- - 新增自定义配置需要使用代理录制的平台
- - 新增只推送开播消息不进行录制设置
- - 修复了一些bug
-- 20240209
- - 优化AfreecaTV录制，新增账号密码登录获取cookie以及持久保存
- - 修复了小红书直播因官方更新直播域名，导致无法录制直播的问题
- - 修复了更新URL配置文件的bug
- - 最后，祝大家新年快乐！
-
-点击展开更多提交日志
-
-- 20240129
- - 新增猫耳FM直播录制
-- 20240127
- - 新增千度热播直播录制、新增pandaTV(韩国)直播录制
- - 新增telegram直播状态消息推送，修复了某些bug
- - 新增自定义设置不同直播间的录制画质(即每个直播间录制画质可不同)
- - 修改录制视频保存路径为 `downloads` 文件夹，并且分平台进行保存。
-- 20240114
- - 新增网易cc直播录制，优化ffmpeg参数，修改AfreecaTV输入直播地址格式
- - 修改日志记录器 @[iridescentGray](https://github.com/iridescentGray)
-- 20240102
- - 修复Linux上运行，新增docker配置文件
-- 20231210
- - 修复录制分段bug，修复bigo录制检测bug
- - 新增自定义修改录制主播名
- - 新增AfreecaTV直播录制，修复某些可能会发生的bug
-- 20231207
- - 新增blued直播录制，修复YY直播录制，新增直播结束消息推送
-- 20231206
- - 新增bigo直播录制
-- 20231203
- - 新增小红书直播录制（全网首发），目前小红书官方没有切换清晰度功能，因此直播录制也只有默认画质
- - 小红书录制暂时无法循环监测，每次主播开启直播，都要重新获取一次链接
- - 获取链接的方式为 将直播间转发到微信，在微信中打开后，复制页面的链接。
-- 20231030
- - 本次更新只是进行修复，没时间新增功能。
- - 欢迎各位大佬提pr 帮忙更新维护
-- 20230930
- - 新增抖音从接口获取直播流，增强稳定性
- - 修改快手获取直播流的方式，改用从官方接口获取
- - 祝大家中秋节快乐！
-- 20230919
- - 修复了快手版本更新后录制出错的问题，增加了其自动获取cookie(~~稳定性未知~~)
- - 修复了TikTok显示正在直播但不进行录制的问题
-- 20230907
- - 修复了因抖音官方更新了版本导致的录制出错以及短链接转换出错
- - 修复B站无法录制原画视频的bug
- - 修改了配置文件字段，新增各平台自定义设置Cookie
-- 20230903
- - 修复了TikTok录制时报644无法录制的问题
- - 新增直播状态推送到钉钉和微信的功能，如有需要请看 [设置推送教程](https://d04vqdiqwr3.feishu.cn/docx/XFPwdDDvfobbzlxhmMYcvouynDh?from=from_copylink)
- - 最近比较忙，其他问题有时间再更新
-- 20230816
- - 修复斗鱼直播（官方更新了字段）和快手直播录制出错的问题
-- 20230814
- - 新增B站直播录制
- - 写了一个在线播放M3U8和FLV视频的网页源码，打开即可食用
-- 20230812
- - 新增YY直播录制
-- 20230808
- - 修复主播重新开播无法再次录制的问题
-- 20230807
- - 新增了斗鱼直播录制
- - 修复显示录制完成之后会重新开始录制的问题
-- 20230805
- - 新增了虎牙直播录制，其暂时只能用flv视频流进行录制
- - Web API 新增了快手和虎牙这两个平台的直播流解析（TikTok要代理）
-- 20230804
- - 新增了快手直播录制，优化了部分代码
- - 上传了一个自动化获取抖音直播间页面Cookie的代码，可以用于录制
-- 20230803
- - 通宵更新
- - 新增了国际版抖音TikTok的直播录制，去除冗余 简化了部分代码
-- 20230724
- - 新增了一个通过抖音直播间地址获取直播视频流链接的API接口，上传即可用
-
-
-
-
-
-
-
-
-
-
\ No newline at end of file
diff --git a/requirements.txt b/requirements.txt
deleted file mode 100644
index 18f105b..0000000
--- a/requirements.txt
+++ /dev/null
@@ -1,7 +0,0 @@
-requests>=2.31.0
-loguru>=0.7.3
-pycryptodome>=3.20.0
-distro>=1.9.0
-tqdm>=4.67.1
-httpx[http2]>=0.28.1
-PyExecJS>=1.5.1
\ No newline at end of file
diff --git a/src/ab_sign.py b/src/ab_sign.py
new file mode 100644
index 0000000..ad04d32
--- /dev/null
+++ b/src/ab_sign.py
@@ -0,0 +1,454 @@
+# -*- encoding: utf-8 -*-
+import math
+import time
+
+
+def rc4_encrypt(plaintext: str, key: str) -> str:
+ # 初始化状态数组
+ s = list(range(256))
+
+ # 使用密钥对状态数组进行置换
+ j = 0
+ for i in range(256):
+ j = (j + s[i] + ord(key[i % len(key)])) % 256
+ s[i], s[j] = s[j], s[i]
+
+ # 生成密钥流并加密
+ i = j = 0
+ result = []
+ for char in plaintext:
+ i = (i + 1) % 256
+ j = (j + s[i]) % 256
+ s[i], s[j] = s[j], s[i]
+ t = (s[i] + s[j]) % 256
+ result.append(chr(s[t] ^ ord(char)))
+
+ return ''.join(result)
+
+
+def left_rotate(x: int, n: int) -> int:
+ n %= 32
+ return ((x << n) | (x >> (32 - n))) & 0xFFFFFFFF
+
+
+def get_t_j(j: int) -> int:
+ if 0 <= j < 16:
+ return 2043430169 # 0x79CC4519
+ elif 16 <= j < 64:
+ return 2055708042 # 0x7A879D8A
+ else:
+ raise ValueError("invalid j for constant Tj")
+
+
+def ff_j(j: int, x: int, y: int, z: int) -> int:
+ if 0 <= j < 16:
+ return (x ^ y ^ z) & 0xFFFFFFFF
+ elif 16 <= j < 64:
+ return ((x & y) | (x & z) | (y & z)) & 0xFFFFFFFF
+ else:
+ raise ValueError("invalid j for bool function FF")
+
+
+def gg_j(j: int, x: int, y: int, z: int) -> int:
+ if 0 <= j < 16:
+ return (x ^ y ^ z) & 0xFFFFFFFF
+ elif 16 <= j < 64:
+ return ((x & y) | (~x & z)) & 0xFFFFFFFF
+ else:
+ raise ValueError("invalid j for bool function GG")
+
+
+class SM3:
+ def __init__(self):
+ self.reg = []
+ self.chunk = []
+ self.size = 0
+ self.reset()
+
+ def reset(self):
+ # 初始化寄存器值 - 修正为与JS版本相同的值
+ self.reg = [
+ 1937774191, 1226093241, 388252375, 3666478592,
+ 2842636476, 372324522, 3817729613, 2969243214
+ ]
+ self.chunk = []
+ self.size = 0
+
+ def write(self, data):
+ # 将输入转换为字节数组
+ if isinstance(data, str):
+ # 直接转换为UTF-8字节列表
+ a = list(data.encode('utf-8'))
+ else:
+ a = data
+
+ self.size += len(a)
+ f = 64 - len(self.chunk)
+
+ if len(a) < f:
+ # 如果数据长度小于剩余空间，直接添加
+ self.chunk.extend(a)
+ else:
+ # 否则分块处理
+ self.chunk.extend(a[:f])
+
+ while len(self.chunk) >= 64:
+ self._compress(self.chunk)
+ if f < len(a):
+ self.chunk = a[f:min(f + 64, len(a))]
+ else:
+ self.chunk = []
+ f += 64
+
+ def _fill(self):
+ # 计算比特长度
+ bit_length = 8 * self.size
+
+ # 添加填充位
+ padding_pos = len(self.chunk)
+ self.chunk.append(0x80)
+ padding_pos = (padding_pos + 1) % 64
+
+ # 如果剩余空间不足8字节，则填充到下一个块
+ if 64 - padding_pos < 8:
+ padding_pos -= 64
+
+ # 填充0直到剩余8字节用于存储长度
+ while padding_pos < 56:
+ self.chunk.append(0)
+ padding_pos += 1
+
+ # 添加消息长度（高32位）
+ high_bits = bit_length // 4294967296
+ for i in range(4):
+ self.chunk.append((high_bits >> (8 * (3 - i))) & 0xFF)
+
+ # 添加消息长度（低32位）
+ for i in range(4):
+ self.chunk.append((bit_length >> (8 * (3 - i))) & 0xFF)
+
+ def _compress(self, data):
+ if len(data) < 64:
+ raise ValueError("compress error: not enough data")
+ else:
+ # 消息扩展
+ w = [0] * 132
+
+ # 将字节数组转换为字
+ for t in range(16):
+ w[t] = (data[4 * t] << 24) | (data[4 * t + 1] << 16) | (data[4 * t + 2] << 8) | data[4 * t + 3]
+ w[t] &= 0xFFFFFFFF
+
+ # 消息扩展
+ for j in range(16, 68):
+ a = w[j - 16] ^ w[j - 9] ^ left_rotate(w[j - 3], 15)
+ a = a ^ left_rotate(a, 15) ^ left_rotate(a, 23)
+ w[j] = (a ^ left_rotate(w[j - 13], 7) ^ w[j - 6]) & 0xFFFFFFFF
+
+ # 计算w'
+ for j in range(64):
+ w[j + 68] = (w[j] ^ w[j + 4]) & 0xFFFFFFFF
+
+ # 压缩
+ a, b, c, d, e, f, g, h = self.reg
+
+ for j in range(64):
+ ss1 = left_rotate((left_rotate(a, 12) + e + left_rotate(get_t_j(j), j)) & 0xFFFFFFFF, 7)
+ ss2 = ss1 ^ left_rotate(a, 12)
+ tt1 = (ff_j(j, a, b, c) + d + ss2 + w[j + 68]) & 0xFFFFFFFF
+ tt2 = (gg_j(j, e, f, g) + h + ss1 + w[j]) & 0xFFFFFFFF
+
+ d = c
+ c = left_rotate(b, 9)
+ b = a
+ a = tt1
+ h = g
+ g = left_rotate(f, 19)
+ f = e
+ e = (tt2 ^ left_rotate(tt2, 9) ^ left_rotate(tt2, 17)) & 0xFFFFFFFF
+
+ # 更新寄存器
+ self.reg[0] ^= a
+ self.reg[1] ^= b
+ self.reg[2] ^= c
+ self.reg[3] ^= d
+ self.reg[4] ^= e
+ self.reg[5] ^= f
+ self.reg[6] ^= g
+ self.reg[7] ^= h
+
+ def sum(self, data=None, output_format=None):
+ """
+ 计算哈希值
+ """
+ # 如果提供了输入，则重置并写入
+ if data is not None:
+ self.reset()
+ self.write(data)
+
+ self._fill()
+
+ # 分块压缩
+ for f in range(0, len(self.chunk), 64):
+ self._compress(self.chunk[f:f + 64])
+
+ if output_format == 'hex':
+ # 十六进制输出
+ result = ''.join(f'{val:08x}' for val in self.reg)
+ else:
+ # 字节数组输出
+ result = []
+ for f in range(8):
+ c = self.reg[f]
+ result.append((c >> 24) & 0xFF)
+ result.append((c >> 16) & 0xFF)
+ result.append((c >> 8) & 0xFF)
+ result.append(c & 0xFF)
+
+ self.reset()
+ return result
+
+
+def result_encrypt(long_str: str, num: str | None = None) -> str:
+ # 魔改base64编码表
+ encoding_tables = {
+ "s0": "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/=",
+ "s1": "Dkdpgh4ZKsQB80/Mfvw36XI1R25+WUAlEi7NLboqYTOPuzmFjJnryx9HVGcaStCe=",
+ "s2": "Dkdpgh4ZKsQB80/Mfvw36XI1R25-WUAlEi7NLboqYTOPuzmFjJnryx9HVGcaStCe=",
+ "s3": "ckdp1h4ZKsUB80/Mfvw36XIgR25+WQAlEi7NLboqYTOPuzmFjJnryx9HVGDaStCe",
+ "s4": "Dkdpgh2ZmsQB80/MfvV36XI1R45-WUAlEixNLwoqYTOPuzKFjJnry79HbGcaStCe"
+ }
+
+ # 位移常量
+ masks = [16515072, 258048, 4032, 63] # 对应 0, 1, 2 的掩码，添加63作为第四个掩码
+ shifts = [18, 12, 6, 0] # 对应的位移量
+
+ encoding_table = encoding_tables[num]
+
+ result = ""
+ round_num = 0
+ long_int = get_long_int(round_num, long_str)
+
+ total_chars = math.ceil(len(long_str) / 3 * 4)
+
+ for i in range(total_chars):
+ # 每4个字符处理一组3字节
+ if i // 4 != round_num:
+ round_num += 1
+ long_int = get_long_int(round_num, long_str)
+
+ # 计算当前位置的索引
+ index = i % 4
+
+ # 使用掩码和位移提取6位值
+ char_index = (long_int & masks[index]) >> shifts[index]
+
+ result += encoding_table[char_index]
+
+ return result
+
+
+def get_long_int(round_num: int, long_str: str) -> int:
+ round_num = round_num * 3
+
+ # 获取字符串中的字符，如果超出范围则使用0
+ char1 = ord(long_str[round_num]) if round_num < len(long_str) else 0
+ char2 = ord(long_str[round_num + 1]) if round_num + 1 < len(long_str) else 0
+ char3 = ord(long_str[round_num + 2]) if round_num + 2 < len(long_str) else 0
+
+ return (char1 << 16) | (char2 << 8) | char3
+
+
+def gener_random(random_num: int, option: list[int]) -> list[int]:
+ byte1 = random_num & 255
+ byte2 = (random_num >> 8) & 255
+
+ return [
+ (byte1 & 170) | (option[0] & 85), # 偶数位与option[0]的奇数位合并
+ (byte1 & 85) | (option[0] & 170), # 奇数位与option[0]的偶数位合并
+ (byte2 & 170) | (option[1] & 85), # 偶数位与option[1]的奇数位合并
+ (byte2 & 85) | (option[1] & 170), # 奇数位与option[1]的偶数位合并
+ ]
+
+
+def generate_random_str() -> str:
+ """
+ 生成随机字符串
+
+ Returns:
+ 随机字符串
+ """
+ # 使用与JS版本相同的固定随机值
+ random_values = [0.123456789, 0.987654321, 0.555555555]
+
+ # 生成三组随机字节并合并
+ random_bytes = []
+ random_bytes.extend(gener_random(int(random_values[0] * 10000), [3, 45]))
+ random_bytes.extend(gener_random(int(random_values[1] * 10000), [1, 0]))
+ random_bytes.extend(gener_random(int(random_values[2] * 10000), [1, 5]))
+
+ return ''.join(chr(b) for b in random_bytes)
+
+
+def generate_rc4_bb_str(url_search_params: str, user_agent: str, window_env_str: str,
+ suffix: str = "cus", arguments: list[int] | None = None) -> str:
+ if arguments is None:
+ arguments = [0, 1, 14]
+
+ sm3 = SM3()
+ start_time = int(time.time() * 1000)
+
+ # 三次加密处理
+ # 1: url_search_params两次sm3之的结果
+ url_search_params_list = sm3.sum(sm3.sum(url_search_params + suffix))
+ # 2: 对后缀两次sm3之的结果
+ cus = sm3.sum(sm3.sum(suffix))
+ # 3: 对ua处理之后的结果
+ ua_key = chr(0) + chr(1) + chr(14) # [1/256, 1, 14]
+ ua = sm3.sum(result_encrypt(
+ rc4_encrypt(user_agent, ua_key),
+ "s3"
+ ))
+
+ end_time = start_time + 100
+
+ # 构建配置对象
+ b = {
+ 8: 3,
+ 10: end_time,
+ 15: {
+ "aid": 6383,
+ "pageId": 110624,
+ "boe": False,
+ "ddrt": 7,
+ "paths": {
+ "include": [{} for _ in range(7)],
+ "exclude": []
+ },
+ "track": {
+ "mode": 0,
+ "delay": 300,
+ "paths": []
+ },
+ "dump": True,
+ "rpU": "hwj"
+ },
+ 16: start_time,
+ 18: 44,
+ 19: [1, 0, 1, 5],
+ }
+
+ def split_to_bytes(num: int) -> list[int]:
+ return [
+ (num >> 24) & 255,
+ (num >> 16) & 255,
+ (num >> 8) & 255,
+ num & 255
+ ]
+
+ # 处理时间戳
+ start_time_bytes = split_to_bytes(b[16])
+ b[20] = start_time_bytes[0]
+ b[21] = start_time_bytes[1]
+ b[22] = start_time_bytes[2]
+ b[23] = start_time_bytes[3]
+ b[24] = int(b[16] / 256 / 256 / 256 / 256) & 255
+ b[25] = int(b[16] / 256 / 256 / 256 / 256 / 256) & 255
+
+ # 处理Arguments参数
+ arg0_bytes = split_to_bytes(arguments[0])
+ b[26] = arg0_bytes[0]
+ b[27] = arg0_bytes[1]
+ b[28] = arg0_bytes[2]
+ b[29] = arg0_bytes[3]
+
+ b[30] = int(arguments[1] / 256) & 255
+ b[31] = (arguments[1] % 256) & 255
+
+ arg1_bytes = split_to_bytes(arguments[1])
+ b[32] = arg1_bytes[0]
+ b[33] = arg1_bytes[1]
+
+ arg2_bytes = split_to_bytes(arguments[2])
+ b[34] = arg2_bytes[0]
+ b[35] = arg2_bytes[1]
+ b[36] = arg2_bytes[2]
+ b[37] = arg2_bytes[3]
+
+ # 处理加密结果
+ b[38] = url_search_params_list[21]
+ b[39] = url_search_params_list[22]
+ b[40] = cus[21]
+ b[41] = cus[22]
+ b[42] = ua[23]
+ b[43] = ua[24]
+
+ # 处理结束时间
+ end_time_bytes = split_to_bytes(b[10])
+ b[44] = end_time_bytes[0]
+ b[45] = end_time_bytes[1]
+ b[46] = end_time_bytes[2]
+ b[47] = end_time_bytes[3]
+ b[48] = b[8]
+ b[49] = int(b[10] / 256 / 256 / 256 / 256) & 255
+ b[50] = int(b[10] / 256 / 256 / 256 / 256 / 256) & 255
+
+ # 处理配置项
+ b[51] = b[15]['pageId']
+
+ page_id_bytes = split_to_bytes(b[15]['pageId'])
+ b[52] = page_id_bytes[0]
+ b[53] = page_id_bytes[1]
+ b[54] = page_id_bytes[2]
+ b[55] = page_id_bytes[3]
+
+ b[56] = b[15]['aid']
+ b[57] = b[15]['aid'] & 255
+ b[58] = (b[15]['aid'] >> 8) & 255
+ b[59] = (b[15]['aid'] >> 16) & 255
+ b[60] = (b[15]['aid'] >> 24) & 255
+
+ # 处理环境信息
+ window_env_list = [ord(char) for char in window_env_str]
+ b[64] = len(window_env_list)
+ b[65] = b[64] & 255
+ b[66] = (b[64] >> 8) & 255
+
+ b[69] = 0
+ b[70] = 0
+ b[71] = 0
+
+ # 计算校验和
+ b[72] = b[18] ^ b[20] ^ b[26] ^ b[30] ^ b[38] ^ b[40] ^ b[42] ^ b[21] ^ b[27] ^ b[31] ^ \
+ b[35] ^ b[39] ^ b[41] ^ b[43] ^ b[22] ^ b[28] ^ b[32] ^ b[36] ^ b[23] ^ b[29] ^ \
+ b[33] ^ b[37] ^ b[44] ^ b[45] ^ b[46] ^ b[47] ^ b[48] ^ b[49] ^ b[50] ^ b[24] ^ \
+ b[25] ^ b[52] ^ b[53] ^ b[54] ^ b[55] ^ b[57] ^ b[58] ^ b[59] ^ b[60] ^ b[65] ^ \
+ b[66] ^ b[70] ^ b[71]
+
+ # 构建最终字节数组
+ bb = [
+ b[18], b[20], b[52], b[26], b[30], b[34], b[58], b[38], b[40], b[53], b[42], b[21],
+ b[27], b[54], b[55], b[31], b[35], b[57], b[39], b[41], b[43], b[22], b[28], b[32],
+ b[60], b[36], b[23], b[29], b[33], b[37], b[44], b[45], b[59], b[46], b[47], b[48],
+ b[49], b[50], b[24], b[25], b[65], b[66], b[70], b[71]
+ ]
+ bb.extend(window_env_list)
+ bb.append(b[72])
+
+ return rc4_encrypt(
+ ''.join(chr(byte) for byte in bb),
+ chr(121)
+ )
+
+
+def ab_sign(url_search_params: str, user_agent: str) -> str:
+ window_env_str = "1920|1080|1920|1040|0|30|0|0|1872|92|1920|1040|1857|92|1|24|Win32"
+
+ # 1. 生成随机字符串前缀
+ # 2. 生成RC4加密的主体部分
+ # 3. 对结果进行最终加密并添加等号后缀
+ return result_encrypt(
+ generate_random_str() +
+ generate_rc4_bb_str(url_search_params, user_agent, window_env_str),
+ "s4"
+ ) + "="
diff --git a/src/spider.py b/src/spider.py
index 2b5c682..b0a9304 100644
--- a/src/spider.py
+++ b/src/spider.py
@@ -4,7 +4,7 @@
Author: Hmily
GitHub: https://github.com/ihmily
Date: 2023-07-15 23:15:00
-Update: 2025-07-19 17:43:00
+Update: 2025-10-23 18:28:00
Copyright (c) 2023-2025 by Hmily, All Rights Reserved.
Function: Get live stream data.
"""
@@ -29,6 +29,7 @@ from .utils import trace_error_decorator, generate_random_string
from .logger import script_path
from .room import get_sec_user_id, get_unique_id, UnsupportedUrlError
from .http_clients.async_http import async_req
+from .ab_sign import ab_sign
ssl_context = ssl.create_default_context()
@@ -64,10 +65,87 @@ async def get_play_url_list(m3u8: str, proxy: OptionalStr = None, header: Option
return play_url_list
+async def get_douyin_web_stream_data(url: str, proxy_addr: OptionalStr = None, cookies: OptionalStr = None):
+ headers = {
+ 'cookie': 'ttwid=1%7C2iDIYVmjzMcpZ20fcaFde0VghXAA3NaNXE_SLR68IyE%7C1761045455'
+ '%7Cab35197d5cfb21df6cbb2fa7ef1c9262206b062c315b9d04da746d0b37dfbc7d',
+ 'referer': 'https://live.douyin.com/335354047186',
+ 'user-agent': 'Mozilla/5.0 (Windows NT 10.0; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) '
+ 'Chrome/116.0.5845.97 Safari/537.36 Core/1.116.567.400 QQBrowser/19.7.6764.400',
+ }
+ if cookies:
+ headers['cookie'] = cookies
+
+ try:
+ web_rid = url.split('?')[0].split('live.douyin.com/')[-1]
+ params = {
+ "aid": "6383",
+ "app_name": "douyin_web",
+ "live_id": "1",
+ "device_platform": "web",
+ "language": "zh-CN",
+ "browser_language": "zh-CN",
+ "browser_platform": "Win32",
+ "browser_name": "Chrome",
+ "browser_version": "116.0.0.0",
+ "web_rid": web_rid,
+ 'msToken': '',
+ }
+
+ api = f'https://live.douyin.com/webcast/room/web/enter/?{urllib.parse.urlencode(params)}'
+ a_bogus = ab_sign(urllib.parse.urlparse(api).query, headers['user-agent'])
+ api += "&a_bogus=" + a_bogus
+ try:
+ json_str = await async_req(url=api, proxy_addr=proxy_addr, headers=headers)
+ if not json_str:
+ raise Exception("it triggered risk control")
+ json_data = json.loads(json_str)['data']
+ if not json_data['data']:
+ raise Exception(f"{url} VR live is not supported")
+ room_data = json_data['data'][0]
+ room_data['anchor_name'] = json_data['user']['nickname']
+ except Exception as e:
+ raise Exception(f"Douyin web data fetch error, because {e}.")
+
+ if room_data['status'] == 2:
+ if 'stream_url' not in room_data:
+ raise RuntimeError(
+ "The live streaming type or gameplay is not supported on the computer side yet, please use the "
+ "app to share the link for recording."
+ )
+ live_core_sdk_data = room_data['stream_url']['live_core_sdk_data']
+ pull_datas = room_data['stream_url']['pull_datas']
+ if live_core_sdk_data:
+ if pull_datas:
+ key = list(pull_datas.keys())[0]
+ json_str = pull_datas[key]['stream_data']
+ else:
+ json_str = live_core_sdk_data['pull_data']['stream_data']
+ json_data = json.loads(json_str)
+ if 'origin' in json_data['data']:
+ stream_data = live_core_sdk_data['pull_data']['stream_data']
+ origin_data = json.loads(stream_data)['data']['origin']['main']
+ sdk_params = json.loads(origin_data['sdk_params'])
+ origin_hls_codec = sdk_params.get('VCodec') or ''
+
+ origin_url_list = json_data['data']['origin']['main']
+ origin_m3u8 = {'ORIGIN': origin_url_list["hls"] + '&codec=' + origin_hls_codec}
+ origin_flv = {'ORIGIN': origin_url_list["flv"] + '&codec=' + origin_hls_codec}
+ hls_pull_url_map = room_data['stream_url']['hls_pull_url_map']
+ flv_pull_url = room_data['stream_url']['flv_pull_url']
+ room_data['stream_url']['hls_pull_url_map'] = {**origin_m3u8, **hls_pull_url_map}
+ room_data['stream_url']['flv_pull_url'] = {**origin_flv, **flv_pull_url}
+ except Exception as e:
+ print(f"Error message: {e} Error line: {e.__traceback__.tb_lineno}")
+ room_data = {'anchor_name': ""}
+ return room_data
+
+
@trace_error_decorator
async def get_douyin_app_stream_data(url: str, proxy_addr: OptionalStr = None, cookies: OptionalStr = None) -> dict:
headers = {
- 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:109.0) Gecko/20100101 Firefox/115.0',
+ 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) '
+ 'Chrome/141.0.0.0 Safari/537.36 Edg/141.0.0.0',
'Accept-Language': 'zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2',
'Referer': 'https://live.douyin.com/',
'Cookie': 'ttwid=1%7CB1qls3GdnZhUov9o2NxOMxxYS2ff6OSvEWbv0ytbES4%7C1680522049%7C280d802d6d478e3e78d0c807f7c487e7ffec0ae4e5fdd6a0fe74c3c6af149511; my_rd=1; passport_csrf_token=3ab34460fa656183fccfb904b16ff742; passport_csrf_token_default=3ab34460fa656183fccfb904b16ff742; d_ticket=9f562383ac0547d0b561904513229d76c9c21; n_mh=hvnJEQ4Q5eiH74-84kTFUyv4VK8xtSrpRZG1AhCeFNI; store-region=cn-fj; store-region-src=uid; LOGIN_STATUS=1; __security_server_data_status=1; FORCE_LOGIN=%7B%22videoConsumedRemainSeconds%22%3A180%7D; pwa2=%223%7C0%7C3%7C0%22; download_guide=%223%2F20230729%2F0%22; volume_info=%7B%22isUserMute%22%3Afalse%2C%22isMute%22%3Afalse%2C%22volume%22%3A0.6%7D; strategyABtestKey=%221690824679.923%22; stream_recommend_feed_params=%22%7B%5C%22cookie_enabled%5C%22%3Atrue%2C%5C%22screen_width%5C%22%3A1536%2C%5C%22screen_height%5C%22%3A864%2C%5C%22browser_online%5C%22%3Atrue%2C%5C%22cpu_core_num%5C%22%3A8%2C%5C%22device_memory%5C%22%3A8%2C%5C%22downlink%5C%22%3A10%2C%5C%22effective_type%5C%22%3A%5C%224g%5C%22%2C%5C%22round_trip_time%5C%22%3A150%7D%22; VIDEO_FILTER_MEMO_SELECT=%7B%22expireTime%22%3A1691443863751%2C%22type%22%3Anull%7D; home_can_add_dy_2_desktop=%221%22; __live_version__=%221.1.1.2169%22; device_web_cpu_core=8; device_web_memory_size=8; xgplayer_user_id=346045893336; csrf_session_id=2e00356b5cd8544d17a0e66484946f28; odin_tt=724eb4dd23bc6ffaed9a1571ac4c757ef597768a70c75fef695b95845b7ffcd8b1524278c2ac31c2587996d058e03414595f0a4e856c53bd0d5e5f56dc6d82e24004dc77773e6b83ced6f80f1bb70627; __ac_nonce=064caded4009deafd8b89; __ac_signature=_02B4Z6wo00f01HLUuwwAAIDBh6tRkVLvBQBy9L-AAHiHf7; ttcid=2e9619ebbb8449eaa3d5a42d8ce88ec835; webcast_leading_last_show_time=1691016922379; webcast_leading_total_show_times=1; webcast_local_quality=sd; live_can_add_dy_2_desktop=%221%22; msToken=1JDHnVPw_9yTvzIrwb7cQj8dCMNOoesXbA_IooV8cezcOdpe4pzusZE7NB7tZn9TBXPr0ylxmv-KMs5rqbNUBHP4P7VBFUu0ZAht_BEylqrLpzgt3y5ne_38hXDOX8o=; msToken=jV_yeN1IQKUd9PlNtpL7k5vthGKcHo0dEh_QPUQhr8G3cuYv-Jbb4NnIxGDmhVOkZOCSihNpA2kvYtHiTW25XNNX_yrsv5FN8O6zm3qmCIXcEe0LywLn7oBO2gITEeg=; tt_scid=mYfqpfbDjqXrIGJuQ7q-DlQJfUSG51qG.KUdzztuGP83OjuVLXnQHjsz-BRHRJu4e986'
@@ -77,7 +155,7 @@ async def get_douyin_app_stream_data(url: str, proxy_addr: OptionalStr = None, c
async def get_app_data(room_id: str, sec_uid: str) -> dict:
app_params = {
- "verifyFp": "verify_lxj5zv70_7szNlAB7_pxNY_48Vh_ALKF_GA1Uf3yteoOY",
+ "verifyFp": "verify_hwj52020_7szNlAB7_pxNY_48Vh_ALKF_GA1Uf3yteoOY",
"type_id": "0",
"live_id": "1",
"room_id": room_id,
@@ -86,36 +164,25 @@ async def get_douyin_app_stream_data(url: str, proxy_addr: OptionalStr = None, c
"app_id": "1128"
}
api2 = f'https://webcast.amemv.com/webcast/room/reflow/info/?{urllib.parse.urlencode(app_params)}'
- json_str2 = await async_req(url=api2, proxy_addr=proxy_addr, headers=headers)
- json_data2 = json.loads(json_str2)['data']
- room_data2 = json_data2['room']
- room_data2['anchor_name'] = room_data2['owner']['nickname']
- return room_data2
+ a_bogus = ab_sign(urllib.parse.urlparse(api2).query, headers['User-Agent'])
+ api2 += "&a_bogus=" + a_bogus
+ try:
+ json_str2 = await async_req(url=api2, proxy_addr=proxy_addr, headers=headers)
+ if not json_str2:
+ raise Exception("it triggered risk control")
+ json_data2 = json.loads(json_str2)['data']
+ if not json_data2.get('room'):
+ raise Exception(f"{url} VR live is not supported")
+ room_data2 = json_data2['room']
+ room_data2['anchor_name'] = room_data2['owner']['nickname']
+ return room_data2
+ except Exception as e:
+ raise Exception(f"Douyin app data fetch error, because {e}.")
try:
web_rid = url.split('?')[0].split('live.douyin.com/')
if len(web_rid) > 1:
- web_rid = web_rid[1]
- params = {
- "aid": "6383",
- "app_name": "douyin_web",
- "live_id": "1",
- "device_platform": "web",
- "language": "zh-CN",
- "browser_language": "zh-CN",
- "browser_platform": "Win32",
- "browser_name": "Chrome",
- "browser_version": "116.0.0.0",
- "web_rid": web_rid,
- 'msToken': '',
- 'a_bogus': ''
-
- }
- api = f'https://live.douyin.com/webcast/room/web/enter/?{urllib.parse.urlencode(params)}'
- json_str = await async_req(url=api, proxy_addr=proxy_addr, headers=headers)
- json_data = json.loads(json_str)['data']
- room_data = json_data['data'][0]
- room_data['anchor_name'] = json_data['user']['nickname']
+ return await get_douyin_web_stream_data(url, proxy_addr, cookies)
else:
try:
data = await get_sec_user_id(url, proxy_addr=proxy_addr)
@@ -218,18 +285,20 @@ async def get_douyin_stream_data(url: str, proxy_addr: OptionalStr = None, cooki
@trace_error_decorator
async def get_tiktok_stream_data(url: str, proxy_addr: OptionalStr = None, cookies: OptionalStr = None) -> dict | None:
headers = {
- 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:124.0) Gecko/20100101 Firefox/124.0',
- 'Cookie': 'ttwid=1%7CM-rF193sJugKuNz2RGNt-rh6pAAR9IMceUSzlDnPCNI%7C1683274418%7Cf726d4947f2fc37fecc7aeb0cdaee52892244d04efde6f8a8edd2bb168263269; tiktok_webapp_theme=light; tt_chain_token=VWkygAWDlm1cFg/k8whmOg==; passport_csrf_token=6e422c5a7991f8cec7033a8082921510; passport_csrf_token_default=6e422c5a7991f8cec7033a8082921510; d_ticket=f8c267d4af4523c97be1ccb355e9991e2ae06; odin_tt=320b5f386cdc23f347be018e588873db7f7aea4ea5d1813681c3fbc018ea025dde957b94f74146dbc0e3612426b865ccb95ec8abe4ee36cca65f15dbffec0deff7b0e69e8ea536d46e0f82a4fc37d211; cmpl_token=AgQQAPNSF-RO0rT04baWtZ0T_jUjl4fVP4PZYM2QPw; uid_tt=319b558dbba684bb1557206c92089cd113a875526a89aee30595925d804b81c7; uid_tt_ss=319b558dbba684bb1557206c92089cd113a875526a89aee30595925d804b81c7; sid_tt=ad5e736f4bedb2f6d42ccd849e706b1d; sessionid=ad5e736f4bedb2f6d42ccd849e706b1d; sessionid_ss=ad5e736f4bedb2f6d42ccd849e706b1d; store-idc=useast5; store-country-code=us; store-country-code-src=uid; tt-target-idc=useast5; tt-target-idc-sign=qXNk0bb1pDQ0FbCNF120Pl9WWMLZg9Edv5PkfyCbS4lIk5ieW5tfLP7XWROnN0mEaSlc5hg6Oji1pF-yz_3ZXnUiNMrA9wNMPvI6D9IFKKVmq555aQzwPIGHv0aQC5dNRgKo5Z5LBkgxUMWEojTKclq2_L8lBciw0IGdhFm_XyVJtbqbBKKgybGDLzK8ZyxF4Jl_cYRXaDlshZjc38JdS6wruDueRSHe7YvNbjxCnApEFUv-OwJANSPU_4rvcqpVhq3JI2VCCfw-cs_4MFIPCDOKisk5EhAo2JlHh3VF7_CLuv80FXg_7ZqQ2pJeMOog294rqxwbbQhl3ATvjQV_JsWyUsMd9zwqecpylrPvtySI2u1qfoggx1owLrrUynee1R48QlanLQnTNW_z1WpmZBgVJqgEGLwFoVOmRzJuFFNj8vIqdjM2nDSdWqX8_wX3wplohkzkPSFPfZgjzGnQX28krhgTytLt7BXYty5dpfGtsdb11WOFHM6MZ9R9uLVB; sid_guard=ad5e736f4bedb2f6d42ccd849e706b1d%7C1690990657%7C15525213%7CMon%2C+29-Jan-2024+08%3A11%3A10+GMT; sid_ucp_v1=1.0.0-KGM3YzgwYjZhODgyYWI1NjIwNTA0NjBmOWUxMGRhMjIzYTI2YjMxNDUKGAiqiJ30keKD5WQQwfCppgYYsws4AkDsBxAEGgd1c2Vhc3Q1IiBhZDVlNzM2ZjRiZWRiMmY2ZDQyY2NkODQ5ZTcwNmIxZA; ssid_ucp_v1=1.0.0-KGM3YzgwYjZhODgyYWI1NjIwNTA0NjBmOWUxMGRhMjIzYTI2YjMxNDUKGAiqiJ30keKD5WQQwfCppgYYsws4AkDsBxAEGgd1c2Vhc3Q1IiBhZDVlNzM2ZjRiZWRiMmY2ZDQyY2NkODQ5ZTcwNmIxZA; tt_csrf_token=dD0EIH8q-pe3qDQsCyyD1jLN6KizJDRjOEyk; __tea_cache_tokens_1988={%22_type_%22:%22default%22%2C%22user_unique_id%22:%227229608516049831425%22%2C%22timestamp%22:1683274422659}; ttwid=1%7CM-rF193sJugKuNz2RGNt-rh6pAAR9IMceUSzlDnPCNI%7C1694002151%7Cd89b77afc809b1a610661a9d1c2784d80ebef9efdd166f06de0d28e27f7e4efe; msToken=KfJAVZ7r9D_QVeQlYAUZzDFbc1Yx-nZz6GF33eOxgd8KlqvTg1lF9bMXW7gFV-qW4MCgUwnBIhbiwU9kdaSpgHJCk-PABsHCtTO5J3qC4oCTsrXQ1_E0XtbqiE4OVLZ_jdF1EYWgKNPT2SnwGkQ=; msToken=KfJAVZ7r9D_QVeQlYAUZzDFbc1Yx-nZz6GF33eOxgd8KlqvTg1lF9bMXW7gFV-qW4MCgUwnBIhbiwU9kdaSpgHJCk-PABsHCtTO5J3qC4oCTsrXQ1_E0XtbqiE4OVLZ_jdF1EYWgKNPT2SnwGkQ='
+ 'referer': 'https://www.tiktok.com/',
+ 'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) '
+ 'Chrome/141.0.0.0 Safari/537.36',
+ 'cookie': cookies or '1%7Cz7FKki38aKyy7i-BC9rEDwcrVvjcLcFEL6QIeqldoy4%7C1761302831%7C6c1461e9f1f980cbe0404c5190'
+ '5177d5d53bbd822e1bf66128887d942c9c3e2f'
}
- if cookies:
- headers['Cookie'] = cookies
+
for i in range(3):
html_str = await async_req(url=url, proxy_addr=proxy_addr, headers=headers, abroad=True, http2=False)
time.sleep(1)
if "We regret to inform you that we have discontinued operating TikTok" in html_str:
msg = re.search('\n\\s+(We regret to inform you that we have discontinu.*?)\\.\n\\s+
', html_str)
raise ConnectionError(
- f"Your proxy node's regional network is blocked from accessing TikTok; please switch to a node in "
+ "Your proxy node's regional network is blocked from accessing TikTok; please switch to a node in "
f"another region to access. {msg.group(1) if msg else ''}"
)
if 'UNEXPECTED_EOF_WHILE_READING' not in html_str:
@@ -935,6 +1004,76 @@ async def get_sooplive_tk(url: str, rtype: str, proxy_addr: OptionalStr = None,
return f"{bj_name}-{bj_id}", json_data['CHANNEL']['BNO']
+def get_soop_headers(cookies):
+ headers = {
+ 'client-id': str(uuid.uuid4()),
+ 'user-agent': 'Mozilla/5.0 (iPhone; CPU iPhone OS 18_5 like Mac OS X) AppleWebKit/605.1.15 (KHTML, '
+ 'like Gecko) Version/18.5 Mobile/15E148 Safari/604.1 Edg/141.0.0.0',
+ }
+ if cookies:
+ headers['cookie'] = cookies
+ return headers
+
+
+async def _get_soop_channel_info_global(bj_id, proxy_addr: OptionalStr = None, cookies: OptionalStr = None) -> str:
+ headers = get_soop_headers(cookies)
+ api = 'https://api.sooplive.com/v2/channel/info/' + str(bj_id)
+ json_str = await async_req(api, proxy_addr=proxy_addr, headers=headers)
+ json_data = json.loads(json_str)
+ nickname = json_data['data']['streamerChannelInfo']['nickname']
+ channelId = json_data['data']['streamerChannelInfo']['channelId']
+ anchor_name = f"{nickname}-{channelId}"
+ return anchor_name
+
+
+async def _get_soop_stream_info_global(bj_id, proxy_addr: OptionalStr = None, cookies: OptionalStr = None) -> tuple:
+ headers = get_soop_headers(cookies)
+ api = 'https://api.sooplive.com/v2/stream/info/' + str(bj_id)
+ json_str = await async_req(api, proxy_addr=proxy_addr, headers=headers)
+ json_data = json.loads(json_str)
+ status = json_data['data']['isStream']
+ title = json_data['data']['title']
+ return status, title
+
+
+async def _fetch_web_stream_data_global(url: str, proxy_addr: OptionalStr = None, cookies: OptionalStr = None) -> dict:
+ split_url = url.split('/')
+ bj_id = split_url[3] if len(split_url) < 6 else split_url[5]
+ anchor_name = await _get_soop_channel_info_global(bj_id)
+ result = {"anchor_name": anchor_name or '', "is_live": False, "live_url": url}
+ status, title = await _get_soop_stream_info_global(bj_id)
+ if not status:
+ return result
+ else:
+ async def _get_url_list(m3u8: str) -> list[str]:
+ headers = {
+ 'user-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) '
+ 'Chrome/141.0.0.0 Safari/537.36 Edg/141.0.0.0',
+ }
+ if cookies:
+ headers['cookie'] = cookies
+ resp = await async_req(url=m3u8, proxy_addr=proxy_addr, headers=headers)
+ play_url_list = []
+ url_prefix = '/'.join(m3u8.split('/')[0:3])
+ for i in resp.split('\n'):
+ if not i.startswith('#') and i.strip():
+ play_url_list.append(url_prefix + i.strip())
+ bandwidth_pattern = re.compile(r'BANDWIDTH=(\d+)')
+ bandwidth_list = bandwidth_pattern.findall(resp)
+ url_to_bandwidth = {purl: int(bandwidth) for bandwidth, purl in zip(bandwidth_list, play_url_list)}
+ play_url_list = sorted(play_url_list, key=lambda purl: url_to_bandwidth[purl], reverse=True)
+ return play_url_list
+
+ m3u8_url = 'https://global-media.sooplive.com/live/' + str(bj_id) + '/master.m3u8'
+ result |= {
+ 'is_live': True,
+ 'title': title,
+ 'm3u8_url': m3u8_url,
+ 'play_url_list': await _get_url_list(m3u8_url)
+ }
+ return result
+
+
@trace_error_decorator
async def get_sooplive_stream_data(
url: str, proxy_addr: OptionalStr = None, cookies: OptionalStr = None,
@@ -949,6 +1088,9 @@ async def get_sooplive_stream_data(
if cookies:
headers['Cookie'] = cookies
+ if "sooplive.com" in url:
+ return await _fetch_web_stream_data_global(url, proxy_addr, cookies)
+
split_url = url.split('/')
bj_id = split_url[3] if len(split_url) < 6 else split_url[5]