feat: 修改代码冲突

lib/app/utils/kr_latency_tester.dart

@@ -1,127 +1,151 @@
 import 'dart:io';
 import 'dart:async';
-import 'package:kaer_with_panels/app/utils/kr_log_util.dart';
+import 'kr_log_util.dart';
 
-/// 延迟测试工具类
-/// 提供真实的 TCP 连接延迟测试功能
+/// 真正的节点延迟测试工具
 class KRLatencyTester {
-  /// 测试单个节点的延迟
-  /// 
-  /// 参数:
-  ///   - host: 主机地址
-  ///   - port: 端口号
-  ///   - timeout: 超时时间（毫秒）
-  /// 
-  /// 返回:
-  ///   - 延迟时间（毫秒），如果失败返回 65535
-  static Future<int> testNode({
+  /// TCP 连接测试延迟（真实测试）
+  /// 返回延迟毫秒数，失败返回 65535
+  static Future<int> testTcpLatency({
     required String host,
     required int port,
-    int timeout = 5000,
+    Duration timeout = const Duration(seconds: 5),
   }) async {
+    Socket? socket;
+    final stopwatch = Stopwatch();
+
     try {
-      final stopwatch = Stopwatch()..start();
-      
-      final socket = await Socket.connect(
+      KRLogUtil.kr_i('🔌 开始测试: $host:$port', tag: 'LatencyTester');
+
+      stopwatch.start();
+
+      // 尝试 TCP 连接
+      socket = await Socket.connect(
         host,
         port,
-        timeout: Duration(milliseconds: timeout),
-      ).timeout(Duration(milliseconds: timeout));
-      
+        timeout: timeout,
+      );
+
       stopwatch.stop();
-      
-      // 立即关闭连接
-      await socket.close();
-      socket.destroy();
-      
+
       final latency = stopwatch.elapsedMilliseconds;
-      KRLogUtil.kr_i('✅ 延迟测试成功: $host:$port = ${latency}ms', tag: 'KRLatencyTester');
-      
+
+      KRLogUtil.kr_i('✅ 测试成功: $host:$port - ${latency}ms', tag: 'LatencyTester');
+
       return latency;
+
+    } on SocketException catch (e) {
+      stopwatch.stop();
+      KRLogUtil.kr_w('❌ 连接失败: $host:$port - ${e.message}', tag: 'LatencyTester');
+      return 65535;
+
+    } on TimeoutException catch (e) {
+      stopwatch.stop();
+      KRLogUtil.kr_w('⏱️ 连接超时: $host:$port - $e', tag: 'LatencyTester');
+      return 65535;
+
     } catch (e) {
-      KRLogUtil.kr_w('❌ 延迟测试失败: $host:$port - $e', tag: 'KRLatencyTester');
-      return 65535; // 测试失败返回最大值
+      stopwatch.stop();
+      KRLogUtil.kr_e('❌ 测试异常: $host:$port - $e', tag: 'LatencyTester');
+      return 65535;
+
+    } finally {
+      // 确保关闭连接
+      try {
+        await socket?.close();
+      } catch (e) {
+        // 忽略关闭错误
+      }
     }
   }
 
-  /// 批量测试多个节点的延迟
-  /// 
-  /// 参数:
-  ///   - nodes: 节点列表，格式为 [{"host": "example.com", "port": 443}]
-  ///   - concurrency: 并发数量
-  ///   - timeout: 超时时间（毫秒）
-  /// 
-  /// 返回:
-  ///   - 测试结果映射，键为 "host:port"，值为延迟时间
+  /// 批量测试多个节点延迟（并发测试）
+  /// 返回 Map<节点tag, 延迟ms>
   static Future<Map<String, int>> testMultipleNodes({
     required List<MapEntry<String, SocketAddress>> nodes,
-    int concurrency = 10,
-    int timeout = 5000,
+    int concurrency = 10,  // 并发数
+    Duration timeout = const Duration(seconds: 5),
   }) async {
     final results = <String, int>{};
-    final semaphore = Completer<void>();
-    var activeCount = 0;
-    var completedCount = 0;
+    final List<List<MapEntry<String, SocketAddress>>> batches = [];
 
-    KRLogUtil.kr_i('🚀 开始批量延迟测试，共 ${nodes.length} 个节点，并发数: $concurrency', tag: 'KRLatencyTester');
+    // 分批处理
+    for (int i = 0; i < nodes.length; i += concurrency) {
+      batches.add(
+        nodes.sublist(i, i + concurrency > nodes.length ? nodes.length : i + concurrency)
+      );
+    }
 
-    Future<void> processNode(MapEntry<String, SocketAddress> node) async {
-      try {
-        final host = node.value.address;
-        final port = node.value.port;
-        final key = node.key;
-        
-        final latency = await testNode(
-          host: host,
-          port: port,
+    KRLogUtil.kr_i('📊 开始批量测试: ${nodes.length} 个节点，分 ${batches.length} 批，每批 $concurrency 个', tag: 'LatencyTester');
+
+    int completedCount = 0;
+
+    // 逐批测试
+    for (int batchIndex = 0; batchIndex < batches.length; batchIndex++) {
+      final batch = batches[batchIndex];
+
+      KRLogUtil.kr_i('📦 测试第 ${batchIndex + 1}/${batches.length} 批（${batch.length} 个节点）', tag: 'LatencyTester');
+
+      // 并发测试当前批次
+      final futures = batch.map((node) async {
+        final tag = node.key;
+        final address = node.value;
+
+        final latency = await testTcpLatency(
+          host: address.host,
+          port: address.port,
           timeout: timeout,
         );
-        
-        results[key] = latency;
-      } catch (e) {
-        results[node.key] = 65535;
-        KRLogUtil.kr_e('❌ 节点测试异常: ${node.key} - $e', tag: 'KRLatencyTester');
-      } finally {
+
         completedCount++;
-        activeCount--;
-        
-        if (completedCount >= nodes.length) {
-          semaphore.complete();
+
+        if (completedCount % 5 == 0 || completedCount == nodes.length) {
+          KRLogUtil.kr_i('📈 测试进度: $completedCount/${nodes.length}', tag: 'LatencyTester');
         }
-      }
-    }
 
-    // 分批处理节点
-    for (var i = 0; i < nodes.length; i += concurrency) {
-      final batch = nodes.skip(i).take(concurrency);
-      
-      for (final node in batch) {
-        activeCount++;
-        processNode(node);
-      }
-      
+        return MapEntry(tag, latency);
+      }).toList();
+
       // 等待当前批次完成
-      if (i + concurrency < nodes.length) {
-        await Future.delayed(Duration(milliseconds: 100));
+      final batchResults = await Future.wait(futures);
+
+      // 收集结果
+      for (final result in batchResults) {
+        results[result.key] = result.value;
+      }
+    }
+
+    // 统计结果
+    final successCount = results.values.where((latency) => latency < 65535).length;
+    final failCount = results.length - successCount;
+
+    KRLogUtil.kr_i('✅ 批量测试完成', tag: 'LatencyTester');
+    KRLogUtil.kr_i('📊 成功: $successCount, 失败: $failCount', tag: 'LatencyTester');
+
+    // 显示延迟最低的前3个
+    final successNodes = results.entries
+        .where((e) => e.value < 65535)
+        .toList()
+      ..sort((a, b) => a.value.compareTo(b.value));
+
+    if (successNodes.isNotEmpty) {
+      KRLogUtil.kr_i('🏆 延迟最低的前3个节点:', tag: 'LatencyTester');
+      for (int i = 0; i < 3 && i < successNodes.length; i++) {
+        KRLogUtil.kr_i('  ${i + 1}. ${successNodes[i].key}: ${successNodes[i].value}ms', tag: 'LatencyTester');
       }
     }
 
-    // 等待所有任务完成
-    await semaphore.future;
-    
-    KRLogUtil.kr_i('✅ 批量延迟测试完成，成功: ${results.length} 个', tag: 'KRLatencyTester');
     return results;
   }
 }
 
-/// Socket 地址类
-/// 表示网络地址和端口的组合
+/// 节点地址信息
 class SocketAddress {
-  final String address;
+  final String host;
   final int port;
 
-  SocketAddress(this.address, this.port);
+  SocketAddress(this.host, this.port);
 
   @override
-  String toString() => '$address:$port';
-}
+  String toString() => '$host:$port';
+}