小鹅通 M3U8 视频下载器

实用软件7天前更新 小编
4 0

支持自动解密、多线程并发与浏览器联动的本地命令行下载工具，配合浏览器，能够无缝接管课程下载任务，真正进入高效的“边看边存”状态

核心特性
浏览器联动，一键发送：运行后在本地启动 HTTP 服务（端口 8910），配合浏览器脚本，在课程页面点击“发送到下载”即可自动拉起后台下载，零繁琐链接复制，彻底解放双手。
开箱即用，免配依赖：脚本内置环境自检逻辑。首次运行自动检测并安装缺失的 Python 依赖（requests, pycryptodome, tqdm）。
全自动解密与合并，效率翻倍：
        自动解密 → 自动获取并解析 AES-128 密钥与 IV，在内存中完成 TS 切片解密。
智能合并 → 极速调用 FFmpeg 将切片合并为 MP4，内置“Stream Copy”与“重编码”双重回退机制，确保视频完美合并。
多线程并发，极速下载：采用 ThreadPoolExecutor 提供多线程并发下载，搭配 tqdm 进度条，直观展示下载进度与切片完成情况。
稳定可靠，日志追溯：提供“控制台+本地日志（downloader.log）”双重记录，所有下载历史有迹可循。

重点说明：
// @match        *://*.xiaoeknow.com/*
// @match        *://*.xet.tech/*
// @match        *://*.xiaoe-tech.com/*
// @match        *://*.xet.pomoho.com/*
// @match        *://*.xet-pc.citv.cn/*
因平台支持自定义域名，因此若脚本中不包含所购买的课程的自定义域名，则需要手动进行添加

使用步骤：一、环境与工具准备安装扩展：为实现网页端联动，用户需要手动在浏览器（如 Chrome、Edge）的扩展商店中安装 Tampermonkey（油猴） 插件。添加脚本：在油猴插件中，添加并启用文件目录下的网页端用户脚本（用于在页面生成交互按钮）
小鹅通 M3U8 视频下载器

  • 免配置环境：程序已设置好本地 Winpython32-3.8.3.0 环境，无需手动创建环境，无需任何编译，真正做到开箱即用。
  • 启动服务：直接运行工具，程序会自动完成自检。当控制台出现“等待浏览器发送下载任务…”提示时，代表本地监听服务已成功启动。

二、一键发送任务，全自动下载
保持下载器的命令行窗口在后台运行，切勿关闭。
打开课程到播放页面，如需特定清晰度需要手动调整，等获取到视频地址后，直接点击由油猴脚本生成的“发送到下载”按钮。
接收到任务后，下载器将在本地 downloads 文件夹下全自动完成切片下载、密钥解密与最终的 MP4 视频合并导出。
小鹅通 M3U8 视频下载器
小鹅通 M3U8 视频下载器

