管理员登录

'; ?> $login_timeout) { session_destroy(); header('Location:./'); exit; } $_SESSION['login_time'] = time(); define('TASKS_FILE', 'tasks.json'); define('HLS_DIR', 'hls_output'); define('FFMPEG_PATH', 'ffmpeg'); define('LOG_DIR', 'logs'); define('PROBE_DIR', 'probe_cache'); @mkdir(HLS_DIR, 0777, true); @mkdir(LOG_DIR, 0777, true); @mkdir(PROBE_DIR, 0777, true); $tasks = json_decode(@file_get_contents(TASKS_FILE), true) ?: []; // 检查exec是否可用 function isExecAvailable() { $disabled = explode(',', ini_get('disable_functions')); return function_exists('exec') && !in_array('exec', $disabled); } // 获取任务专属日志文件 function getTaskLogFile($id) { return LOG_DIR . "/{$id}.log"; } // 记录日志 function logMessage($id, $msg, $type = 'INFO') { $timestamp = date('Y-m-d H:i:s'); $logFile = getTaskLogFile($id); $logMsg = "[{$timestamp}] [{$type}] {$msg}\n"; file_put_contents($logFile, $logMsg, FILE_APPEND); $globalLog = LOG_DIR . "/all.log"; file_put_contents($globalLog, $logMsg, FILE_APPEND); } // 清除任务日志 function clearTaskLog($id) { $logFile = getTaskLogFile($id); if (file_exists($logFile)) { file_put_contents($logFile, ''); return true; } return false; } // 读取任务日志 function getTaskLog($id, $lines = 500) { $logFile = getTaskLogFile($id); if (!file_exists($logFile)) { return "暂无日志"; } $logs = file_get_contents($logFile); if ($lines > 0 && strlen($logs) > $lines * 100) { $logs = substr($logs, -($lines * 100)); } return nl2br(htmlspecialchars($logs)); } function clearLogs() { $globalLog = LOG_DIR . "/all.log"; if (file_exists($globalLog)) { file_put_contents($globalLog, ''); } return true; } // ==================== URL处理 ==================== function safeTrim($str) { return is_string($str) ? trim($str) : ''; } function fullUrl($base, $path) { if (empty($path)) return ''; if (strpos($path, 'http') === 0) return $path; if (empty($base)) return $path; $parse = parse_url($base); $dir = dirname($parse['path'] ?? '/'); $baseHost = ($parse['scheme'] ?? 'http') . '://' . ($parse['host'] ?? ''); return rtrim($baseHost . $dir, '/') . '/' . ltrim($path, '/'); } function getFinalUrl($url) { if (empty($url)) return ''; $ch = curl_init($url); curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); curl_setopt($ch, CURLOPT_USERAGENT, "Mozilla/5.0"); curl_setopt($ch, CURLOPT_NOBODY, true); curl_exec($ch); $finalUrl = curl_getinfo($ch, CURLINFO_EFFECTIVE_URL); curl_close($ch); return $finalUrl ?: $url; } // ==================== 获取 PHP 代理返回的真实地址 ==================== function getRealMPDUrl($proxyUrl, &$debug = []) { $debug = ['status' => '获取真实地址中']; $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $proxyUrl); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true); curl_setopt($ch, CURLOPT_TIMEOUT, 30); curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36'); $headers = [ 'Accept: application/dash+xml,application/xml,text/html,*/*', 'Accept-Language: zh-CN,zh;q=0.9,en;q=0.8', 'Connection: keep-alive', ]; curl_setopt($ch, CURLOPT_HTTPHEADER, $headers); $content = curl_exec($ch); $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE); $finalUrl = curl_getinfo($ch, CURLINFO_EFFECTIVE_URL); $contentType = curl_getinfo($ch, CURLINFO_CONTENT_TYPE); curl_close($ch); $debug['http_code'] = $httpCode; $debug['final_url'] = $finalUrl; $debug['content_type'] = $contentType; // 302重定向到MPD地址 if ($httpCode === 302 && strpos($finalUrl, '.mpd') !== false) { $debug['status'] = '302重定向到MPD'; return $finalUrl; } if ($httpCode !== 200) { $debug['status'] = "HTTP错误: {$httpCode}"; return false; } // 返回的是MPD XML内容 if (strpos($content, '([^<]+)<\/BaseURL>/', $content, $matches)) { $baseUrl = trim($matches[1]); if (strpos($baseUrl, 'http') === 0) { $debug['extracted_baseurl'] = $baseUrl; $debug['status'] = '提取到BaseURL'; return $baseUrl; } } // 提取session和token构建TVB地址 $session = ''; $token = ''; if (preg_match('/session\/([^\/]+)/', $content, $matches)) { $session = $matches[1]; } if (preg_match('/token=([^"\']+)/', $content, $matches)) { $token = $matches[1]; } if ($session && $token) { $tvbUrl = "http://hk4-edge26-1.edgeware.tvb.com:80/session/{$session}/__cl/slocalr43/__c/ott_J_hevc/__op/cenc_m/__f/index.mpd?token={$token}"; $debug['constructed_url'] = $tvbUrl; $debug['status'] = '构建TVB播放地址'; return $tvbUrl; } // 保存MPD到文件 $tempFile = PROBE_DIR . '/temp_' . md5($proxyUrl) . '.mpd'; file_put_contents($tempFile, $content); $debug['cached_file'] = $tempFile; return false; } // 返回的是M3U8 if (strpos($content, '#EXTM3U') !== false) { $debug['status'] = '返回的是M3U8'; return $proxyUrl; } $debug['status'] = '无法识别返回内容'; return false; } // ==================== 通用流探测 ==================== function probeStream($url, &$debug = []) { $debug = ['status' => '探测中']; $cacheFile = PROBE_DIR . '/' . md5($url) . '.json'; if (file_exists($cacheFile) && (time() - filemtime($cacheFile)) < 3600) { $cached = json_decode(file_get_contents($cacheFile), true); if ($cached) { $debug = $cached['debug'] ?? ['status' => '从缓存读取']; return $cached['data']; } } if (!isExecAvailable()) { $debug['status'] = '无法探测：exec函数不可用'; return false; } $cmd = FFMPEG_PATH . ' -i ' . escapeshellarg($url) . ' 2>&1'; exec($cmd, $output, $returnCode); $ffprobeOutput = implode("\n", $output); $videoList = []; $audioList = []; $subList = []; $lines = explode("\n", $ffprobeOutput); $videoIndex = 0; $audioIndex = 0; $subIndex = 0; foreach ($lines as $line) { if (preg_match('/Stream #\d+:(\d+).*?: Video: ([\w]+)/', $line, $matches)) { $codec = $matches[2]; $resolution = ''; if (preg_match('/(\d+)x(\d+)/', $line, $resMatch)) { $resolution = " {$resMatch[1]}x{$resMatch[2]}"; } $videoList[] = [ 'id' => $videoIndex, 'codecs' => $codec . $resolution, 'index' => $matches[1] ]; $videoIndex++; } elseif (preg_match('/Stream #\d+:(\d+).*?: Audio: ([\w]+)/', $line, $matches)) { $codec = $matches[2]; $lang = ''; if (preg_match('/$([a-z]{2,3})$/', $line, $langMatch)) { $lang = $langMatch[1]; } $audioList[] = [ 'id' => $audioIndex, 'codecs' => $codec, 'lang' => $lang, 'index' => $matches[1] ]; $audioIndex++; } elseif (preg_match('/Stream #\d+:(\d+).*?: Subtitle: ([\w]+)/', $line, $matches)) { $codec = $matches[2]; $lang = ''; if (preg_match('/$([a-z]{2,3})$/', $line, $langMatch)) { $lang = $langMatch[1]; } $subList[] = [ 'id' => $subIndex, 'codecs' => $codec, 'lang' => $lang, 'index' => $matches[1] ]; $subIndex++; } } $debug['status'] = '探测成功'; $debug['ffprobe_output'] = substr($ffprobeOutput, 0, 500); $result = [ 'video' => $videoList, 'audio' => $audioList, 'subtitle' => $subList, 'originUrl' => $url ]; file_put_contents($cacheFile, json_encode(['data' => $result, 'debug' => $debug])); return $result; } // ==================== MPD解析模式 ==================== function parseMPD($mpd_url, &$debug = []) { if (empty($mpd_url)) { $debug = ['status' => 'MPD地址为空']; return false; } $realUrl = getFinalUrl($mpd_url); $debug = ['http_code'=>0, 'content_len'=>0, 'curl_error'=>'', 'status'=>'等待下载']; $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $realUrl); curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1); curl_setopt($ch, CURLOPT_TIMEOUT, 30); curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); curl_setopt($ch, CURLOPT_ENCODING, 'gzip, deflate, br'); curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0'); $mpd_content = curl_exec($ch); $debug['http_code'] = curl_getinfo($ch, CURLINFO_HTTP_CODE); $debug['curl_error'] = curl_error($ch); $debug['content_len'] = strlen($mpd_content); curl_close($ch); if ($debug['http_code'] !== 200) { $debug['status'] = "HTTP错误: {$debug['http_code']}"; return false; } if ($debug['content_len'] < 100) { $debug['status'] = 'MPD内容过小，可能被拒绝'; return false; } libxml_use_internal_errors(true); $xml = simplexml_load_string($mpd_content); if (!$xml) { $errors = libxml_get_errors(); $debug['status'] = 'XML解析失败: ' . ($errors[0]->message ?? '未知错误'); libxml_clear_errors(); return false; } $videoList = []; $audioList = []; $subList = []; $segments = []; if (isset($xml->Period)) { foreach ($xml->Period->AdaptationSet as $set) { $mime = strtolower(safeTrim((string)($set->attributes()->mimeType ?? ''))); $lang = safeTrim((string)($set->attributes()->lang ?? '')); if (isset($set->SegmentTemplate)) { $t = $set->SegmentTemplate; $media = safeTrim((string)($t->attributes()->media ?? '')); $dur = (int)($t->attributes()->duration ?? 2000); $start = (int)($t->attributes()->startNumber ?? 1); $isTimeMode = strpos($media, '$Time$') !== false; for ($i = 0; $i < min(40, 80); $i++) { $num = $isTimeMode ? ($start + ($i * $dur)) : ($start + $i); $segUrl = str_replace( ['$RepresentationID$', '$Number$', '$Time$', '$Bandwidth$'], ['', $num, $num, ''], $media ); $fullSeg = fullUrl($realUrl, $segUrl); if (!empty($fullSeg)) { $segments[] = $fullSeg; } } } elseif (isset($set->SegmentList)) { $segList = $set->SegmentList; foreach ($segList->SegmentURL as $seg) { $segUrl = safeTrim((string)($seg->attributes()->media ?? '')); if (!empty($segUrl)) { $fullSeg = fullUrl($realUrl, $segUrl); if (!empty($fullSeg)) $segments[] = $fullSeg; } } } foreach ($set->Representation as $rep) { $rid = safeTrim((string)($rep->attributes()->id ?? '')); $codecs = safeTrim((string)($rep->attributes()->codecs ?? '')); if(empty($rid)) continue; if (strpos($mime, 'video') !== false) { $videoList[] = ['id' => $rid, 'codecs' => $codecs]; } elseif (strpos($mime, 'audio') !== false) { $audioList[] = ['id' => $rid, 'codecs' => $codecs, 'lang' => $lang]; } elseif (strpos($mime, 'subtitle') !== false || strpos($mime, 'stpp') !== false || strpos($mime, 'vtt') !== false) { $subList[] = ['id' => $rid, 'codecs' => $codecs, 'lang' => $lang]; } } } } if (empty($videoList) && !empty($segments)) { $debug['status'] = '解析成功，未找到轨道信息'; } else { $debug['status'] = '解析成功'; } return [ 'video' => $videoList, 'audio' => $audioList, 'subtitle' => $subList, 'segments' => $segments, 'originUrl' => $realUrl ]; } // ==================== TVB专用流处理 ==================== function startTVBStream($id, $proxyUrl, $videoTrack = 0, $audioTrack = 0, $subTrack = -1, $clearkey = '') { logMessage($id, "尝试TVB专用模式: {$proxyUrl}", 'INFO'); // 获取真实的MPD地址 $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $proxyUrl); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true); curl_setopt($ch, CURLOPT_TIMEOUT, 15); curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36'); $content = curl_exec($ch); $info = curl_getinfo($ch); curl_close($ch); $realMpdUrl = ''; // 提取真实MPD URL if ($info['http_code'] == 302 && strpos($info['url'], '.mpd') !== false) { $realMpdUrl = $info['url']; } elseif (preg_match('/([^<]+)<\/BaseURL>/', $content, $matches)) { $realMpdUrl = trim($matches[1]); } elseif (preg_match('/https?:\/\/[^\s"\']+\.mpd[^\s"\']*/', $content, $matches)) { $realMpdUrl = $matches[0]; } if (empty($realMpdUrl)) { logMessage($id, "无法提取真实MPD地址", 'ERROR'); return false; } logMessage($id, "提取到真实MPD: {$realMpdUrl}", 'INFO'); $outputDir = HLS_DIR . "/{$id}"; if (!is_dir($outputDir)) { mkdir($outputDir, 0777, true); } $outputM3u8 = $outputDir . "/index.m3u8"; $pidFile = HLS_DIR . "/{$id}.pid"; $runningFile = HLS_DIR . "/{$id}.running"; stopFFmpeg($id, true); $taskLogFile = getTaskLogFile($id); // TVB需要的HTTP头 $headers = "Referer: https://www.tvb.com/\r\n"; $headers .= "Origin: https://www.tvb.com/\r\n"; $headers .= "User-Agent: Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36\r\n"; $decryptionParam = ''; if (!empty($clearkey)) { $clearkey = trim($clearkey); $decryptionParam = ' -decryption_key ' . escapeshellarg($clearkey); logMessage($id, "应用ClearKey: {$clearkey}", 'INFO'); } // 构建映射参数 $mapParams = '-map 0'; if ($videoTrack !== 0 || $audioTrack !== 0) { $mapParams = '-map 0:v:' . $videoTrack . ' -map 0:a:' . $audioTrack; if ($subTrack >= 0) { $mapParams .= ' -map 0:s:' . $subTrack; } } $cmd = FFMPEG_PATH . ' -reconnect 1 -reconnect_at_eof 1 -reconnect_streamed 1 -reconnect_delay_max 5' . ' -timeout 30000000' . ' -headers "' . $headers . '"' . ' -user_agent "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36"' . ' -fflags +genpts+igndts+discardcorrupt' . ' -i ' . escapeshellarg($realMpdUrl) . $decryptionParam . ' ' . $mapParams . ' -c:v libx264 -preset ultrafast -crf 23 -tune zerolatency' . ' -c:a aac -b:a 128k' . ' -f hls -hls_time 6 -hls_list_size 0' . ' -hls_flags delete_segments+discont_start+omit_endlist' . ' -avoid_negative_ts make_zero -copytb 1' . ' -hls_segment_filename ' . escapeshellarg($outputDir . '/segment_%03d.ts') . ' ' . escapeshellarg($outputM3u8) . ' >> ' . escapeshellarg($taskLogFile) . ' 2>&1 & echo $!'; logMessage($id, "执行TVB专用命令...", 'DEBUG'); $pid = trim(shell_exec($cmd)); if (is_numeric($pid) && $pid > 0) { file_put_contents($pidFile, $pid); file_put_contents($runningFile, '1'); logMessage($id, "TVB专用模式启动成功，PID: {$pid}", 'SUCCESS'); sleep(3); if (file_exists($outputM3u8) && filesize($outputM3u8) > 0) { logMessage($id, "M3U8文件已生成", 'SUCCESS'); return true; } return true; } return false; } // ==================== 通用FFmpeg命令构建 ==================== function buildFFmpegCommand($input, $outputDir, $outputM3u8, $mapParams, $decryptionParam = '') { $reconnectParams = ' -reconnect 1 -reconnect_at_eof 1 -reconnect_streamed 1 -reconnect_delay_max 5'; $timeoutParams = ' -timeout 30000000'; $userAgent = ' -user_agent "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36"'; $fflags = ' -fflags +genpts+igndts+discardcorrupt'; $hlsFlags = ' -hls_flags delete_segments+discont_start+omit_endlist'; $hlsTime = ' -hls_time 6'; $hlsListSize = ' -hls_list_size 0'; $hlsSegmentFilename = ' -hls_segment_filename ' . escapeshellarg($outputDir . '/segment_%03d.ts'); $overwriteParams = ' -y'; $cmd = FFMPEG_PATH . $reconnectParams . $timeoutParams . $userAgent . $fflags . $overwriteParams . ' -i ' . escapeshellarg($input) . $decryptionParam . ' ' . $mapParams . ' -c:v libx264 -preset ultrafast -crf 23 -tune zerolatency' . ' -c:a aac -b:a 128k' . ' -f hls' . $hlsTime . $hlsListSize . $hlsFlags . $hlsSegmentFilename . ' -avoid_negative_ts make_zero -copytb 1' . ' ' . escapeshellarg($outputM3u8); return $cmd; } // ==================== FFmpeg推流模式（直接模式） ==================== function startFFmpeg($id, $source, $videoTrack = 0, $audioTrack = 0, $subTrack = -1) { $outputDir = HLS_DIR . "/{$id}"; if (!is_dir($outputDir)) { mkdir($outputDir, 0777, true); } $outputM3u8 = $outputDir . "/index.m3u8"; $pidFile = HLS_DIR . "/{$id}.pid"; $runningFile = HLS_DIR . "/{$id}.running"; stopFFmpeg($id, true); $taskLogFile = getTaskLogFile($id); $mapParams = ''; if ($videoTrack !== 0 || $audioTrack !== 0) { $mapParams = '-map 0:v:' . $videoTrack . ' -map 0:a:' . $audioTrack; if ($subTrack >= 0) { $mapParams .= ' -map 0:s:' . $subTrack; } } else { $mapParams = '-map 0'; } $cmd = buildFFmpegCommand($source, $outputDir, $outputM3u8, $mapParams, ''); $cmd .= ' >> ' . escapeshellarg($taskLogFile) . ' 2>&1 & echo $!'; logMessage($id, "启动FFmpeg直播任务, 源: {$source}", 'START'); $pid = trim(shell_exec($cmd)); if (is_numeric($pid) && $pid > 0) { file_put_contents($pidFile, $pid); file_put_contents($runningFile, '1'); logMessage($id, "FFmpeg进程启动成功，PID: {$pid}", 'SUCCESS'); sleep(2); if (file_exists($outputM3u8) && filesize($outputM3u8) > 0) { logMessage($id, "M3U8文件已生成: {$outputM3u8}", 'SUCCESS'); } else { logMessage($id, "警告：M3U8文件未生成，请检查FFmpeg日志", 'WARN'); } return true; } logMessage($id, "FFmpeg进程启动失败", 'ERROR'); return false; } // ==================== MPD推流模式 ==================== function startMPDToFFmpeg($id, $source, $videoTrack = 0, $audioTrack = 0, $subTrack = -1, $clearkey = '') { logMessage($id, "开始处理源: {$source} | ClearKey: " . ($clearkey ? '已提供' : '无'), 'INFO'); $outputDir = HLS_DIR . "/{$id}"; if (!is_dir($outputDir)) { mkdir($outputDir, 0777, true); } $outputM3u8 = $outputDir . "/index.m3u8"; $pidFile = HLS_DIR . "/{$id}.pid"; $runningFile = HLS_DIR . "/{$id}.running"; $isPhpProxy = strpos($source, '.php') !== false; $realSource = $source; // 如果是 PHP 代理，先获取真实地址 if ($isPhpProxy) { logMessage($id, "检测到 PHP 代理，尝试获取真实地址...", 'INFO'); $debug = []; $realSource = getRealMPDUrl($source, $debug); logMessage($id, "获取结果: " . json_encode($debug), 'INFO'); if (!$realSource) { logMessage($id, "无法获取真实地址，尝试直接拉流模式", 'WARN'); return startDirectStream($id, $source, $videoTrack, $audioTrack, $subTrack, $clearkey); } logMessage($id, "获取到真实地址: {$realSource}", 'INFO'); } stopFFmpeg($id, true); $taskLogFile = getTaskLogFile($id); $decryptionParam = ''; if (!empty($clearkey)) { $clearkey = trim($clearkey); $decryptionParam = ' -decryption_key ' . escapeshellarg($clearkey); logMessage($id, "应用 ClearKey: {$clearkey}", 'INFO'); } $mapParams = ''; if ($videoTrack !== 0 || $audioTrack !== 0) { $mapParams = '-map 0:v:' . $videoTrack . ' -map 0:a:' . $audioTrack; if ($subTrack >= 0) { $mapParams .= ' -map 0:s:' . $subTrack; } } else { $mapParams = '-map 0'; } $cmd = buildFFmpegCommand($realSource, $outputDir, $outputM3u8, $mapParams, $decryptionParam); $cmd .= ' >> ' . escapeshellarg($taskLogFile) . ' 2>&1 & echo $!'; logMessage($id, "执行 FFmpeg 直播命令...", 'DEBUG'); $pid = trim(shell_exec($cmd)); if (is_numeric($pid) && $pid > 0) { file_put_contents($pidFile, $pid); file_put_contents($runningFile, '1'); logMessage($id, "FFmpeg进程启动成功，PID: {$pid}", 'SUCCESS'); for ($i = 0; $i < 10; $i++) { sleep(2); if (file_exists($outputM3u8) && filesize($outputM3u8) > 0) { logMessage($id, "M3U8文件已生成: {$outputM3u8}", 'SUCCESS'); return true; } } return true; } logMessage($id, "FFmpeg进程启动失败", 'ERROR'); return false; } // ==================== 直接拉流模式 ==================== function startDirectStream($id, $source, $videoTrack = 0, $audioTrack = 0, $subTrack = -1, $clearkey = '') { logMessage($id, "尝试直接拉流模式: {$source}", 'INFO'); $outputDir = HLS_DIR . "/{$id}"; if (!is_dir($outputDir)) { mkdir($outputDir, 0777, true); } $outputM3u8 = $outputDir . "/index.m3u8"; $pidFile = HLS_DIR . "/{$id}.pid"; $runningFile = HLS_DIR . "/{$id}.running"; stopFFmpeg($id, true); $taskLogFile = getTaskLogFile($id); $mapParams = ''; if ($videoTrack !== 0 || $audioTrack !== 0) { $mapParams = '-map 0:v:' . $videoTrack . ' -map 0:a:' . $audioTrack; if ($subTrack >= 0) { $mapParams .= ' -map 0:s:' . $subTrack; } } else { $mapParams = '-map 0'; } $decryptionParam = ''; if (!empty($clearkey)) { $clearkey = trim($clearkey); $decryptionParam = ' -decryption_key ' . escapeshellarg($clearkey); } $cmd = buildFFmpegCommand($source, $outputDir, $outputM3u8, $mapParams, $decryptionParam); $cmd .= ' >> ' . escapeshellarg($taskLogFile) . ' 2>&1 & echo $!'; logMessage($id, "执行直接拉流命令...", 'DEBUG'); $pid = trim(shell_exec($cmd)); if (is_numeric($pid) && $pid > 0) { file_put_contents($pidFile, $pid); file_put_contents($runningFile, '1'); logMessage($id, "直接拉流启动成功，PID: {$pid}", 'SUCCESS'); sleep(3); return true; } return false; } function stopFFmpeg($id, $deleteFiles = false) { $pidFile = HLS_DIR . "/{$id}.pid"; $runningFile = HLS_DIR . "/{$id}.running"; if (file_exists($pidFile)) { $pid = trim(file_get_contents($pidFile)); if (!empty($pid) && is_numeric($pid)) { @shell_exec("kill -9 $pid 2>/dev/null"); logMessage($id, "停止FFmpeg进程, PID: {$pid}", 'STOP'); } @unlink($pidFile); } @unlink($runningFile); if ($deleteFiles) { $taskDir = HLS_DIR . "/{$id}"; if (is_dir($taskDir)) { foreach (glob("{$taskDir}/*.ts") as $f) @unlink($f); foreach (glob("{$taskDir}/*.m3u8") as $f) @unlink($f); } @unlink(HLS_DIR . "/{$id}_concat.txt"); } } function isFFmpegRunning($id) { $runningFile = HLS_DIR . "/{$id}.running"; if (!file_exists($runningFile)) { return false; } $outputM3u8 = HLS_DIR . "/{$id}/index.m3u8"; if (file_exists($outputM3u8) && filesize($outputM3u8) > 0) { $mtime = filemtime($outputM3u8); if (time() - $mtime < 60) { return true; } } $pidFile = HLS_DIR . "/{$id}.pid"; if (file_exists($pidFile) && isExecAvailable()) { $pid = trim(file_get_contents($pidFile)); if (!empty($pid) && is_numeric($pid)) { exec("ps -p $pid 2>/dev/null", $output); if (!empty($output)) { return true; } } } return false; } function deleteTaskFiles($id) { stopFFmpeg($id, true); @unlink(HLS_DIR . "/{$id}.m3u8"); @unlink(HLS_DIR . "/{$id}_concat.txt"); @unlink(HLS_DIR . "/{$id}.running"); @unlink(HLS_DIR . "/{$id}.pid"); $taskDir = HLS_DIR . "/{$id}"; if (is_dir($taskDir)) { foreach (glob("{$taskDir}/*.ts") as $f) @unlink($f); foreach (glob("{$taskDir}/*.m3u8") as $f) @unlink($f); @rmdir($taskDir); } $logFile = getTaskLogFile($id); @unlink($logFile); } // 自动维护任务状态 foreach ($tasks as $id => &$task) { if ($task['mode'] === 'mpd_pull' || $task['mode'] === 'direct') { $running = isFFmpegRunning($id); if ($task['status'] === 'running' && !$running) { $task['status'] = 'stopped'; logMessage($id, "检测到进程已停止，更新状态为stopped", 'WARN'); } elseif ($task['status'] !== 'running' && $running) { $task['status'] = 'running'; logMessage($id, "检测到进程运行中，更新状态为running", 'INFO'); } } } unset($task); file_put_contents(TASKS_FILE, json_encode($tasks, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT)); $action = $_GET['action'] ?? ''; // 调试 PHP 代理 if ($action === 'debug_proxy') { $url = $_GET['url'] ?? ''; if (empty($url)) { echo "请提供 URL"; exit; } $ch = curl_init(); curl_setopt($ch, CURLOPT_URL, $url); curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true); curl_setopt($ch, CURLOPT_TIMEOUT, 30); curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0'); $content = curl_exec($ch); $info = curl_getinfo($ch); curl_close($ch); header('Content-Type: text/plain; charset=utf-8'); echo "=== 请求信息 ===\n"; echo "URL: {$url}\n"; echo "HTTP Code: " . $info['http_code'] . "\n"; echo "Content-Type: " . $info['content_type'] . "\n"; echo "Final URL: " . $info['url'] . "\n"; echo "\n=== 返回内容 ===\n"; echo substr($content, 0, 3000); if (strlen($content) > 3000) { echo "\n... (内容过长，已截断)"; } exit; } // 通用流探测 if ($action === 'probe') { $url = trim($_POST['url'] ?? ''); $type = $_POST['type'] ?? 'mpd'; $debug = []; if ($type === 'mpd') { $ret = parseMPD($url, $debug); } else { $ret = probeStream($url, $debug); } $videoOpt = ''; $audioOpt = ''; $subOpt = ''; if ($ret && is_array($ret)) { if (isset($ret['video']) && is_array($ret['video'])) { foreach ($ret['video'] as $k => $v) { $display = isset($v['id']) ? "视频轨道{$k}｜{$v['codecs']}" : "视频轨道{$k}｜" . ($v['codecs'] ?? ''); $videoOpt .= ""; } } if (isset($ret['audio']) && is_array($ret['audio'])) { foreach ($ret['audio'] as $k => $a) { $lang = $a['lang'] ?? ''; $display = "音频轨道{$k}｜" . ($a['codecs'] ?? '') . ($lang ? " [{$lang}]" : ''); $audioOpt .= ""; } } if (isset($ret['subtitle']) && is_array($ret['subtitle'])) { $subOpt = ''; foreach ($ret['subtitle'] as $k => $s) { $lang = $s['lang'] ?? ''; $display = "字幕轨道{$k}｜" . ($s['codecs'] ?? '') . ($lang ? " [{$lang}]" : ''); $subOpt .= ""; } } } $segmentCount = 0; if ($type === 'mpd' && is_array($ret) && isset($ret['segments'])) { $segmentCount = count($ret['segments']); } echo json_encode([ 'video' => $videoOpt, 'audio' => $audioOpt, 'sub' => $subOpt, 'debug' => $debug ?? ['status' => '解析失败'], 'segment_count' => $segmentCount ], JSON_UNESCAPED_UNICODE); exit; } // 添加任务 if ($action === 'add') { $id = preg_replace('/[^a-zA-Z0-9_-]/', '', trim($_POST['id'] ?? '')); $source = trim($_POST['source'] ?? ''); $clearkey = trim($_POST['clearkey'] ?? ''); $mode = $_POST['mode'] ?? 'direct'; $vTrack = intval($_POST['video_track'] ?? 0); $aTrack = intval($_POST['audio_track'] ?? 0); $sTrack = intval($_POST['sub_track'] ?? -1); if (empty($id) || empty($source)) { header('Location:./'); exit; } $m3u8Path = ''; $status = 'running'; $errorMsg = ''; if ($mode === 'mpd_pull') { // 检测是否是TVB流 if (strpos($source, 'tvb.com') !== false || strpos($source, 'filegear-sg.me') !== false) { logMessage($id, "检测到TVB流，使用专用模式", 'INFO'); $result = startTVBStream($id, $source, $vTrack, $aTrack, $sTrack, $clearkey); } else { $result = startMPDToFFmpeg($id, $source, $vTrack, $aTrack, $sTrack, $clearkey); } if ($result) { $m3u8Path = "/hls_output/{$id}/index.m3u8"; } else { $errorMsg = 'MPD解析或FFmpeg启动失败，请查看日志'; $status = 'error'; } } elseif ($mode === 'direct') { $result = startFFmpeg($id, $source, $vTrack, $aTrack, $sTrack); if ($result) { $m3u8Path = "/hls_output/{$id}/index.m3u8"; } else { $errorMsg = 'FFmpeg启动失败，请检查FFmpeg是否安装'; $status = 'error'; } } else { $mpdData = parseMPD($source); if ($mpdData && !empty($mpdData['segments'])) { $m3u8Content = "#EXTM3U\n#EXT-X-VERSION:3\n#EXT-X-TARGETDURATION:10\n#EXT-X-MEDIA-SEQUENCE:0\n"; foreach ($mpdData['segments'] as $i => $seg) { $m3u8Content .= "#EXTINF:5,\n"; $m3u8Content .= $seg . "\n"; } $m3u8Content .= "#EXT-X-ENDLIST\n"; file_put_contents(HLS_DIR . "/{$id}.m3u8", $m3u8Content); $m3u8Path = "/hls_output/{$id}.m3u8"; } else { $errorMsg = 'MPD解析失败或无分片'; $status = 'error'; } } $tasks[$id] = [ 'id' => $id, 'source' => $source, 'clearkey' => $clearkey, 'mode' => $mode, 'video_track' => $vTrack, 'audio_track' => $aTrack, 'sub_track' => $sTrack, 'status' => $status, 'create_time' => time(), 'error_msg' => $errorMsg ]; file_put_contents(TASKS_FILE, json_encode($tasks, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT)); header('Location:./'); exit; } // 获取任务信息 if ($action === 'get_task') { $id = $_GET['id'] ?? ''; if (isset($tasks[$id])) { header('Content-Type: application/json'); echo json_encode($tasks[$id]); } else { echo json_encode(['error' => '任务不存在']); } exit; } // 更新任务 if ($action === 'update') { $id = $_POST['id'] ?? ''; if (isset($tasks[$id]) && is_array($tasks[$id])) { $oldMode = $tasks[$id]['mode']; $newMode = $_POST['mode'] ?? $oldMode; $tasks[$id]['source'] = trim($_POST['source'] ?? ''); $tasks[$id]['clearkey'] = trim($_POST['clearkey'] ?? ''); $tasks[$id]['mode'] = $newMode; $tasks[$id]['video_track'] = intval($_POST['video_track'] ?? 0); $tasks[$id]['audio_track'] = intval($_POST['audio_track'] ?? 0); $tasks[$id]['sub_track'] = intval($_POST['sub_track'] ?? -1); // 保存配置后，如果任务状态是运行中，则用新配置重新启动 if ($tasks[$id]['status'] === 'running') { stopFFmpeg($id, true); if ($newMode === 'mpd_pull') { if (strpos($tasks[$id]['source'], 'tvb.com') !== false || strpos($tasks[$id]['source'], 'filegear-sg.me') !== false) { startTVBStream($id, $tasks[$id]['source'], $tasks[$id]['video_track'], $tasks[$id]['audio_track'], $tasks[$id]['sub_track'], $tasks[$id]['clearkey']); } else { startMPDToFFmpeg($id, $tasks[$id]['source'], $tasks[$id]['video_track'], $tasks[$id]['audio_track'], $tasks[$id]['sub_track'], $tasks[$id]['clearkey']); } } elseif ($newMode === 'direct') { startFFmpeg($id, $tasks[$id]['source'], $tasks[$id]['video_track'], $tasks[$id]['audio_track'], $tasks[$id]['sub_track']); } } file_put_contents(TASKS_FILE, json_encode($tasks, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT)); } header('Location:./'); exit; } // 启动/停止 if ($action === 'toggle') { $id = $_GET['id'] ?? ''; $result = ['success' => false]; if (isset($tasks[$id]) && is_array($tasks[$id])) { if ($tasks[$id]['status'] === 'running') { $tasks[$id]['status'] = 'stopped'; stopFFmpeg($id, true); logMessage($id, "用户手动停止任务", 'STOP'); } else { $tasks[$id]['status'] = 'running'; if ($tasks[$id]['mode'] === 'direct') { startFFmpeg($id, $tasks[$id]['source'], $tasks[$id]['video_track'] ?? 0, $tasks[$id]['audio_track'] ?? 0, $tasks[$id]['sub_track'] ?? -1); } elseif ($tasks[$id]['mode'] === 'mpd_pull') { if (strpos($tasks[$id]['source'], 'tvb.com') !== false || strpos($tasks[$id]['source'], 'filegear-sg.me') !== false) { startTVBStream($id, $tasks[$id]['source'], $tasks[$id]['video_track'] ?? 0, $tasks[$id]['audio_track'] ?? 0, $tasks[$id]['sub_track'] ?? -1, $tasks[$id]['clearkey'] ?? ''); } else { startMPDToFFmpeg($id, $tasks[$id]['source'], $tasks[$id]['video_track'] ?? 0, $tasks[$id]['audio_track'] ?? 0, $tasks[$id]['sub_track'] ?? -1, $tasks[$id]['clearkey'] ?? ''); } } logMessage($id, "用户手动启动任务", 'START'); } file_put_contents(TASKS_FILE, json_encode($tasks, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT)); $result['success'] = true; } header('Content-Type: application/json'); echo json_encode($result); exit; } // 删除 if ($action === 'del') { $id = $_GET['id'] ?? ''; $result = ['success' => false]; if (isset($tasks[$id])) { deleteTaskFiles($id); unset($tasks[$id]); file_put_contents(TASKS_FILE, json_encode($tasks, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT)); $result['success'] = true; } header('Content-Type: application/json'); echo json_encode($result); exit; } // 批量删除 if ($action === 'batch_del') { $ids = json_decode(file_get_contents('php://input'), true)['ids'] ?? []; if (is_array($ids)) { foreach ($ids as $id) { if (isset($tasks[$id])) { deleteTaskFiles($id); unset($tasks[$id]); } } } file_put_contents(TASKS_FILE, json_encode($tasks, JSON_UNESCAPED_UNICODE | JSON_PRETTY_PRINT)); header('Content-Type: application/json'); echo json_encode(['success' => true]); exit; } // 导出 if ($action === 'export') { $baseUrl = 'http://' . $_SERVER['HTTP_HOST'] . rtrim(dirname($_SERVER['SCRIPT_NAME']), '/') . '/' . HLS_DIR . '/'; $txt = ''; if (is_array($tasks)) { foreach ($tasks as $v) { if (is_array($v)) { if ($v['mode'] === 'direct' || $v['mode'] === 'mpd_pull') { $url = $baseUrl . $v['id'] . "/index.m3u8"; } else { $url = $baseUrl . $v['id'] . ".m3u8"; } $txt .= $v['id'] . ' | ' . $url . "\n"; } } } header('Content-Type: text/plain'); header('Content-Disposition: attachment; filename="m3u8_list.txt"'); echo $txt; exit; } // 获取任务日志 if ($action === 'get_task_log') { $id = $_GET['id'] ?? ''; if (!empty($id)) { echo getTaskLog($id); } else { echo "任务ID不能为空"; } exit; } // 清除任务日志 if ($action === 'clear_task_log') { $id = $_GET['id'] ?? ''; $result = ['success' => false]; if (!empty($id)) { $result['success'] = clearTaskLog($id); } header('Content-Type: application/json'); echo json_encode($result); exit; } // 全局日志 if ($action === 'get_logs') { $globalLog = LOG_DIR . "/all.log"; if (file_exists($globalLog)) { $logs = file_get_contents($globalLog); echo nl2br(htmlspecialchars(substr($logs, -5000))); } else { echo "暂无日志"; } exit; } if ($action === 'clear_logs') { clearLogs(); header('Content-Type: application/json'); echo json_encode(['success' => true]); exit; } $baseUrl = 'http://' . $_SERVER['HTTP_HOST'] . rtrim(dirname($_SERVER['SCRIPT_NAME']), '/') . '/' . HLS_DIR . '/'; $exec_available = isExecAvailable(); ?> MPD / FFmpeg 转 HLS 直播系统

操作成功

MPD / FFmpeg 转 HLS 直播系统

系统命令:

自动重连: 已启用

新建任务

🎬 直接推流模式

🔄 MPD解析后推流

📄 MPD静态解析

任务列表

	任务ID	模式	状态	播放链接	操作
	错误
暂无任务