fix(*)

Author: liuchuancong

android/gradle.properties

@@ -1,9 +1,9 @@
 org.gradle.jvmargs=-Xmx8G -XX:MaxMetaspaceSize=4G -XX:ReservedCodeCacheSize=512m -XX:+HeapDumpOnOutOfMemoryError -Dfile.encoding=UTF-8 -Dconsole.encoding=UTF-8
 android.useAndroidX=true
 android.enableJetifier=true
-# systemProp.http.proxyHost=127.0.0.1
-# systemProp.http.proxyPort=7890
-# systemProp.https.proxyHost=127.0.0.1
-# systemProp.https.proxyPort=7890
+systemProp.http.proxyHost=127.0.0.1
+systemProp.http.proxyPort=7890
+systemProp.https.proxyHost=127.0.0.1
+systemProp.https.proxyPort=7890
 # systemProp.socks.proxyHost=127.0.0.1
 # systemProp.socks.proxyPort=7898

lib/recorder/ffmpeg/ffmpeg_command_builder.dart

@@ -20,32 +20,43 @@ class FFmpegCommandBuilder {
     final ua = headers?['user-agent'] ?? defaultUserAgent;
     final headerStr = _buildHeader(headers);
     final normalizedOutputPath = '$outputDir${Platform.pathSeparator}%Y%m%d_%H%M%S.ts';
-    final rwTimeoutMicro = (rwTimeout * 1000000).clamp(0, 2147483647);
-
     final args = <String>[
       '-y',
       '-hide_banner',
       '-loglevel', 'info',
+      // 允许的协议白名单，确保直播流能正常加载
       '-protocol_whitelist', 'httpproxy,udp,rtp,tcp,tls,data,file,http,https,crypto',
+
+      // --- 重连与网络优化 ---
       '-reconnect', '1',
       '-reconnect_streamed', '1',
       '-reconnect_delay_max', '2',
       '-reconnect_at_eof', '1',
-      '-rw_timeout', rwTimeoutMicro.toString(),
+      '-rw_timeout', '${rwTimeout * 1000000}', // 转化为微秒
       '-max_delay', '5000000',
       '-thread_queue_size', threadQueueSize.toString(),
-      '-user_agent', ua,
-      if (headerStr.isNotEmpty) ...['-headers', _quote(headerStr)], //关键：headers
-      '-i', url,
+
+      // --- 身份伪装 ---
+      '-user_agent', _quote(ua),
+      if (headerStr.isNotEmpty) ...['-headers', _quote(headerStr)], // 关键：headers必须包裹在引号内
+      // --- 输入 ---
+      '-i', _quote(url),
+
+      // --- 轨道处理 ---
+      // 使用 copy 模式避免 CPU 占用过高
       '-map', preferBestStream ? '0:v:0' : '0:v',
       '-map', preferBestStream ? '0:a:0' : '0:a',
       '-c', 'copy',
+
+      // --- 分段逻辑 ---
       '-f', 'segment',
       '-segment_format', 'mpegts',
       '-segment_time', segmentTime.toString(),
       '-reset_timestamps', '1',
       '-strftime', '1',
-      normalizedOutputPath,
+
+      // 输出路径 (使用 .ts 格式以防断流导致文件损坏)
+      _quote(normalizedOutputPath),
     ];
 
     return args.join(' ');
@@ -57,6 +68,8 @@ class FFmpegCommandBuilder {
         .where((e) => e.key.toLowerCase() != 'user-agent')
         .map((e) => '${e.key}: ${e.value}')
         .join('\r\n');
+
+    // FFmpeg 要求 headers 末尾也必须有换行符
     return lines.isEmpty ? '' : '$lines\r\n';
   }
 }

lib/recorder/services/ffmpeg_service.dart

@@ -62,12 +62,18 @@ class FFmpegService {
     });
     ffempgSession.setCompleteCallback((completedSession) {
       final code = completedSession.getReturnCode();
-      final success = ReturnCode.isSuccess(code);
-      log('FFmpeg complete => taskId: $taskId;successCode: $code ');
+      bool isNormalExit = [
+        0, // 正常完成
+        255, // 手动停止
+        -1094995529, // 断流/无数据
+        -1077350400, // 超时/网络断开
+        -1005272104, // 读取中断
+      ].contains(code);
+      log('FFmpeg complete => taskId: $taskId; code: $code ');
       onEvent(
         FFmpegEvent(
           taskId: taskId,
-          type: success ? FFmpegEventType.complete : FFmpegEventType.error,
+          type: isNormalExit ? FFmpegEventType.complete : FFmpegEventType.error,
           data: {"code": code},
         ),
       );