最低系统可支持到win7 32位，若存在不兼容问题可以直接替换环境
[Python] 

  1. """小鹅通 M3U8 视频下载器 — 交互式命令行版"""

  2. import os, time, shutil, subprocess, binascii, re

  3. from concurrent.futures import ThreadPoolExecutor, as_completed

  4. from urllib.parse import urljoin

  5. import requests

  6. from Crypto.Cipher import AES

  7. from Crypto.Util.Padding import unpad

  8. from tqdm import tqdm

  9.  

  10. # 强制 stdout 行缓冲，确保 Windows CMD 中实时输出

  11. if hasattr(sys.stdout, 'reconfigure'):

  12.     sys.stdout.reconfigure(line_buffering=True)

  13.  

  14. BASE_DIR = os.path.dirname(os.path.abspath(__file__))

  15. OUT = os.path.join(BASE_DIR, 'downloads')

  16. os.makedirs(OUT, exist_ok=True)

  17. LOG_FILE = os.path.join(BASE_DIR, 'downloader.log')

  18.  

  19.  

  20. def _console_encoding():

  21.     """获取 Windows 控制台实际代码页，避免 UTF-8/GBK 猜错"""

  22.     try:

  23.         import ctypes

  24.         cp = ctypes.windll.kernel32.GetConsoleOutputCP()

  25.         if cp == 65001:

  26.             return 'utf-8'

  27.         elif cp == 936:

  28.             return 'gbk'

  29.         else:

  30.             return f'cp{cp}'

  31.     except Exception:

  32.         return (sys.stdout.encoding or 'utf-8').lower()

  33.  

  34.  

  35. CONSOLE_ENC = _console_encoding()

  36.  

  37.  

  38. def log(msg, end='\n'):

  39.     """同时输出到控制台和日志文件。控制台按实际代码页编码，避免乱码"""

  40.     ts = time.strftime('%H:%M:%S')

  41.     line = f'[{ts}] {msg}'

  42.     # 1. 文件日志（始终可靠）

  43.     try:

  44.         with open(LOG_FILE, 'a', encoding='utf-8') as f:

  45.             f.write(line)

  46.             if end:

  47.                 f.write(end)

  48.             f.flush()

  49.     except Exception:

  50.         pass

  51.     # 2. 控制台：按真实代码页编码

  52.     try:

  53.         data = (line + end).encode(CONSOLE_ENC, errors='replace')

  54.     except Exception:

  55.         data = (line + end).encode('utf-8', errors='replace')

  56.     try:

  57.         os.write(1, data)

  58.     except Exception:

  59.         try:

  60.             os.write(2, data)

  61.         except Exception:

  62.             pass

  63.  

  64.  

  65. FFMPEG = os.path.join(BASE_DIR, 'ffmpeg.exe')

  66.  

  67.  

  68. def safe_name(name):

  69.     """去除文件名中的非法字符"""

  70.     return re.sub(r'[<>:"/\\|?*]', '_', name).strip()

  71.  

  72.  

  73. def find_ffmpeg():

  74.     for p in [FFMPEG, shutil.which('ffmpeg'), shutil.which('ffmpeg.exe')]:

  75.         if p and os.path.isfile(p):

  76.             return p

  77.     return None

  78.  

  79.  

  80. def download_one(name, m3u8_url):

  81.     """下载单个视频"""

  82.     s = requests.Session()

  83.     s.headers.update({

  84.         'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36',

  85.         'Referer': 'https://xiaoe-tech.com/',

  86.     })

  87.  

  88.     log(f'\n  {name}')

  89.     log(f'  {"─" * 50}')

  90.  

  91.     # 1. 下载 M3U8

  92.     log('  [1/4] 下载索引...', end=' ')

  93.     try:

  94.         resp = s.get(m3u8_url, timeout=30)

  95.         resp.raise_for_status()

  96.     except Exception as e:

  97.         log(f'失败: {e}')

  98.         return False

  99.     m3u8 = resp.text

  100.     base = '/'.join(m3u8_url.split('/')[:-1]) + '/'

  101.  

  102.     # 2. 解析

  103.     segments = []

  104.     key_url = None

  105.     iv = b'\x00' * 16

  106.     for line in m3u8.split('\n'):

  107.         line = line.strip()

  108.         if 'URI=' in line and 'AES-128' in line:

  109.             a = line.find('URI="') + 5

  110.             b = line.find('"', a)

  111.             key_url = line[a:b]

  112.             if not key_url.startswith('http'):

  113.                 key_url = urljoin(base, key_url)

  114.             iv_s = line.find('IV=0x')

  115.             if iv_s != -1:

  116.                 iv = binascii.unhexlify(line[iv_s + 5:iv_s + 37])

  117.         elif line and not line.startswith('#'):

  118.             u = line if line.startswith('http') else urljoin(base, line)

  119.             segments.append(u)

  120.  

  121.     log(f'{len(segments)} 片段')

  122.  

  123.     # 3. 获取密钥

  124.     log('  [2/4] 获取密钥...', end=' ')

  125.     try:

  126.         key = s.get(key_url, timeout=15).content

  127.         log(f'{len(key)} 字节')

  128.     except Exception as e:

  129.         log(f'失败: {e}')

  130.         return False

  131.  

  132.     # 4. 并行下载

  133.     tmp = os.path.join(OUT, f'tmp_{int(time.time())}')

  134.     os.makedirs(tmp, exist_ok=True)

  135.  

  136.     def dl_one(url, key, iv, idx):

  137.         for _ in range(3):

  138.             try:

  139.                 data = s.get(url, timeout=60).content

  140.                 break

  141.             except:

  142.                 time.sleep(1)

  143.         else:

  144.             return None

  145.         seg_iv = iv[:12] + idx.to_bytes(4, 'big')

  146.         dec = AES.new(key, AES.MODE_CBC, iv=seg_iv).decrypt(data)

  147.         try:

  148.             dec = unpad(dec, AES.block_size)

  149.         except:

  150.             pass

  151.         fp = os.path.join(tmp, f's_{idx:05d}.ts')

  152.         with open(fp, 'wb') as f:

  153.             f.write(dec)

  154.         return fp

  155.  

  156.     t0 = time.time()

  157.     results = {}

  158.     with ThreadPoolExecutor(max_workers=6) as ex:

  159.         fut = {ex.submit(dl_one, u, key, iv, i): i for i, u in enumerate(segments)}

  160.         with tqdm(total=len(segments), desc='  [3/4] 下载中', unit='片',

  161.                   ncols=60, bar_format='{desc}: {percentage:3.0f}%|{bar}| {n_fmt}/{total_fmt}') as pbar:

  162.             for f in as_completed(fut):

  163.                 if f.result():

  164.                     results[fut[f]] = f.result()

  165.                     pbar.update(1)

  166.     elapsed = time.time() - t0

  167.  

  168.     if not results:

  169.         log('  所有片段下载失败')

  170.         shutil.rmtree(tmp, ignore_errors=True)

  171.         return False

  172.  

  173.     # 5. 合并

  174.     log(f'  [4/4] 合并 ({elapsed:.1f}s 下载, {len(results)}/{len(segments)} 成功)...', end=' ')

  175.     files = [results[i] for i in sorted(results)]

  176.     output = os.path.join(OUT, f'{safe_name(name)}.mp4')

  177.  

  178.     # Concat 列表

  179.     lst = os.path.join(OUT, '_concat.txt')

  180.     with open(lst, 'w', encoding='utf-8') as f:

  181.         for fp in files:

  182.             f.write(f"file '{fp.replace(os.sep, '/')}'\n")

  183.  

  184.     if os.path.exists(output):

  185.         os.remove(output)

  186.  

  187.     cmd = [find_ffmpeg() or 'ffmpeg', '-f', 'concat', '-safe', '0',

  188.            '-i', lst, '-c', 'copy', '-movflags', '+faststart', '-y', output]

  189.     r = subprocess.run(cmd, capture_output=True, encoding='utf-8',

  190.                        errors='replace', timeout=600)

  191.     if os.path.exists(lst):

  192.         os.remove(lst)

  193.  

  194.     if r.returncode != 0:

  195.         # 重编码回退

  196.         lst2 = os.path.join(OUT, '_concat2.txt')

  197.         with open(lst2, 'w', encoding='utf-8') as f:

  198.             for fp in files:

  199.                 f.write(f"file '{fp.replace(os.sep, '/')}'\n")

  200.         cmd2 = [find_ffmpeg() or 'ffmpeg', '-f', 'concat', '-safe', '0',

  201.                 '-i', lst2, '-c:v', 'libx264', '-c:a', 'aac',

  202.                 '-movflags', '+faststart', '-y', output]

  203.         subprocess.run(cmd2, capture_output=True, encoding='utf-8',

  204.                        errors='replace', timeout=600)

  205.         if os.path.exists(lst2):

  206.             os.remove(lst2)

  207.  

  208.     shutil.rmtree(tmp, ignore_errors=True)

  209.  

  210.     if os.path.exists(output):

  211.         mb = os.path.getsize(output) / 1048576

  212.         log(f'  {mb:.1f} MB  ->  {output}')

  213.         return True

  214.     else:

  215.         log('  合并失败')

  216.         return False

  217.  

  218.  

  219. # ============================================================

  220. #  HTTP 服务 — 接收浏览器发来的下载任务

  221. # ============================================================

  222.  

  223. import json

  224. import traceback

  225. import threading

  226. from http.server import HTTPServer, BaseHTTPRequestHandler

  227.  

  228. PORT = 8910

  229. total_count = 0

  230. count_lock = threading.Lock()

  231.  

  232. # 线程池：支持同时下载最多3个

  233. download_pool = ThreadPoolExecutor(max_workers=3)

  234.  

  235.  

  236. class Handler(BaseHTTPRequestHandler):

  237.     def log_message(self, *args):

  238.         pass

  239.  

  240.     def do_OPTIONS(self):

  241.         log(f'HTTP OPTIONS {self.path}')

  242.         self._cors()

  243.  

  244.     def do_GET(self):

  245.         log(f'HTTP GET {self.path}')

  246.         self._cors()

  247.         self._json({'status': 'running', 'port': PORT, 'total': total_count})

  248.  

  249.     def do_POST(self):

  250.         global total_count

  251.         log(f'HTTP POST {self.path} 开始处理')

  252.         try:

  253.             length = int(self.headers.get('Content-Length', 0))

  254.             raw = self.rfile.read(length)

  255.             data = json.loads(raw)

  256.             name = data.get('name', '').strip()

  257.             url = data.get('url', '').strip()

  258.  

  259.             log(f'HTTP POST {self.path} body_len={length}')

  260.             log(f'JSON: name={name!r} url={url[:60]}...')

  261.  

  262.             if not name or not url:

  263.                 log('拒绝任务：name 或 url 为空')

  264.                 self._cors()

  265.                 self._json({'status': 'error', 'msg': 'missing name or url'})

  266.                 return

  267.  

  268.             log(f'>>> 收到任务: [{name}]')

  269.             log(f'    URL: {url[:80]}...')

  270.  

  271.             self._cors()

  272.             self._json({'status': 'accepted', 'msg': f'已接收: {name}'})

  273.             log(f'已响应 accepted，提交后台下载...')

  274.  

  275.             download_pool.submit(self._do_download, name, url)

  276.  

  277.         except Exception as e:

  278.             tb = traceback.format_exc()

  279.             log(f'HTTP POST 异常: {e}')

  280.             log(f'异常堆栈: {tb}')

  281.             self._cors()

  282.             self._json({'status': 'error', 'msg': str(e)})

  283.  

  284.     def _do_download(self, name, url):

  285.         """在单独线程中执行下载"""

  286.         global total_count

  287.         log(f'开始下载: [{name}]')

  288.         ok = download_one(name, url)

  289.         with count_lock:

  290.             if ok:

  291.                 total_count += 1

  292.             log(f'--- 任务结束: [{name}] {"成功" if ok else "失败"} (累计: {total_count}) ---')

  293.             log('等待新任务...')

  294.  

  295.     def _cors(self):

  296.         self.send_response(200)

  297.         self.send_header('Access-Control-Allow-Origin', '*')

  298.         self.send_header('Access-Control-Allow-Methods', 'POST, GET, OPTIONS')

  299.         self.send_header('Access-Control-Allow-Headers', 'Content-Type')

  300.         self.send_header('Content-Type', 'application/json')

  301.         self.end_headers()

  302.  

  303.     def _json(self, obj):

  304.         body = json.dumps(obj, ensure_ascii=False).encode('utf-8')

  305.         self.wfile.write(body)

  306.  

  307.  

  308. def main():

  309.     ffmpeg = find_ffmpeg()

  310.     if not ffmpeg:

  311.         log('未找到 ffmpeg.exe，请放到本目录下')

  312.         sys.exit(1)

  313.  

  314.     server = HTTPServer(('127.0.0.1', PORT), Handler)

  315.  

  316.     log('=' * 50)

  317.     log('小鹅通 M3U8 视频下载器 启动')

  318.     log(f'ffmpeg: {ffmpeg}')

  319.     log(f'输出:   {OUT}')

  320.     log(f'端口:   localhost:{PORT}')

  321.     log('等待浏览器发送下载任务...')

  322.     log('在课程页面点击 "发送到下载" 即可')

  323.     log('按 Ctrl+C 退出')

  324.     log('=' * 50)

  325.  

  326.     try:

  327.         server.serve_forever()

  328.     except KeyboardInterrupt:

  329.         log('\n退出。本次共下载 {} 个视频。'.format(total_count))

  330.         server.shutdown()

  331.  

  332.  

  333. if __name__ == '__main__':

  334.     main()
复制代码

下载地址

https://wwamb.lanzoul.com/ijN623u0mxji

© 版权声明
文章版权归作者所有，未经允许请勿转载。

相关文章

添加小工具
点此为“正文侧边栏”添加小工具