1.0.4

.metadata

@@ -15,9 +15,6 @@ migration:
     - platform: root
       create_revision: c23637390482d4cf9598c3ce3f2be31aa7332daf
       base_revision: c23637390482d4cf9598c3ce3f2be31aa7332daf
-    - platform: web
-      create_revision: c23637390482d4cf9598c3ce3f2be31aa7332daf
-      base_revision: c23637390482d4cf9598c3ce3f2be31aa7332daf
 
   # User provided section
 

.vscode/launch.json

@@ -4,6 +4,12 @@
     // 欲了解更多信息，请访问: https://go.microsoft.com/fwlink/?linkid=830387
     "version": "0.2.0",
     "configurations": [
+        {
+            "name": "Flutter",
+            "request": "launch",
+            "type": "dart",
+            "flutterMode": "profile"
+          },
         {
             "name": "Flutter Run",
             "request": "launch",

lib/app.dart

@@ -6,7 +6,6 @@ import 'dart:io';
 import 'screens/Home.dart';
 import 'config/themeconfiguration.dart';
 import 'config/app_config.dart';
-import 'package:astral/utils/up.dart'; // 添加这行导入
 
 // 定义应用程序的主要StatefulWidget
 class MyApp extends StatefulWidget {
@@ -39,17 +38,6 @@ class _MyAppState extends State<MyApp> {
 
     // 初始化系统托盘
     initSystemTray();
-
-    // 添加版本检查（在下一帧执行确保context可用）
-    Future.microtask(() {
-      final updateChecker = UpdateChecker(
-        owner: 'ldoubil',
-        repo: 'astral',
-      );
-      if (mounted) {
-        updateChecker.scheckForUpdates(context);
-      }
-    });
   }
 
   // 初始化系统托盘

lib/config/app_config.dart

@@ -28,8 +28,13 @@ class AppConfig {
           'seedColor': Colors.blue.value,
         },
         'server': {
-          'list': ['public.easytier.cn:11010'],
-          'current': 'public.easytier.cn:11010',
+          'list': [
+            {
+              'url': 'public.easytier.cn:11010',
+              'name': '公共服务器',
+              'selected': true,
+            }
+          ],
         },
         'room': {
           'name': 'kevin',
@@ -44,6 +49,7 @@ class AppConfig {
         },
         'system': {
           'closeToTray': true,
+          'enablePing': true, // 添加全局ping开关默认配置
         },
       },
     );
@@ -78,27 +84,27 @@ class AppConfig {
   }
 
   // 服务器列表设置
-  List<String> get serverList {
-    final List? value = _configManager.get<List>('server.list');
-    return value?.cast<String>() ?? ['public.easytier.cn:11010'];
+  List<Map<String, dynamic>> get serverList {
+    final dynamic value = _configManager.get('server.list');
+    if (value is List) {
+      return List<Map<String, dynamic>>.from(
+        value.map((item) => Map<String, dynamic>.from(item as Map)),
+      );
+    }
+    return [
+      {
+        'url': 'public.easytier.cn:11010',
+        'name': '公共服务器',
+        'selected': true,
+      }
+    ];
   }
 
-  Future<void> setServerList(List<String> servers) async {
+  Future<void> setServerList(List<Map<String, dynamic>> servers) async {
     _configManager.set('server.list', servers);
     await _configManager.save();
   }
 
-  // 当前选中的服务器设置
-  String get currentServer {
-    return _configManager.get<String>('server.current') ??
-        'public.easytier.cn:11010';
-  }
-
-  Future<void> setCurrentServer(String server) async {
-    _configManager.set('server.current', server);
-    await _configManager.save();
-  }
-
   // 房间名设置
   String get roomName {
     return _configManager.get<String>('room.name') ?? 'kevin';
@@ -158,4 +164,14 @@ class AppConfig {
     _configManager.set('network.dynamicIP', enabled);
     await _configManager.save();
   }
+
+  // 全局ping开关设置
+  bool get enablePing {
+    return _configManager.get<bool>('system.enablePing') ?? true;
+  }
+
+  Future<void> setEnablePing(bool enabled) async {
+    _configManager.set('system.enablePing', enabled);
+    await _configManager.save();
+  }
 }

lib/config/cof.dart

@@ -25,7 +25,10 @@ class ConfigManager {
       final yamlMap = loadYaml(content);
       _config = _mergeConfigs(_convertYaml(yamlMap));
     } catch (e) {
-      throw Exception('配置文件解析失败: $e');
+      // 提供更详细的错误信息并使用默认配置
+      print('配置文件解析失败: $e');
+      print('将使用默认配置继续运行。请检查配置文件格式是否正确。');
+      _config = Map.from(defaultConfig);
     }
   }
 
@@ -61,7 +64,15 @@ class ConfigManager {
       current = current.putIfAbsent(key, () => <String, dynamic>{});
     }
 
-    current[keys.last] = value;
+    // 类型转换确保值类型兼容性
+    if (value is Map<String, dynamic>) {
+      current[keys.last] = Map<String, Object>.from(value);
+    } else if (value is List<Map<String, dynamic>>) {
+      current[keys.last] =
+          value.map((e) => Map<String, Object>.from(e)).toList();
+    } else {
+      current[keys.last] = value;
+    }
   }
 
   /// 合并用户配置与默认配置

lib/screens/Home.dart

@@ -1,3 +1,4 @@
+import 'package:astral/utils/up.dart';
 import 'package:flutter/material.dart';
 import 'package:window_manager/window_manager.dart';
 import '../widgets/window_control_buttons.dart';
@@ -46,6 +47,17 @@ class _MainScreenState extends State<MainScreen>
       duration: const Duration(seconds: 3),
       vsync: this,
     )..repeat();
+
+    // 添加异步更新检查（推荐方式）
+    WidgetsBinding.instance.addPostFrameCallback((_) {
+      final updateChecker = UpdateChecker(
+        owner: 'ldoubil',
+        repo: 'astral',
+      );
+      if (mounted) {
+        updateChecker.scheckForUpdates(context);
+      }
+    });
   }
 
   @override
@@ -229,7 +241,8 @@ class PageKeepAlive extends StatefulWidget {
   State<PageKeepAlive> createState() => _PageKeepAliveState();
 }
 
-class _PageKeepAliveState extends State<PageKeepAlive> with AutomaticKeepAliveClientMixin {
+class _PageKeepAliveState extends State<PageKeepAlive>
+    with AutomaticKeepAliveClientMixin {
   @override
   bool get wantKeepAlive => true;
 

lib/screens/about.dart

@@ -2,35 +2,11 @@
 
 import 'package:flutter/material.dart';
 import 'package:url_launcher/url_launcher.dart';
-import 'dart:math' as math;
 import 'package:astral/utils/app_info.dart';
 
-class InfoPage extends StatefulWidget {
+class InfoPage extends StatelessWidget {
   const InfoPage({super.key});
 
-  @override
-  State<InfoPage> createState() => _InfoPageState();
-}
-
-class _InfoPageState extends State<InfoPage>
-    with SingleTickerProviderStateMixin {
-  late AnimationController _controller;
-
-  @override
-  void initState() {
-    super.initState();
-    _controller = AnimationController(
-      duration: const Duration(seconds: 10),
-      vsync: this,
-    )..repeat();
-  }
-
-  @override
-  void dispose() {
-    _controller.dispose();
-    super.dispose();
-  }
-
   @override
   Widget build(BuildContext context) {
     return SingleChildScrollView(
@@ -40,156 +16,95 @@ class _InfoPageState extends State<InfoPage>
           child: Column(
             mainAxisAlignment: MainAxisAlignment.center,
             children: [
-              // 旋转的图标效果
-              AnimatedBuilder(
-                animation: _controller,
-                builder: (_, child) {
-                  return Transform.rotate(
-                    angle: _controller.value * 2 * math.pi,
-                    child: Container(
-                      height: 110,
-                      width: 110,
-                      decoration: BoxDecoration(
-                        shape: BoxShape.circle,
-                        gradient: SweepGradient(
-                          colors: [
-                            Theme.of(context).colorScheme.primary,
-                            Theme.of(context).colorScheme.secondary,
-                            Theme.of(context).colorScheme.tertiary,
-                            Theme.of(context).colorScheme.primary,
-                          ],
-                          stops: const [0.0, 0.3, 0.6, 1.0],
-                          transform:
-                              GradientRotation(_controller.value * 2 * math.pi),
-                        ),
-                        boxShadow: [
-                          BoxShadow(
-                            color: Theme.of(context)
-                                .colorScheme
-                                .primary
-                                .withOpacity(0.5),
-                            blurRadius: 15,
-                            spreadRadius: 1,
-                          ),
-                        ],
-                      ),
-                      child: Center(
-                        child: Icon(
-                          Icons.games,
-                          size: 50,
-                          color: Theme.of(context).colorScheme.onPrimary,
-                        ),
-                      ),
+              // 静态图标
+              Container(
+                height: 110,
+                width: 110,
+                decoration: BoxDecoration(
+                  shape: BoxShape.circle,
+                  color: Theme.of(context).colorScheme.primary,
+                  boxShadow: [
+                    BoxShadow(
+                      color: Theme.of(context)
+                          .colorScheme
+                          .primary
+                          .withOpacity(0.5),
+                      blurRadius: 15,
+                      spreadRadius: 1,
                     ),
-                  );
-                },
+                  ],
+                ),
+                child: Center(
+                  child: Icon(
+                    Icons.games,
+                    size: 50,
+                    color: Theme.of(context).colorScheme.onPrimary,
+                  ),
+                ),
               ),
               const SizedBox(height: 20),
-              // 应用名称添加渐变效果
-              ShaderMask(
-                shaderCallback: (bounds) => LinearGradient(
-                  colors: [
-                    Theme.of(context).colorScheme.primary,
-                    Theme.of(context).colorScheme.tertiary,
-                  ],
-                ).createShader(bounds),
-                child: Text(
-                  'ASTRAL',
-                  style: Theme.of(context).textTheme.headlineMedium?.copyWith(
-                        fontWeight: FontWeight.bold,
-                        letterSpacing: 2.0,
-                      ),
-                ),
+              // 应用名称
+              Text(
+                'ASTRAL',
+                style: Theme.of(context).textTheme.headlineMedium?.copyWith(
+                      fontWeight: FontWeight.bold,
+                      letterSpacing: 2.0,
+                      color: Theme.of(context).colorScheme.primary,
+                    ),
               ),
               const SizedBox(height: 8),
-              // 版本号添加动画效果
-              TweenAnimationBuilder<double>(
-                tween: Tween<double>(begin: 0, end: 1),
-                duration: const Duration(milliseconds: 800),
-                builder: (context, value, child) {
-                  return Opacity(
-                    opacity: value,
-                    child: Transform.translate(
-                      offset: Offset(0, 20 * (1 - value)),
-                      child: child,
-                    ),
-                  );
-                },
-                child: Text(
-                  AppInfoUtil.getVersion(),
-                  style: Theme.of(context).textTheme.bodyLarge,
-                ),
+              // 版本号
+              Text(
+                AppInfoUtil.getVersion(),
+                style: Theme.of(context).textTheme.bodyLarge,
               ),
               const SizedBox(height: 20),
-              // 卡片添加动画和阴影效果
-              _buildAnimatedCard(
+              // 静态卡片
+              _buildCard(
                 context,
                 '特别鸣谢',
                 '特别感谢EasyTier作者所做的工作和帮助，为本项目提供了重要的技术支持。如果您有功能需求或遇到bug，欢迎加入我们的QQ群获取帮助和了解最新动态。',
                 Icons.favorite,
-                Colors.red,
-                delay: 200,
               ),
               // 合并后的卡片
 
               const SizedBox(height: 30),
-              // 按钮添加动画效果
-              TweenAnimationBuilder<double>(
-                tween: Tween<double>(begin: 0, end: 1),
-                duration: const Duration(milliseconds: 1000),
-                curve: Curves.elasticOut,
-                builder: (context, value, child) {
-                  return Transform.scale(
-                    scale: value,
-                    child: child,
-                  );
-                },
-                child: ElevatedButton.icon(
-                  icon: const Icon(Icons.group_add),
-                  label: const Text('加入QQ群'),
-                  style: ElevatedButton.styleFrom(
-                    padding: const EdgeInsets.symmetric(
-                        horizontal: 24, vertical: 12),
-                    shape: RoundedRectangleBorder(
-                      borderRadius: BorderRadius.circular(30),
-                    ),
-                    elevation: 5,
+              // 静态按钮
+              ElevatedButton.icon(
+                icon: const Icon(Icons.group_add),
+                label: const Text('加入QQ群'),
+                style: ElevatedButton.styleFrom(
+                  padding:
+                      const EdgeInsets.symmetric(horizontal: 24, vertical: 12),
+                  shape: RoundedRectangleBorder(
+                    borderRadius: BorderRadius.circular(30),
                   ),
-                  onPressed: () async {
-                    final url = 'https://qm.qq.com/q/ErscyNPTzO';
-                    if (await canLaunchUrl(Uri.parse(url))) {
-                      await launchUrl(Uri.parse(url));
-                    } else {
-                      // 无法打开链接时显示提示
-                      if (context.mounted) {
-                        ScaffoldMessenger.of(context).showSnackBar(
-                          const SnackBar(content: Text('无法打开QQ群链接')),
-                        );
-                      }
-                    }
-                  },
+                  elevation: 5,
                 ),
+                onPressed: () async {
+                  final url = 'https://qm.qq.com/q/ErscyNPTzO';
+                  if (await canLaunchUrl(Uri.parse(url))) {
+                    await launchUrl(Uri.parse(url));
+                  } else {
+                    // 无法打开链接时显示提示
+                    if (context.mounted) {
+                      ScaffoldMessenger.of(context).showSnackBar(
+                        const SnackBar(content: Text('无法打开QQ群链接')),
+                      );
+                    }
+                  }
+                },
               ),
               const SizedBox(height: 20),
-              // 添加版权信息
-              TweenAnimationBuilder<double>(
-                tween: Tween<double>(begin: 0, end: 1),
-                duration: const Duration(milliseconds: 1200),
-                builder: (context, value, child) {
-                  return Opacity(
-                    opacity: value,
-                    child: child,
-                  );
-                },
-                child: Text(
-                  '© ${DateTime.now().year} ASTRAL Team',
-                  style: Theme.of(context).textTheme.bodySmall?.copyWith(
-                        color: Theme.of(context)
-                            .colorScheme
-                            .onSurface
-                            .withOpacity(0.6),
-                      ),
-                ),
+              // 版权信息
+              Text(
+                '© ${DateTime.now().year} ASTRAL Team',
+                style: Theme.of(context).textTheme.bodySmall?.copyWith(
+                      color: Theme.of(context)
+                          .colorScheme
+                          .onSurface
+                          .withOpacity(0.6),
+                    ),
               ),
             ],
           ),
@@ -198,129 +113,55 @@ class _InfoPageState extends State<InfoPage>
     );
   }
 
-  Widget _buildAnimatedCard(BuildContext context, String title, String content,
-      IconData icon, Color iconColor,
-      {int delay = 0}) {
-    // 根据当前主题调整颜色
-    final isDarkMode = Theme.of(context).brightness == Brightness.dark;
-    final cardColor = Theme.of(context).cardColor;
-    final textColor = Theme.of(context).textTheme.bodyMedium?.color;
-
-    return TweenAnimationBuilder<double>(
-      tween: Tween<double>(begin: 0, end: 1),
-      duration: Duration(milliseconds: 800 + delay),
-      curve: Curves.easeOutBack,
-      builder: (context, value, child) {
-        // 确保 opacity 值在有效范围内 (0.0 到 1.0)
-        final safeOpacity = value.clamp(0.0, 1.0);
-        return Opacity(
-          opacity: safeOpacity,
-          child: Transform.translate(
-            offset: Offset(100 * (1 - value), 0),
-            child: child,
-          ),
-        );
-      },
-      child: Card(
-        elevation: 8,
-        shadowColor: iconColor.withOpacity(isDarkMode ? 0.3 : 0.4),
-        shape: RoundedRectangleBorder(
-          borderRadius: BorderRadius.circular(16),
-        ),
-        child: Container(
-          decoration: BoxDecoration(
-            borderRadius: BorderRadius.circular(16),
-            gradient: LinearGradient(
-              begin: Alignment.topLeft,
-              end: Alignment.bottomRight,
-              colors: [
-                cardColor,
-                isDarkMode
-                    ? cardColor.withOpacity(0.9).withBlue(cardColor.blue + 5)
-                    : iconColor.withOpacity(0.05),
-                cardColor,
-              ],
-              stops: const [0.0, 0.5, 1.0],
-            ),
-            boxShadow: [
-              BoxShadow(
-                color: iconColor.withOpacity(isDarkMode ? 0.05 : 0.1),
-                blurRadius: 10,
-                spreadRadius: -5,
-                offset: const Offset(0, 5),
+  Widget _buildCard(
+    BuildContext context,
+    String title,
+    String content,
+    IconData icon,
+  ) {
+    return Card(
+      elevation: 2,
+      shape: RoundedRectangleBorder(
+        borderRadius: BorderRadius.circular(16),
+      ),
+      child: Padding(
+        padding: const EdgeInsets.all(16.0),
+        child: Row(
+          crossAxisAlignment: CrossAxisAlignment.start,
+          children: [
+            Container(
+              padding: const EdgeInsets.all(12),
+              decoration: BoxDecoration(
+                color: Theme.of(context).colorScheme.primary.withOpacity(0.1),
+                shape: BoxShape.circle,
+              ),
+              child: Icon(
+                icon,
+                color: Theme.of(context).colorScheme.primary,
+                size: 30,
               ),
-            ],
-          ),
-          child: Padding(
-            padding: const EdgeInsets.all(16.0),
-            child: Row(
-              crossAxisAlignment: CrossAxisAlignment.start,
-              children: [
-                // 左侧图标 - 适配深色模式
-                Container(
-                  padding: const EdgeInsets.all(12),
-                  decoration: BoxDecoration(
-                    color: iconColor.withOpacity(isDarkMode ? 0.2 : 0.15),
-                    shape: BoxShape.circle,
-                    boxShadow: [
-                      BoxShadow(
-                        color: iconColor.withOpacity(isDarkMode ? 0.15 : 0.2),
-                        blurRadius: isDarkMode ? 6 : 8,
-                        spreadRadius: isDarkMode ? 0 : 1,
-                      ),
-                    ],
-                    gradient: RadialGradient(
-                      colors: [
-                        iconColor.withOpacity(isDarkMode ? 0.8 : 0.7),
-                        iconColor.withOpacity(isDarkMode ? 0.2 : 0.1),
-                      ],
-                      stops: const [0.0, 1.0],
-                      radius: 0.8,
-                    ),
-                  ),
-                  child: Icon(
-                    icon,
-                    color: Colors.white,
-                    size: 30,
-                  ),
-                ),
-                const SizedBox(width: 16),
-                // 右侧内容 - 适配深色模式
-                Expanded(
-                  child: Column(
-                    crossAxisAlignment: CrossAxisAlignment.start,
-                    children: [
-                      Text(
-                        title,
-                        style: Theme.of(context).textTheme.titleLarge?.copyWith(
-                              fontWeight: FontWeight.bold,
-                              letterSpacing: 1.2,
-                              color:
-                                  iconColor.withOpacity(isDarkMode ? 0.9 : 0.8),
-                            ),
-                      ),
-                      const SizedBox(height: 8),
-                      Divider(
-                        color: iconColor.withOpacity(isDarkMode ? 0.4 : 0.3),
-                        thickness: 1.5,
-                        endIndent: 60,
-                      ),
-                      const SizedBox(height: 8),
-                      Text(
-                        content,
-                        style: Theme.of(context).textTheme.bodyMedium?.copyWith(
-                              height: 1.5,
-                              letterSpacing: 0.5,
-                              color: textColor
-                                  ?.withOpacity(isDarkMode ? 0.9 : 1.0),
-                            ),
-                      ),
-                    ],
-                  ),
-                ),
-              ],
             ),
-          ),
+            const SizedBox(width: 16),
+            Expanded(
+              child: Column(
+                crossAxisAlignment: CrossAxisAlignment.start,
+                children: [
+                  Text(
+                    title,
+                    style: Theme.of(context).textTheme.titleLarge?.copyWith(
+                          fontWeight: FontWeight.bold,
+                          color: Theme.of(context).colorScheme.primary,
+                        ),
+                  ),
+                  const SizedBox(height: 8),
+                  Text(
+                    content,
+                    style: Theme.of(context).textTheme.bodyMedium,
+                  ),
+                ],
+              ),
+            ),
+          ],
         ),
       ),
     );

lib/screens/front.dart

@@ -52,8 +52,7 @@ class HomePage extends StatefulWidget {
 }
 
 class _HomePageState extends State<HomePage> {
-  // 定义状态枚举
-
+  int connectionTimeoutCounter = 0;
   // 当前连接状态
   ConnectionState _connectionState = ConnectionState.notStarted;
 
@@ -74,7 +73,7 @@ class _HomePageState extends State<HomePage> {
 
   bool _isAutoIP = true; // 只用于控制IP自动/手动模式
 
-  String Serverip = "";
+  List<String> Serverip = [""];
   int _uploadBytes = 0;
   int _downloadBytes = 0;
   int _lastUploadBytes = 0;
@@ -87,25 +86,105 @@ class _HomePageState extends State<HomePage> {
   late final TextEditingController _roomPasswordController;
   late final TextEditingController _usernameController;
   late final TextEditingController _virtualIPController;
+  // 添加FocusNode来监听焦点变化
+  late final FocusNode _virtualIPFocusNode;
+  late final FocusNode _usernameControllerFocusNode;
+  late final FocusNode _roomNameControllerFocusNode;
+  late final FocusNode _roomPasswordControllerFocusNode;
 
   @override
   void initState() {
     super.initState();
-    // 初始化 TextEditingController
+    // 初始化所有TextEditingController
     _roomNameController = TextEditingController(text: roomName);
     _roomPasswordController = TextEditingController(text: roomPassword);
     _usernameController = TextEditingController(text: username);
-    _virtualIPController = TextEditingController(text: publicIP);
+    _virtualIPController = TextEditingController(text: publicIP); // 添加缺失的初始化
 
-    // 修改卡片构建器列表，添加版本信息卡片
+    // 初始化FocusNode并添加监听器
+    _virtualIPFocusNode = FocusNode();
+    _virtualIPFocusNode.addListener(_onVirtualIPFocusChange);
+
+    // 初始化用户名、房间名和密码的FocusNode
+    _usernameControllerFocusNode = FocusNode();
+    _usernameControllerFocusNode.addListener(_onUsernameFocusChange);
+
+    _roomNameControllerFocusNode = FocusNode();
+    _roomNameControllerFocusNode.addListener(_onRoomNameFocusChange);
+
+    _roomPasswordControllerFocusNode = FocusNode();
+    _roomPasswordControllerFocusNode.addListener(_onRoomPasswordFocusChange);
+
+    // 修改卡片构建器列表，添加服务器列表卡片
     _cardBuilders = [
-      _buildNetworkStatusCard, // 网络状态卡片
-      _buildUserInfoCard, // 用户信息卡片
-      _buildRoomInfoCard, // 房间信息卡片
-      _buildVersionInfoCard, // 新增版本信息卡片
+      _buildNetworkStatusCard,
+      _buildUserInfoCard,
+      _buildRoomInfoCard,
+      _buildServerListCard,
+      _buildVersionInfoCard,
     ];
   }
 
+  // 添加焦点变化监听方法
+  void _onVirtualIPFocusChange() {
+    if (!_virtualIPFocusNode.hasFocus && !_isAutoIP) {
+      // 当失去焦点且不是自动IP模式时更新值
+      Provider.of<KM>(context, listen: false).virtualIP =
+          _virtualIPController.text;
+    }
+  }
+
+  // 添加用户名焦点变化监听方法
+  void _onUsernameFocusChange() {
+    if (!_usernameControllerFocusNode.hasFocus) {
+      Provider.of<KM>(context, listen: false).username =
+          _usernameController.text;
+    }
+  }
+
+  // 添加房间名焦点变化监听方法
+  void _onRoomNameFocusChange() {
+    if (!_roomNameControllerFocusNode.hasFocus) {
+      Provider.of<KM>(context, listen: false).roomName =
+          _roomNameController.text;
+    }
+  }
+
+  // 添加房间密码焦点变化监听方法
+  void _onRoomPasswordFocusChange() {
+    if (!_roomPasswordControllerFocusNode.hasFocus) {
+      Provider.of<KM>(context, listen: false).roomPassword =
+          _roomPasswordController.text;
+    }
+  }
+
+  @override
+  void dispose() {
+    // 取消所有计时器
+    timer?.cancel();
+    timer = null;
+
+    // 释放所有控制器和焦点节点
+    _roomNameController.dispose();
+    _roomPasswordController.dispose();
+    _usernameController.dispose();
+    _virtualIPController.dispose();
+
+    _virtualIPFocusNode.removeListener(_onVirtualIPFocusChange);
+    _virtualIPFocusNode.dispose();
+
+    _usernameControllerFocusNode.removeListener(_onUsernameFocusChange);
+    _usernameControllerFocusNode.dispose();
+
+    _roomNameControllerFocusNode.removeListener(_onRoomNameFocusChange);
+    _roomNameControllerFocusNode.dispose();
+
+    _roomPasswordControllerFocusNode.removeListener(_onRoomPasswordFocusChange);
+    _roomPasswordControllerFocusNode.dispose();
+
+    super.dispose();
+  }
+
   void toggleRunning() {
     final km = Provider.of<KM>(context, listen: false);
     setState(() {
@@ -121,9 +200,6 @@ class _HomePageState extends State<HomePage> {
             roomPassword: roomPassword,
             severurl: Serverip);
 
-        // 添加连接超时计数器
-        int connectionTimeoutCounter = 0;
-
         // 不再使用固定延迟模拟连接成功，而是通过定时检查IP来确定连接状态
         timer = Timer.periodic(const Duration(seconds: 1), (timer) async {
           // 检查组件是否仍然挂载
@@ -146,49 +222,40 @@ class _HomePageState extends State<HomePage> {
           final int? version = runin.myNodeInfo?.virtualIpv4?.address?.addr;
           if (version != null) {
             String ipStr = _intToIpv4String(version);
-            // 检查IP不为0.0.0.0时认为连接成功
-            if (ipStr != "0.0.0.0") {
-              if (publicIP != ipStr) {
-                km.virtualIP = ipStr;
-              }
+            if (publicIP != ipStr) {
+              km.virtualIP = ipStr;
+            }
 
-              // 如果当前状态还是连接中，则更新为已连接
-              if (_connectionState == ConnectionState.connecting) {
-                setState(() {
-                  _connectionState = ConnectionState.connected;
-                });
-              }
-
-              // 重置超时计数器
+            // 如果当前状态还是连接中，则更新为已连接
+            if (_connectionState == ConnectionState.connecting) {
+              setState(() {
+                _connectionState = ConnectionState.connected;
+              });
+            }
+            connectionTimeoutCounter = 0;
+          } else if (_connectionState == ConnectionState.connecting) {
+            connectionTimeoutCounter++;
+            if (connectionTimeoutCounter >= 10) {
               connectionTimeoutCounter = 0;
-            } else if (_connectionState == ConnectionState.connecting) {
-              // 只在连接状态下增加超时计数
-              connectionTimeoutCounter++;
+              timer.cancel();
+              setState(() {
+                isRunning = false;
+                _connectionState = ConnectionState.notStarted;
+                runningTime = Duration.zero;
+              });
 
-              // 如果连续10秒都是0.0.0.0，判断为连接失败
-              if (connectionTimeoutCounter >= 10) {
-                // 停止连接并显示失败消息
-                timer.cancel();
-                setState(() {
-                  isRunning = false;
-                  _connectionState = ConnectionState.notStarted;
-                  runningTime = Duration.zero;
-                });
-
-                // 关闭服务器连接
-                closeAllServer();
-
-                // 显示连接失败提示
-                if (mounted) {
-                  ScaffoldMessenger.of(context).showSnackBar(
-                    const SnackBar(
-                      content: Text('连接失败，请检查网络或房间信息后重试'),
-                      duration: Duration(seconds: 3),
-                    ),
-                  );
-                }
-                return;
+              closeAllServer();
+// 清空玩家列表数据
+              Provider.of<KM>(context, listen: false).nodes = [];
+              if (mounted) {
+                ScaffoldMessenger.of(context).showSnackBar(
+                  const SnackBar(
+                    content: Text('连接失败，未能获取节点信息'),
+                    duration: Duration(seconds: 3),
+                  ),
+                );
               }
+              return;
             }
           }
 
@@ -207,6 +274,8 @@ class _HomePageState extends State<HomePage> {
         // 停止时重置状态
         _connectionState = ConnectionState.notStarted;
         closeAllServer();
+        // 清空玩家列表数据
+        Provider.of<KM>(context, listen: false).nodes = [];
         timer?.cancel();
         runningTime = Duration.zero;
         // 重置网络统计数据
@@ -216,6 +285,7 @@ class _HomePageState extends State<HomePage> {
         _lastDownloadBytes = 0;
         uploadSpeed = 0;
         downloadSpeed = 0;
+        //connectionTimeoutCounter
       }
     });
   }
@@ -286,6 +356,7 @@ class _HomePageState extends State<HomePage> {
       text: km.username,
       selection: _usernameController.selection,
     );
+    // 添加虚拟IP控制器的值同步
     _virtualIPController.value = TextEditingValue(
       text: km.virtualIP,
       selection: _virtualIPController.selection,
@@ -478,88 +549,6 @@ class _HomePageState extends State<HomePage> {
     }
   }
 
-  // 修改卡片构建方法，移除多余的内边距
-  Widget _buildDashboardCard(ColorScheme colorScheme) {
-    return FloatingCard(
-        colorScheme: colorScheme,
-        maxWidth: 600, // 设置最大宽度
-        height: 200,
-        child: SizedBox(
-          child: PieChart(
-            PieChartData(
-              sections: [
-                PieChartSectionData(
-                  value: uploadSpeed,
-                  title: '上传',
-                  color: colorScheme.primary,
-                ),
-                PieChartSectionData(
-                  value: downloadSpeed,
-                  title: '下载',
-                  color: colorScheme.secondary,
-                ),
-              ],
-            ),
-          ),
-        ));
-  }
-
-  // 修改流量统计卡片，移除多余的内边距
-  Widget _buildTrafficCard(ColorScheme colorScheme) {
-    return FloatingCard(
-        colorScheme: colorScheme,
-        maxWidth: 600,
-        child: Column(
-          crossAxisAlignment: CrossAxisAlignment.start,
-          children: [
-            // 修改标题为图标+文字组合
-            Row(
-              children: [
-                Icon(Icons.data_usage, color: colorScheme.primary, size: 22),
-                const SizedBox(width: 8),
-                const Text('流量统计',
-                    style:
-                        TextStyle(fontSize: 18, fontWeight: FontWeight.bold)),
-              ],
-            ),
-            const SizedBox(height: 16),
-            Row(
-              mainAxisAlignment: MainAxisAlignment.spaceAround,
-              children: [
-                _buildTrafficInfo('上传速度', '$uploadSpeed MB/s', Icons.upload,
-                    colorScheme.primary),
-                _buildTrafficInfo('下载速度', '$downloadSpeed MB/s', Icons.download,
-                    colorScheme.secondary),
-              ],
-            ),
-          ],
-        ));
-  }
-
-  // 修改IP地址卡片，移除多余的内边距
-  Widget _buildIPCard(ColorScheme colorScheme) {
-    return FloatingCard(
-      colorScheme: colorScheme,
-      maxWidth: 600,
-      child: Column(
-        crossAxisAlignment: CrossAxisAlignment.start,
-        children: [
-          // 修改标题为图标+文字组合
-          Row(
-            children: [
-              Icon(Icons.wifi, color: colorScheme.primary, size: 22),
-              const SizedBox(width: 8),
-              const Text('网络信息',
-                  style: TextStyle(fontSize: 18, fontWeight: FontWeight.bold)),
-            ],
-          ),
-          const SizedBox(height: 16),
-          _buildIPInfo('虚拟 IP', publicIP, Icons.public, colorScheme),
-        ],
-      ),
-    );
-  }
-
   Widget _buildTrafficInfo(
       String label, String value, IconData icon, Color color) {
     return Column(
@@ -585,7 +574,60 @@ class _HomePageState extends State<HomePage> {
     );
   }
 
+// 添加服务器列表卡片
+  Widget _buildServerListCard(ColorScheme colorScheme) {
+    final km = Provider.of<KM>(context);
+    // 直接使用 serverIP 列表，而不是尝试访问 serverList
+    final serverUrls = km.serverIP;
+
+    return FloatingCard(
+      colorScheme: colorScheme,
+      maxWidth: 600,
+      child: Column(
+        crossAxisAlignment: CrossAxisAlignment.start,
+        children: [
+          // 标题栏
+          Row(
+            children: [
+              Icon(Icons.dns, color: colorScheme.primary, size: 22),
+              const SizedBox(width: 8),
+              const Text('当前服务器',
+                  style: TextStyle(fontSize: 18, fontWeight: FontWeight.bold)),
+            ],
+          ),
+          const SizedBox(height: 16),
+
+          // 当前选中的服务器
+          Wrap(
+            spacing: 8,
+            runSpacing: 8,
+            children: serverUrls.isEmpty ||
+                    (serverUrls.length == 1 && serverUrls[0].isEmpty)
+                ? [
+                    Chip(
+                      avatar: Icon(Icons.info_outline,
+                          size: 16, color: colorScheme.error),
+                      label: const Text('未选择服务器'),
+                      backgroundColor:
+                          colorScheme.errorContainer.withOpacity(0.3),
+                    )
+                  ]
+                : serverUrls
+                    .map((url) => Chip(
+                          avatar: Icon(Icons.dns,
+                              size: 16, color: colorScheme.primary),
+                          label: Text(url),
+                          backgroundColor: colorScheme.surfaceVariant,
+                        ))
+                    .toList(),
+          ),
+        ],
+      ),
+    );
+  }
+
   // 新增合并后的网络状态卡片（合并了流量统计和IP信息）
+  // 修改网络状态卡片，去除流量统计部分
   Widget _buildNetworkStatusCard(ColorScheme colorScheme) {
     return FloatingCard(
       colorScheme: colorScheme,
@@ -623,33 +665,6 @@ class _HomePageState extends State<HomePage> {
 
           // IP信息部分
           _buildIPInfo('虚拟 IP', publicIP, Icons.public, colorScheme),
-          const SizedBox(height: 12),
-
-          // 流量统计部分
-          const Divider(),
-          const SizedBox(height: 8),
-          Row(
-            children: [
-              Icon(Icons.data_usage, color: colorScheme.primary, size: 18),
-              const SizedBox(width: 8),
-              Text('流量统计',
-                  style: TextStyle(
-                    fontSize: 16,
-                    fontWeight: FontWeight.w500,
-                    color: colorScheme.primary,
-                  )),
-            ],
-          ),
-          const SizedBox(height: 12),
-          Row(
-            mainAxisAlignment: MainAxisAlignment.spaceAround,
-            children: [
-              _buildTrafficInfo('上传速度', '$uploadSpeed MB/s', Icons.upload,
-                  colorScheme.primary),
-              _buildTrafficInfo('下载速度', '$downloadSpeed MB/s', Icons.download,
-                  colorScheme.secondary),
-            ],
-          ),
 
           // 添加运行时间显示
           if (_connectionState == ConnectionState.connected) ...[
@@ -743,9 +758,12 @@ class _HomePageState extends State<HomePage> {
           // 用户名输入框
           TextField(
             controller: _usernameController,
+            focusNode: _usernameControllerFocusNode, // 添加焦点节点
             enabled: _connectionState != ConnectionState.connected,
-            onChanged: (value) {
-              km.username = value;
+            onEditingComplete: () {
+              // 改为完成编辑时更新
+              Provider.of<KM>(context, listen: false).username =
+                  _usernameController.text;
             },
             decoration: InputDecoration(
               labelText: '用户名',
@@ -762,12 +780,17 @@ class _HomePageState extends State<HomePage> {
               Expanded(
                 child: TextField(
                   controller: _virtualIPController,
+                  focusNode: _virtualIPFocusNode, // 添加焦点节点
                   enabled: !_isAutoIP &&
                       _connectionState != ConnectionState.connected,
                   onChanged: (value) {
+                    // 保留空回调以避免实时更新
+                  },
+                  onEditingComplete: () {
+                    // 添加完成编辑回调
                     if (!_isAutoIP) {
-                      setState(() {});
-                      km.virtualIP = value;
+                      Provider.of<KM>(context, listen: false).virtualIP =
+                          _virtualIPController.text;
                     }
                   },
                   decoration: InputDecoration(
@@ -790,6 +813,10 @@ class _HomePageState extends State<HomePage> {
                               _isAutoIP = value;
                             });
                             km.dynamicIP = value;
+                            // 切换模式时同步最新值
+                            if (!value) {
+                              km.virtualIP = _virtualIPController.text;
+                            }
                           }
                         : null,
                   ),
@@ -859,9 +886,12 @@ class _HomePageState extends State<HomePage> {
           // 房间名称输入框
           TextField(
             controller: _roomNameController,
+            focusNode: _roomNameControllerFocusNode, // 添加焦点节点
             enabled: _connectionState != ConnectionState.connected,
-            onChanged: (value) {
-              km.roomName = value;
+            onEditingComplete: () {
+              // 改为完成编辑时更新
+              Provider.of<KM>(context, listen: false).roomName =
+                  _roomNameController.text;
             },
             decoration: InputDecoration(
               labelText: '房间名称',
@@ -875,9 +905,12 @@ class _HomePageState extends State<HomePage> {
           // 房间密码输入框
           TextField(
             controller: _roomPasswordController,
+            focusNode: _roomPasswordControllerFocusNode, // 添加焦点节点
             enabled: _connectionState != ConnectionState.connected,
-            onChanged: (value) {
-              km.roomPassword = value;
+            onEditingComplete: () {
+              // 改为完成编辑时更新
+              Provider.of<KM>(context, listen: false).roomPassword =
+                  _roomPasswordController.text;
             },
             obscureText: true,
             decoration: InputDecoration(

lib/screens/kvroom.dart

@@ -230,13 +230,7 @@ class _RoomPageState extends State<RoomPage> {
         }
 
         // 计算丢包率 (简单估算)
-        double packetLossRate = 0.0;
-        if (sentPackets > 0 && receivedPackets > 0) {
-          packetLossRate = (1.0 - (receivedPackets / sentPackets)).abs() * 100;
-          if (packetLossRate > 100) packetLossRate = 100.0;
-          packetLossRate = double.parse(packetLossRate.toStringAsFixed(1));
-        }
-
+        double packetLossRate = node.lossRate;
         // 获取NAT类型
         String natType = _mapNatType(node.nat);
 

lib/screens/settings.dart

@@ -1,3 +1,4 @@
+import 'dart:async';
 import 'package:astral/utils/app_info.dart';
 import 'package:astral/utils/up.dart';
 import 'package:flutter/material.dart';
@@ -19,91 +20,127 @@ final updateChecker = UpdateChecker(
 );
 
 class _SettingsPageState extends State<SettingsPage> {
-  bool _notificationsEnabled = true;
-  double _fontSize = 16.0;
-  late List<String> _serverList;
-  late String _currentServer;
+  late List<Map<String, dynamic>> _serverList;
   final _appConfig = AppConfig();
   bool _closeToTray = false; // 添加关闭进入托盘变量
+  bool _pingEnabled = true; // 添加全局ping开关
 
   String serverIP = "";
   // 添加 ping 相关状态
   Map<String, int?> pingResults = {};
-  Map<String, bool> isPinging = {};
 
   @override
   void initState() {
     super.initState();
     _serverList = _appConfig.serverList;
-    _currentServer = _appConfig.currentServer;
-    serverIP = _appConfig.currentServer;
+    serverIP = _getSelectedServersString();
     _closeToTray = _appConfig.closeToTray; // 初始化托盘设置
+    // 初始化全局ping开关
+    _pingEnabled = _appConfig.enablePing;
 
     // 初始化 ping 状态
     for (var server in _serverList) {
-      pingResults[server] = null;
-      isPinging[server] = true; // 默认所有服务器都开启ping
+      pingResults[server['url']] = null;
     }
 
     // 开始 ping 所有服务器
-    for (var server in _serverList) {
-      _pingServer(server);
+    _startPingAllServers();
+  }
+
+  // 获取选中的服务器字符串
+  String _getSelectedServersString() {
+    final selected =
+        _serverList.where((server) => server['selected'] == true).toList();
+    if (selected.isEmpty && _serverList.isNotEmpty) {
+      return _serverList.first['url'];
     }
+    return selected.map((server) => server['url']).join(', ');
+  }
+
+  // 添加一个计时器变量来控制 ping 操作
+  Timer? _pingTimer;
+
+  // 新增方法：开始 ping 所有服务器
+  void _startPingAllServers() {
+    // 取消之前的计时器（如果存在）
+    _pingTimer?.cancel();
+
+    // 创建新的计时器，使用设置的间隔时间
+    _pingTimer = Timer.periodic(Duration(milliseconds: 1000), (timer) {
+      if (!mounted) {
+        timer.cancel();
+        return;
+      }
+
+      if (_pingEnabled) {
+        for (var server in _serverList) {
+          _pingServerOnce(server['url']);
+        }
+      }
+    });
   }
 
   @override
   void dispose() {
-    // 停止所有 ping
-    for (var server in _serverList) {
-      isPinging[server] = false;
-    }
+    // 取消计时器
+    _pingTimer?.cancel();
+    _pingTimer = null;
     super.dispose();
   }
 
-  // 简化 ping 方法，移除强制持续 ping 参数
-  void _startPingServer(String server) {
-    if (isPinging[server] == true) return;
-
-    isPinging[server] = true;
-    _pingServer(server);
-  }
-
-  // 修改停止 ping 方法 - 实际上不再需要，但保留以防将来需要
-  void _stopPingServer(String server) {
-    isPinging[server] = false;
-  }
-
-  // 执行 ping 操作
-  Future<void> _pingServer(String server) async {
-    if (isPinging[server] != true) return;
-
+  // 执行单次 ping 操作
+  Future<void> _pingServerOnce(String server) async {
     final pingResult = await PingUtil.ping(server);
 
     if (mounted) {
       setState(() {
         pingResults[server] = pingResult;
       });
-
-      // 1秒后再次 ping
-      Future.delayed(const Duration(seconds: 1), () {
-        _pingServer(server);
-      });
     }
   }
 
+  // 切换全局ping状态
+  void _togglePingStatus(bool value) {
+    setState(() {
+      _pingEnabled = value;
+      _appConfig.setEnablePing(_pingEnabled);
+      if (!_pingEnabled) {
+        // 如果关闭ping，清空所有结果
+        for (var server in _serverList) {
+          pingResults[server['url']] = null;
+        }
+      }
+    });
+  }
+
   // 添加服务器对话框
   Future<void> _showAddServerDialog() async {
-    final controller = TextEditingController();
-    final result = await showDialog<String>(
+    final urlController = TextEditingController();
+    final nameController = TextEditingController();
+
+    final result = await showDialog<Map<String, dynamic>>(
       context: context,
       builder: (context) => AlertDialog(
         title: const Text('添加服务器'),
-        content: TextField(
-          controller: controller,
-          decoration: const InputDecoration(
-            labelText: '服务器地址',
-            hintText: 'example.com:port',
-          ),
+        content: Column(
+          mainAxisSize: MainAxisSize.min,
+          children: [
+            TextField(
+              controller: nameController,
+              decoration: const InputDecoration(
+                labelText: '服务器名称',
+                hintText: '自定义名称',
+              ),
+            ),
+            const SizedBox(height: 8),
+            TextField(
+              controller: urlController,
+              decoration: const InputDecoration(
+                labelText: '服务器地址',
+                hintText: 'example.com:port',
+              ),
+            ),
+          ],
         ),
         actions: [
           TextButton(
@@ -111,39 +148,67 @@ class _SettingsPageState extends State<SettingsPage> {
             child: const Text('取消'),
           ),
           TextButton(
-            onPressed: () => Navigator.pop(context, controller.text),
+            onPressed: () {
+              if (urlController.text.isNotEmpty) {
+                Navigator.pop(context, {
+                  'url': urlController.text,
+                  'name': nameController.text.isNotEmpty
+                      ? nameController.text
+                      : urlController.text,
+                });
+              }
+            },
             child: const Text('添加'),
           ),
         ],
       ),
     );
 
-    if (result != null && result.isNotEmpty) {
+    if (result != null) {
       setState(() {
-        _serverList.add(result);
+        // 添加新服务器，默认不选中
+        _serverList.add({
+          'url': result['url'],
+          'name': result['name'],
+          'selected': false,
+        });
         _appConfig.setServerList(_serverList);
 
-        // 初始化新服务器的 ping 状态并立即开始 ping
-        pingResults[result] = null;
-        isPinging[result] = true;
-        _pingServer(result);
+        // 初始化新服务器的 ping 状态
+        pingResults[result['url']] = null;
       });
     }
   }
 
   // 编辑服务器对话框
   Future<void> _showEditServerDialog(int index) async {
-    final controller = TextEditingController(text: _serverList[index]);
-    final result = await showDialog<String>(
+    final server = _serverList[index];
+    final urlController = TextEditingController(text: server['url']);
+    final nameController = TextEditingController(text: server['name']);
+
+    final result = await showDialog<Map<String, dynamic>>(
       context: context,
       builder: (context) => AlertDialog(
         title: const Text('编辑服务器'),
-        content: TextField(
-          controller: controller,
-          decoration: const InputDecoration(
-            labelText: '服务器地址',
-            hintText: 'example.com:port',
-          ),
+        content: Column(
+          mainAxisSize: MainAxisSize.min,
+          children: [
+            TextField(
+              controller: nameController,
+              decoration: const InputDecoration(
+                labelText: '服务器名称',
+                hintText: '自定义名称',
+              ),
+            ),
+            const SizedBox(height: 8),
+            TextField(
+              controller: urlController,
+              decoration: const InputDecoration(
+                labelText: '服务器地址',
+                hintText: 'example.com:port',
+              ),
+            ),
+          ],
         ),
         actions: [
           TextButton(
@@ -151,17 +216,42 @@ class _SettingsPageState extends State<SettingsPage> {
             child: const Text('取消'),
           ),
           TextButton(
-            onPressed: () => Navigator.pop(context, controller.text),
+            onPressed: () {
+              if (urlController.text.isNotEmpty) {
+                Navigator.pop(context, {
+                  'url': urlController.text,
+                  'name': nameController.text.isNotEmpty
+                      ? nameController.text
+                      : urlController.text,
+                });
+              }
+            },
             child: const Text('保存'),
           ),
         ],
       ),
     );
 
-    if (result != null && result.isNotEmpty) {
+    if (result != null) {
+      final oldUrl = server['url'];
       setState(() {
-        _serverList[index] = result;
+        _serverList[index] = {
+          'url': result['url'],
+          'name': result['name'],
+          'selected': server['selected'],
+        };
         _appConfig.setServerList(_serverList);
+
+        // 更新 ping 状态
+        if (oldUrl != result['url']) {
+          pingResults[result['url']] = pingResults[oldUrl];
+          pingResults.remove(oldUrl);
+        }
+
+        // 更新当前选中的服务器显示
+        serverIP = _getSelectedServersString();
+        // 使用新的 serverList 方法替代直接设置 serverIP
+        Provider.of<KM>(context, listen: false).serverList = _serverList;
       });
     }
   }
@@ -189,30 +279,54 @@ class _SettingsPageState extends State<SettingsPage> {
     if (confirm == true) {
       final server = _serverList[index];
 
-      // 停止 ping
-      _stopPingServer(server);
-
       setState(() {
         _serverList.removeAt(index);
         _appConfig.setServerList(_serverList);
 
         // 移除 ping 状态
-        pingResults.remove(server);
-        isPinging.remove(server);
+        pingResults.remove(server['url']);
 
-        if (_currentServer == server && _serverList.isNotEmpty) {
-          _currentServer = _serverList[0];
-          _appConfig.setCurrentServer(_currentServer);
-          _startPingServer(_currentServer);
+        // 确保至少有一个服务器被选中
+        if (_serverList.isNotEmpty &&
+            !_serverList.any((server) => server['selected'] == true)) {
+          _serverList.first['selected'] = true;
         }
+
+        // 更新当前选中的服务器显示
+        serverIP = _getSelectedServersString();
+        // 使用新的 serverList 方法替代直接设置 serverIP
+        Provider.of<KM>(context, listen: false).serverList = _serverList;
       });
     }
   }
 
+  // 切换服务器选中状态
+  void _toggleServerSelection(int index) {
+    setState(() {
+      _serverList[index]['selected'] =
+          !(_serverList[index]['selected'] ?? false);
+      _appConfig.setServerList(_serverList);
+
+      // 更新当前选中的服务器显示
+      serverIP = _getSelectedServersString();
+      // 使用新的 serverList 方法替代直接设置 serverIP
+      Provider.of<KM>(context, listen: false).serverList = _serverList;
+
+      ScaffoldMessenger.of(context).showSnackBar(
+        SnackBar(
+            content: Text(_serverList[index]['selected']
+                ? '已选中服务器: ${_serverList[index]['name']}'
+                : '已取消选中: ${_serverList[index]['name']}')),
+      );
+    });
+  }
+
   // 添加构建 ping 显示组件的方法
-  Widget _buildPingWidget(String server) {
-    final pingResult = pingResults[server];
-    if (pingResult == null) {
+  Widget _buildPingWidget(String url) {
+    final pingResult = pingResults[url];
+    if (!_pingEnabled) {
+      return const Text('Ping已关闭', style: TextStyle(color: Colors.grey));
+    } else if (pingResult == null) {
       return const Text('测试中...', style: TextStyle(color: Colors.grey));
     } else {
       return Text(
@@ -229,7 +343,6 @@ class _SettingsPageState extends State<SettingsPage> {
   @override
   Widget build(BuildContext context) {
     // updateChecker.checkForUpdates(context);
-    serverIP = Provider.of<KM>(context).virtualIP;
     return ListView(
       padding: const EdgeInsets.all(16.0),
       children: [
@@ -238,60 +351,39 @@ class _SettingsPageState extends State<SettingsPage> {
             children: [
               ListTile(
                 leading: const Icon(Icons.dns),
-                title: Row(
-                  children: [
-                    const Text('当前服务器'),
-                    const SizedBox(width: 8),
-                    _buildPingWidget(_currentServer),
-                  ],
-                ),
-                subtitle: Text(_currentServer),
+                title: const Text('已选中的服务器'),
+                subtitle: Text(serverIP),
               ),
               ExpansionTile(
                 leading: const Icon(Icons.list),
                 title: const Text('服务器列表'),
-                onExpansionChanged: (expanded) {
-                  // 不再需要处理展开折叠时的 ping 状态，所有服务器都持续 ping
-                },
                 children: [
-                  // 在服务器列表前添加当前服务器的 ping 状态显示
                   ListView.builder(
                     shrinkWrap: true,
                     physics: const NeverScrollableScrollPhysics(),
                     itemCount: _serverList.length,
                     itemBuilder: (context, index) {
                       final server = _serverList[index];
-                      final pingResult = pingResults[server];
-
-                      // 构建延迟显示组件
-                      Widget pingWidget;
-                      if (pingResult == null) {
-                        pingWidget = const Text('测试中...',
-                            style: TextStyle(color: Colors.grey));
-                      } else {
-                        pingWidget = Text('${pingResult}ms',
-                            style: TextStyle(
-                                color: pingResult < 100
-                                    ? Colors.green
-                                    : (pingResult < 300
-                                        ? Colors.orange
-                                        : Colors.red)));
-                      }
+                      final isSelected = server['selected'] == true;
 
                       return ListTile(
-                        leading: const Icon(Icons.computer),
+                        leading: Icon(
+                          isSelected
+                              ? Icons.check_circle
+                              : Icons.circle_outlined,
+                          color: isSelected ? Colors.green : null,
+                        ),
                         title: Row(
                           children: [
-                            Text('服务器 ${index + 1}'),
+                            Text(server['name']),
                             const SizedBox(width: 8),
-                            pingWidget,
+                            _buildPingWidget(server['url']),
                           ],
                         ),
-                        subtitle: Text(server),
+                        subtitle: Text(server['url']),
                         trailing: Row(
                           mainAxisSize: MainAxisSize.min,
                           children: [
-                            // 移除 ping 按钮，只保留编辑和删除按钮
                             IconButton(
                               icon: const Icon(Icons.edit),
                               onPressed: () => _showEditServerDialog(index),
@@ -302,17 +394,7 @@ class _SettingsPageState extends State<SettingsPage> {
                             ),
                           ],
                         ),
-                        onTap: () {
-                          setState(() {
-                            _currentServer = server;
-                            Provider.of<KM>(context, listen: false).serverIP =
-                                server;
-                            // 不再需要特别开始 ping 新选择的服务器，因为所有服务器都在 ping
-                          });
-                          ScaffoldMessenger.of(context).showSnackBar(
-                            SnackBar(content: Text('已切换到服务器: $server')),
-                          );
-                        },
+                        onTap: () => _toggleServerSelection(index),
                       );
                     },
                   ),
@@ -347,6 +429,12 @@ class _SettingsPageState extends State<SettingsPage> {
                   });
                 },
               ),
+              SwitchListTile(
+                title: const Text('启用服务器Ping测试'),
+                subtitle: const Text('定期测试所有服务器的网络延迟'),
+                value: _pingEnabled,
+                onChanged: _togglePingStatus,
+              ),
             ],
           ),
         ),

lib/src/rust/api/simple.dart

@@ -37,7 +37,7 @@ Future<void> createServer(
         required String specifiedIp,
         required String roomName,
         required String roomPassword,
-        required String severurl}) =>
+        required List<String> severurl}) =>
     RustLib.instance.api.crateApiSimpleCreateServer(
         username: username,
         enableDhcp: enableDhcp,
@@ -124,6 +124,7 @@ class KVNodeInfo {
   final String ipv4;
   final double latencyMs;
   final String nat;
+  final double lossRate;
   final List<KVNodeConnectionStats> connections;
   final String version;
   final int cost;
@@ -133,6 +134,7 @@ class KVNodeInfo {
     required this.ipv4,
     required this.latencyMs,
     required this.nat,
+    required this.lossRate,
     required this.connections,
     required this.version,
     required this.cost,
@@ -144,6 +146,7 @@ class KVNodeInfo {
       ipv4.hashCode ^
       latencyMs.hashCode ^
       nat.hashCode ^
+      lossRate.hashCode ^
       connections.hashCode ^
       version.hashCode ^
       cost.hashCode;
@@ -157,6 +160,7 @@ class KVNodeInfo {
           ipv4 == other.ipv4 &&
           latencyMs == other.latencyMs &&
           nat == other.nat &&
+          lossRate == other.lossRate &&
           connections == other.connections &&
           version == other.version &&
           cost == other.cost;

lib/src/rust/frb_generated.dart

@@ -85,7 +85,7 @@ abstract class RustLibApi extends BaseApi {
       required String specifiedIp,
       required String roomName,
       required String roomPassword,
-      required String severurl});
+      required List<String> severurl});
 
   Future<String> crateApiSimpleEasytierVersion();
 
@@ -174,7 +174,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
       required String specifiedIp,
       required String roomName,
       required String roomPassword,
-      required String severurl}) {
+      required List<String> severurl}) {
     return handler.executeNormal(NormalTask(
       callFfi: (port_) {
         final serializer = SseSerializer(generalizedFrbRustBinding);
@@ -183,7 +183,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
         sse_encode_String(specifiedIp, serializer);
         sse_encode_String(roomName, serializer);
         sse_encode_String(roomPassword, serializer);
-        sse_encode_String(severurl, serializer);
+        sse_encode_list_String(severurl, serializer);
         pdeCallFfi(generalizedFrbRustBinding, serializer,
             funcId: 2, port: port_);
       },
@@ -515,6 +515,12 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     return raw as bool;
   }
 
+  @protected
+  double dco_decode_f_32(dynamic raw) {
+    // Codec=Dco (DartCObject based), see doc to use other codecs
+    return raw as double;
+  }
+
   @protected
   double dco_decode_f_64(dynamic raw) {
     // Codec=Dco (DartCObject based), see doc to use other codecs
@@ -558,16 +564,17 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
   KVNodeInfo dco_decode_kv_node_info(dynamic raw) {
     // Codec=Dco (DartCObject based), see doc to use other codecs
     final arr = raw as List<dynamic>;
-    if (arr.length != 7)
-      throw Exception('unexpected arr length: expect 7 but see ${arr.length}');
+    if (arr.length != 8)
+      throw Exception('unexpected arr length: expect 8 but see ${arr.length}');
     return KVNodeInfo(
       hostname: dco_decode_String(arr[0]),
       ipv4: dco_decode_String(arr[1]),
       latencyMs: dco_decode_f_64(arr[2]),
       nat: dco_decode_String(arr[3]),
-      connections: dco_decode_list_kv_node_connection_stats(arr[4]),
-      version: dco_decode_String(arr[5]),
-      cost: dco_decode_i_32(arr[6]),
+      lossRate: dco_decode_f_32(arr[4]),
+      connections: dco_decode_list_kv_node_connection_stats(arr[5]),
+      version: dco_decode_String(arr[6]),
+      cost: dco_decode_i_32(arr[7]),
     );
   }
 
@@ -604,6 +611,12 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
         .toList();
   }
 
+  @protected
+  List<String> dco_decode_list_String(dynamic raw) {
+    // Codec=Dco (DartCObject based), see doc to use other codecs
+    return (raw as List<dynamic>).map(dco_decode_String).toList();
+  }
+
   @protected
   List<KVNodeConnectionStats> dco_decode_list_kv_node_connection_stats(
       dynamic raw) {
@@ -753,6 +766,12 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     return deserializer.buffer.getUint8() != 0;
   }
 
+  @protected
+  double sse_decode_f_32(SseDeserializer deserializer) {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    return deserializer.buffer.getFloat32();
+  }
+
   @protected
   double sse_decode_f_64(SseDeserializer deserializer) {
     // Codec=Sse (Serialization based), see doc to use other codecs
@@ -797,6 +816,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     var var_ipv4 = sse_decode_String(deserializer);
     var var_latencyMs = sse_decode_f_64(deserializer);
     var var_nat = sse_decode_String(deserializer);
+    var var_lossRate = sse_decode_f_32(deserializer);
     var var_connections =
         sse_decode_list_kv_node_connection_stats(deserializer);
     var var_version = sse_decode_String(deserializer);
@@ -806,6 +826,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
         ipv4: var_ipv4,
         latencyMs: var_latencyMs,
         nat: var_nat,
+        lossRate: var_lossRate,
         connections: var_connections,
         version: var_version,
         cost: var_cost);
@@ -859,6 +880,18 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     return ans_;
   }
 
+  @protected
+  List<String> sse_decode_list_String(SseDeserializer deserializer) {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+
+    var len_ = sse_decode_i_32(deserializer);
+    var ans_ = <String>[];
+    for (var idx_ = 0; idx_ < len_; ++idx_) {
+      ans_.add(sse_decode_String(deserializer));
+    }
+    return ans_;
+  }
+
   @protected
   List<KVNodeConnectionStats> sse_decode_list_kv_node_connection_stats(
       SseDeserializer deserializer) {
@@ -1016,6 +1049,12 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     serializer.buffer.putUint8(self ? 1 : 0);
   }
 
+  @protected
+  void sse_encode_f_32(double self, SseSerializer serializer) {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    serializer.buffer.putFloat32(self);
+  }
+
   @protected
   void sse_encode_f_64(double self, SseSerializer serializer) {
     // Codec=Sse (Serialization based), see doc to use other codecs
@@ -1054,6 +1093,7 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     sse_encode_String(self.ipv4, serializer);
     sse_encode_f_64(self.latencyMs, serializer);
     sse_encode_String(self.nat, serializer);
+    sse_encode_f_32(self.lossRate, serializer);
     sse_encode_list_kv_node_connection_stats(self.connections, serializer);
     sse_encode_String(self.version, serializer);
     sse_encode_i_32(self.cost, serializer);
@@ -1095,6 +1135,15 @@ class RustLibApiImpl extends RustLibApiImplPlatform implements RustLibApi {
     }
   }
 
+  @protected
+  void sse_encode_list_String(List<String> self, SseSerializer serializer) {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    sse_encode_i_32(self.length, serializer);
+    for (final item in self) {
+      sse_encode_String(item, serializer);
+    }
+  }
+
   @protected
   void sse_encode_list_kv_node_connection_stats(
       List<KVNodeConnectionStats> self, SseSerializer serializer) {

lib/src/rust/frb_generated.io.dart

@@ -77,6 +77,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   bool dco_decode_bool(dynamic raw);
 
+  @protected
+  double dco_decode_f_32(dynamic raw);
+
   @protected
   double dco_decode_f_64(dynamic raw);
 
@@ -107,6 +110,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       dco_decode_list_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRoute(
           dynamic raw);
 
+  @protected
+  List<String> dco_decode_list_String(dynamic raw);
+
   @protected
   List<KVNodeConnectionStats> dco_decode_list_kv_node_connection_stats(
       dynamic raw);
@@ -182,6 +188,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   bool sse_decode_bool(SseDeserializer deserializer);
 
+  @protected
+  double sse_decode_f_32(SseDeserializer deserializer);
+
   @protected
   double sse_decode_f_64(SseDeserializer deserializer);
 
@@ -213,6 +222,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       sse_decode_list_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRoute(
           SseDeserializer deserializer);
 
+  @protected
+  List<String> sse_decode_list_String(SseDeserializer deserializer);
+
   @protected
   List<KVNodeConnectionStats> sse_decode_list_kv_node_connection_stats(
       SseDeserializer deserializer);
@@ -288,6 +300,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   void sse_encode_bool(bool self, SseSerializer serializer);
 
+  @protected
+  void sse_encode_f_32(double self, SseSerializer serializer);
+
   @protected
   void sse_encode_f_64(double self, SseSerializer serializer);
 
@@ -320,6 +335,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       sse_encode_list_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRoute(
           List<Route> self, SseSerializer serializer);
 
+  @protected
+  void sse_encode_list_String(List<String> self, SseSerializer serializer);
+
   @protected
   void sse_encode_list_kv_node_connection_stats(
       List<KVNodeConnectionStats> self, SseSerializer serializer);

lib/src/rust/frb_generated.web.dart

@@ -79,6 +79,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   bool dco_decode_bool(dynamic raw);
 
+  @protected
+  double dco_decode_f_32(dynamic raw);
+
   @protected
   double dco_decode_f_64(dynamic raw);
 
@@ -109,6 +112,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       dco_decode_list_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRoute(
           dynamic raw);
 
+  @protected
+  List<String> dco_decode_list_String(dynamic raw);
+
   @protected
   List<KVNodeConnectionStats> dco_decode_list_kv_node_connection_stats(
       dynamic raw);
@@ -184,6 +190,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   bool sse_decode_bool(SseDeserializer deserializer);
 
+  @protected
+  double sse_decode_f_32(SseDeserializer deserializer);
+
   @protected
   double sse_decode_f_64(SseDeserializer deserializer);
 
@@ -215,6 +224,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       sse_decode_list_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRoute(
           SseDeserializer deserializer);
 
+  @protected
+  List<String> sse_decode_list_String(SseDeserializer deserializer);
+
   @protected
   List<KVNodeConnectionStats> sse_decode_list_kv_node_connection_stats(
       SseDeserializer deserializer);
@@ -290,6 +302,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
   @protected
   void sse_encode_bool(bool self, SseSerializer serializer);
 
+  @protected
+  void sse_encode_f_32(double self, SseSerializer serializer);
+
   @protected
   void sse_encode_f_64(double self, SseSerializer serializer);
 
@@ -322,6 +337,9 @@ abstract class RustLibApiImplPlatform extends BaseApiImpl<RustLibWire> {
       sse_encode_list_Auto_Owned_RustOpaque_flutter_rust_bridgefor_generatedRustAutoOpaqueInnerRoute(
           List<Route> self, SseSerializer serializer);
 
+  @protected
+  void sse_encode_list_String(List<String> self, SseSerializer serializer);
+
   @protected
   void sse_encode_list_kv_node_connection_stats(
       List<KVNodeConnectionStats> self, SseSerializer serializer);

lib/utils/kv_state.dart

@@ -47,13 +47,52 @@ class KM extends ChangeNotifier {
     notifyListeners();
   }
 
-  //当前服务器IP
-  String get serverIP => _config.currentServer;
-  set serverIP(String value) {
-    _config.setCurrentServer(value);
+//服务器列表
+  List<Map<String, dynamic>> get serverList => _config.serverList;
+  set serverList(List<Map<String, dynamic>> value) {
+    List<Map<String, dynamic>> convertedList = value.map((item) {
+      return Map<String, dynamic>.from(item);
+    }).toList();
+    _config.setServerList(convertedList);
     notifyListeners();
   }
 
+  //获取选中的服务器
+  //获取选中的服务器
+  List<String> get serverIP {
+    try {
+      final selected =
+          serverList.where((server) => server['selected'] == true).toList();
+
+      if (selected.isEmpty && serverList.isNotEmpty) {
+        final firstServer = serverList.first;
+        if (firstServer['url'] is String) {
+          return [firstServer['url'] as String];
+        }
+        return [];
+      }
+
+      return selected
+          .where((server) => server['url'] is String)
+          .map((server) => server['url'] as String)
+          .toList();
+    } catch (e) {
+      debugPrint('获取服务器IP时出错: $e');
+      return [];
+    }
+  }
+
+  //设置服务器选中状态
+  void setServerSelected(String url, bool selected) {
+    final servers = serverList;
+    for (var i = 0; i < servers.length; i++) {
+      if (servers[i]['url'] == url) {
+        servers[i]['selected'] = selected;
+      }
+    }
+    serverList = servers;
+  }
+
   // 节点列表
   List<KVNodeInfo> _nodes = [];
   List<KVNodeInfo> get nodes => _nodes;

lib/utils/ping_util.dart

@@ -3,25 +3,28 @@ import 'dart:async';
 
 class PingUtil {
   static Future<int?> ping(String host) async {
+    Socket? socket;
     try {
       // 从 host:port 格式中提取主机名
       final hostname = host.split(':')[0];
-      final post = host.split(':')[1];
+      final port = host.split(':')[1]; // 修正变量名 post -> port
 
       // 使用 Socket 连接来测量实际网络延迟
       final startTime = DateTime.now();
-      final socket = await Socket.connect(hostname, int.parse(post),
+      socket = await Socket.connect(hostname, int.parse(port),
           timeout: const Duration(seconds: 2));
       final endTime = DateTime.now();
 
-      // 关闭连接
-      await socket.close();
-
+      // 计算延迟时间
       return endTime.difference(startTime).inMilliseconds;
     } on SocketException {
       return null;
     } catch (e) {
       return null;
+    } finally {
+      // 确保在所有情况下都关闭 socket 连接
+      socket?.destroy();
+      socket = null;
     }
   }
 }

lib/widgets/card.dart

@@ -1,5 +1,4 @@
 import 'package:flutter/material.dart';
-import 'dart:math' as math;
 
 class FloatingCard extends StatefulWidget {
   final ColorScheme colorScheme;
@@ -8,14 +7,8 @@ class FloatingCard extends StatefulWidget {
   final EdgeInsetsGeometry padding;
   final Duration duration;
   final double hoverElevation;
-  final double? maxWidth; // 添加最大宽度参数
-  final double? height; // 添加最大宽度参数
-  final bool enable3DEffect; // 是否启用3D效果
-  final double maxRotationDegree; // 最大旋转角度
-  final bool enableTranslateEffect; // 是否启用偏移效果
-  final double maxTranslateDistance; // 最大偏移距离
-  final double zTranslation; // Z轴偏移距离
-  final bool riseOnHover; // 控制悬浮时是升起还是降下
+  final double? maxWidth;
+  final double? height;
 
   const FloatingCard({
     super.key,
@@ -27,12 +20,6 @@ class FloatingCard extends StatefulWidget {
     this.hoverElevation = 8,
     this.maxWidth,
     this.height,
-    this.enable3DEffect = false, // 默认启用3D效果
-    this.maxRotationDegree = 10, // 默认最大旋转角度为10度
-    this.enableTranslateEffect = false, // 默认启用偏移效果
-    this.maxTranslateDistance = 0.1, // 默认最大偏移距离为5
-    this.zTranslation = 10, // 默认Z轴偏移距离为20
-    this.riseOnHover = true, // 默认悬浮时升起
   });
 
   @override
@@ -41,67 +28,12 @@ class FloatingCard extends StatefulWidget {
 
 class _FloatingCardState extends State<FloatingCard> {
   bool isHovered = false;
-  Offset mousePosition = Offset.zero;
-  final GlobalKey _cardKey = GlobalKey();
-
-  // 获取卡片的尺寸和位置
-  Rect? _getCardRect() {
-    final RenderBox? renderBox =
-        _cardKey.currentContext?.findRenderObject() as RenderBox?;
-    if (renderBox == null) return null;
-    final position = renderBox.localToGlobal(Offset.zero);
-    return Rect.fromLTWH(
-        position.dx, position.dy, renderBox.size.width, renderBox.size.height);
-  }
-
-  // 计算旋转角度
-  (double, double) _calculateRotation() {
-    final rect = _getCardRect();
-    if (rect == null) return (0, 0);
-
-    // 计算鼠标相对于卡片中心的位置
-    final centerX = rect.width / 2;
-    final centerY = rect.height / 2;
-    final deltaX = (mousePosition.dx - centerX) / centerX;
-    final deltaY = (mousePosition.dy - centerY) / centerY;
-
-    // 计算旋转角度，鼠标在右侧时向左倾斜（Y轴正向旋转），鼠标在下方时向上倾斜（X轴负向旋转）
-    final rotateY = deltaX * widget.maxRotationDegree;
-    final rotateX = -deltaY * widget.maxRotationDegree;
-
-    return (rotateX, rotateY);
-  }
 
   @override
   Widget build(BuildContext context) {
-    // 根据是否启用3D效果计算旋转角度
-    final (rotateX, rotateY) =
-        isHovered && widget.enable3DEffect ? _calculateRotation() : (0.0, 0.0);
-
-    // 根据是否启用偏移效果计算偏移距离
-    final translateX = isHovered && widget.enableTranslateEffect
-        ? rotateY * widget.maxTranslateDistance
-        : 0.0;
-    final translateY = isHovered && widget.enableTranslateEffect
-        ? rotateX * widget.maxTranslateDistance
-        : 0.0;
-
-    // 根据riseOnHover决定Z轴偏移方向
-    final zDirection = widget.riseOnHover ? 1.0 : -1.0;
-    final translateZ = isHovered && widget.enableTranslateEffect
-        ? widget.zTranslation * zDirection
-        : 0.0;
-
     return MouseRegion(
       onEnter: (_) => setState(() => isHovered = true),
       onExit: (_) => setState(() => isHovered = false),
-      onHover: (event) {
-        if (widget.enable3DEffect || widget.enableTranslateEffect) {
-          setState(() {
-            mousePosition = event.localPosition;
-          });
-        }
-      },
       cursor: SystemMouseCursors.click,
       child: Center(
         child: ConstrainedBox(
@@ -109,15 +41,7 @@ class _FloatingCardState extends State<FloatingCard> {
             maxWidth: widget.maxWidth ?? double.infinity,
           ),
           child: AnimatedContainer(
-            key: _cardKey,
             duration: widget.duration,
-            transform: Matrix4.identity()
-              ..setEntry(3, 2, 0.001) // 透视效果
-              // 仅当启用3D效果时应用旋转
-              ..rotateX(widget.enable3DEffect ? rotateX * math.pi / 180 : 0)
-              ..rotateY(widget.enable3DEffect ? rotateY * math.pi / 180 : 0)
-              // 仅当启用偏移效果时应用偏移
-              ..translate(translateX, translateY, translateZ),
             transformAlignment: Alignment.center,
             child: Card(
                 shape: RoundedRectangleBorder(

pubspec.yaml

@@ -16,7 +16,7 @@ publish_to: 'none' # Remove this line if you wish to publish to pub.dev
 # https://developer.apple.com/library/archive/documentation/General/Reference/InfoPlistKeyReference/Articles/CoreFoundationKeys.html
 # In Windows, build-name is used as the major, minor, and patch parts
 # of the product and file versions while build-number is used as the build suffix.
-version: 1.0.1
+version: 1.0.4
 
 environment:
   sdk: ^3.5.4
@@ -42,7 +42,6 @@ dependencies:
   flutter_rust_bridge: 2.9.0
   flutter_colorpicker: ^1.1.0
   window_manager: ^0.4.3
-  fl_chart: ^0.70.2
   flutter_staggered_grid_view: ^0.7.0
   json_annotation: ^4.8.1
   tray_manager: ^0.3.2
@@ -52,6 +51,7 @@ dependencies:
   yaml: ^3.1.2
   flutter_local_notifications: ^19.0.0 
   windows_notification: ^1.3.0
+  fl_chart: ^0.70.2
 
 dev_dependencies:
   flutter_test:

rust/Cargo.lock

@@ -389,6 +389,15 @@ dependencies = [
  "x25519-dalek",
 ]
 
+[[package]]
+name = "bounded_join_set"
+version = "0.3.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "ae18fd8f4a623bcf416b5bc8f1e0905534d9911597ed17cc57ab9b6eed65454d"
+dependencies = [
+ "tokio",
+]
+
 [[package]]
 name = "bstr"
 version = "1.8.0"
@@ -954,7 +963,7 @@ dependencies = [
 
 [[package]]
 name = "easytier"
-version = "2.2.2"
+version = "2.2.3"
 dependencies = [
  "anyhow",
  "async-compression",
@@ -967,6 +976,7 @@ dependencies = [
  "base64 0.22.1",
  "bitflags 2.9.0",
  "boringtun-easytier",
+ "bounded_join_set",
  "bytecodec",
  "byteorder",
  "bytes",

rust/easytier/Cargo.toml

@@ -3,7 +3,7 @@ name = "easytier"
 description = "A full meshed p2p VPN, connecting all your devices in one network with one command."
 homepage = "https://github.com/EasyTier/EasyTier"
 repository = "https://github.com/EasyTier/EasyTier"
-version = "2.2.2"
+version = "2.2.3"
 edition = "2021"
 authors = ["kkrainbow"]
 keywords = ["vpn", "p2p", "network", "easytier"]
@@ -192,6 +192,8 @@ http_req = { git = "https://github.com/EasyTier/http_req.git", default-features
 # for dns connector
 hickory-resolver = "0.24.4"
 
+bounded_join_set = "0.3.0"
+
 [target.'cfg(any(target_os = "linux", target_os = "macos", target_os = "windows", target_os = "freebsd"))'.dependencies]
 machine-uid = "0.5.3"
 

rust/easytier/src/common/config.rs

@@ -27,7 +27,6 @@ pub fn gen_default_flags() -> Flags {
         disable_p2p: false,
         relay_all_peer_rpc: false,
         disable_udp_hole_punching: false,
-        ipv6_listener: "udp://[::]:0".to_string(),
         multi_thread: true,
         data_compress_algo: CompressionAlgoPb::None.into(),
         bind_device: true,

rust/easytier/src/common/constants.rs

@@ -29,7 +29,7 @@ pub const WIN_SERVICE_WORK_DIR_REG_KEY: &str = "SOFTWARE\\EasyTier\\Service\\Wor
 
 pub const EASYTIER_VERSION: &str = git_version::git_version!(
     args = ["--abbrev=8", "--always", "--dirty=~"],
-    prefix = concat!(env!("CARGO_PKG_VERSION"), "-@astral "),
+    prefix = concat!(env!("CARGO_PKG_VERSION"), "-"),
     suffix = "",
-    fallback = env!("CARGO_PKG_VERSION")
+    fallback = "astral"
 );

rust/easytier/src/common/stun.rs

@@ -1,5 +1,5 @@
 use std::collections::BTreeSet;
-use std::net::{IpAddr, SocketAddr};
+use std::net::{IpAddr, Ipv6Addr, SocketAddr};
 use std::sync::atomic::AtomicBool;
 use std::sync::{Arc, RwLock};
 use std::time::{Duration, Instant};
@@ -8,6 +8,8 @@ use crate::proto::common::{NatType, StunInfo};
 use anyhow::Context;
 use chrono::Local;
 use crossbeam::atomic::AtomicCell;
+use hickory_resolver::config::{NameServerConfig, Protocol, ResolverConfig, ResolverOpts};
+use hickory_resolver::TokioAsyncResolver;
 use rand::seq::IteratorRandom;
 use tokio::net::{lookup_host, UdpSocket};
 use tokio::sync::{broadcast, Mutex};
@@ -22,21 +24,68 @@ use crate::common::error::Error;
 
 use super::stun_codec_ext::*;
 
+pub fn get_default_resolver_config() -> ResolverConfig {
+    let mut default_resolve_config = ResolverConfig::new();
+    default_resolve_config.add_name_server(NameServerConfig::new(
+        "223.5.5.5:53".parse().unwrap(),
+        Protocol::Udp,
+    ));
+    default_resolve_config.add_name_server(NameServerConfig::new(
+        "180.184.1.1:53".parse().unwrap(),
+        Protocol::Udp,
+    ));
+    default_resolve_config
+}
+
+pub async fn resolve_txt_record(
+    domain_name: &str,
+    resolver: &TokioAsyncResolver,
+) -> Result<String, Error> {
+    let response = resolver.txt_lookup(domain_name).await.with_context(|| {
+        format!(
+            "txt_lookup failed, domain_name: {}",
+            domain_name.to_string()
+        )
+    })?;
+
+    let txt_record = response.iter().next().with_context(|| {
+        format!(
+            "no txt record found, domain_name: {}",
+            domain_name.to_string()
+        )
+    })?;
+
+    let txt_data = String::from_utf8_lossy(&txt_record.txt_data()[0]);
+    tracing::info!(?txt_data, ?domain_name, "get txt record");
+
+    Ok(txt_data.to_string())
+}
+
 struct HostResolverIter {
     hostnames: Vec<String>,
     ips: Vec<SocketAddr>,
     max_ip_per_domain: u32,
+    use_ipv6: bool,
 }
 
 impl HostResolverIter {
-    fn new(hostnames: Vec<String>, max_ip_per_domain: u32) -> Self {
+    fn new(hostnames: Vec<String>, max_ip_per_domain: u32, use_ipv6: bool) -> Self {
         Self {
             hostnames,
             ips: vec![],
             max_ip_per_domain,
+            use_ipv6,
         }
     }
 
+    async fn get_txt_record(domain_name: &str) -> Result<Vec<String>, Error> {
+        let resolver = TokioAsyncResolver::tokio_from_system_conf().unwrap_or(
+            TokioAsyncResolver::tokio(get_default_resolver_config(), ResolverOpts::default()),
+        );
+        let txt_data = resolve_txt_record(domain_name, &resolver).await?;
+        Ok(txt_data.split(" ").map(|x| x.to_string()).collect())
+    }
+
     #[async_recursion::async_recursion]
     async fn next(&mut self) -> Option<SocketAddr> {
         if self.ips.is_empty() {
@@ -51,10 +100,35 @@ impl HostResolverIter {
                 format!("{}:3478", host)
             };
 
+            if host.starts_with("txt:") {
+                let domain_name = host.trim_start_matches("txt:");
+                match Self::get_txt_record(domain_name).await {
+                    Ok(hosts) => {
+                        tracing::info!(
+                            ?domain_name,
+                            ?hosts,
+                            "get txt record success when resolve stun server"
+                        );
+                        // insert hosts to the head of hostnames
+                        self.hostnames.splice(0..0, hosts.into_iter());
+                    }
+                    Err(e) => {
+                        tracing::warn!(
+                            ?domain_name,
+                            ?e,
+                            "get txt record failed when resolve stun server"
+                        );
+                    }
+                }
+                return self.next().await;
+            }
+
+            let use_ipv6 = self.use_ipv6;
+
             match lookup_host(&host).await {
                 Ok(ips) => {
                     self.ips = ips
-                        .filter(|x| x.is_ipv4())
+                        .filter(|x| if use_ipv6 { x.is_ipv6() } else { x.is_ipv4() })
                         .choose_multiple(&mut rand::thread_rng(), self.max_ip_per_domain as usize);
 
                     if self.ips.is_empty() {
@@ -400,7 +474,7 @@ impl UdpNatTypeDetectResult {
         // find resp with distinct stun server
         self.stun_resps
             .iter()
-            .map(|x| x.stun_server_addr)
+            .map(|x| x.recv_from_addr)
             .collect::<BTreeSet<_>>()
             .len()
     }
@@ -555,8 +629,11 @@ impl UdpNatTypeDetector {
         udp: Arc<UdpSocket>,
     ) -> Result<UdpNatTypeDetectResult, Error> {
         let mut stun_servers = vec![];
-        let mut host_resolver =
-            HostResolverIter::new(self.stun_server_hosts.clone(), self.max_ip_per_domain);
+        let mut host_resolver = HostResolverIter::new(
+            self.stun_server_hosts.clone(),
+            self.max_ip_per_domain,
+            false,
+        );
         while let Some(addr) = host_resolver.next().await {
             stun_servers.push(addr);
         }
@@ -602,7 +679,9 @@ pub trait StunInfoCollectorTrait: Send + Sync {
 
 pub struct StunInfoCollector {
     stun_servers: Arc<RwLock<Vec<String>>>,
+    stun_servers_v6: Arc<RwLock<Vec<String>>>,
     udp_nat_test_result: Arc<RwLock<Option<UdpNatTypeDetectResult>>>,
+    public_ipv6: Arc<AtomicCell<Option<Ipv6Addr>>>,
     nat_test_result_time: Arc<AtomicCell<chrono::DateTime<Local>>>,
     redetect_notify: Arc<tokio::sync::Notify>,
     tasks: std::sync::Mutex<JoinSet<()>>,
@@ -621,7 +700,12 @@ impl StunInfoCollectorTrait for StunInfoCollector {
             udp_nat_type: result.nat_type() as i32,
             tcp_nat_type: 0,
             last_update_time: self.nat_test_result_time.load().timestamp(),
-            public_ip: result.public_ips().iter().map(|x| x.to_string()).collect(),
+            public_ip: result
+                .public_ips()
+                .iter()
+                .map(|x| x.to_string())
+                .chain(self.public_ipv6.load().map(|x| x.to_string()))
+                .collect(),
             min_port: result.min_port() as u32,
             max_port: result.max_port() as u32,
         }
@@ -640,7 +724,7 @@ impl StunInfoCollectorTrait for StunInfoCollector {
 
         if stun_servers.is_empty() {
             let mut host_resolver =
-                HostResolverIter::new(self.stun_servers.read().unwrap().clone(), 2);
+                HostResolverIter::new(self.stun_servers.read().unwrap().clone(), 2, false);
             while let Some(addr) = host_resolver.next().await {
                 stun_servers.push(addr);
                 if stun_servers.len() >= 2 {
@@ -680,7 +764,9 @@ impl StunInfoCollector {
     pub fn new(stun_servers: Vec<String>) -> Self {
         Self {
             stun_servers: Arc::new(RwLock::new(stun_servers)),
+            stun_servers_v6: Arc::new(RwLock::new(Self::get_default_servers_v6())),
             udp_nat_test_result: Arc::new(RwLock::new(None)),
+            public_ipv6: Arc::new(AtomicCell::new(None)),
             nat_test_result_time: Arc::new(AtomicCell::new(Local::now())),
             redetect_notify: Arc::new(tokio::sync::Notify::new()),
             tasks: std::sync::Mutex::new(JoinSet::new()),
@@ -696,28 +782,42 @@ impl StunInfoCollector {
         // NOTICE: we may need to choose stun stun server based on geo location
         // stun server cross nation may return a external ip address with high latency and loss rate
         vec![
+            "txt:stun.easytier.cn",
             "stun.miwifi.com",
             "stun.chat.bilibili.com",
             "stun.hitv.com",
-            "stun.cdnbye.com",
-            "stun.douyucdn.cn:18000",
-            "fwa.lifesizecloud.com",
-            "global.turn.twilio.com",
-            "turn.cloudflare.com",
-            "stun.isp.net.au",
-            "stun.nextcloud.com",
-            "stun.freeswitch.org",
-            "stun.voip.blackberry.com",
-            "stunserver.stunprotocol.org",
-            "stun.sipnet.com",
-            "stun.radiojar.com",
-            "stun.sonetel.com",
         ]
         .iter()
         .map(|x| x.to_string())
         .collect()
     }
 
+    pub fn get_default_servers_v6() -> Vec<String> {
+        vec!["txt:stun-v6.easytier.cn"]
+            .iter()
+            .map(|x| x.to_string())
+            .collect()
+    }
+
+    async fn get_public_ipv6(servers: &Vec<String>) -> Option<Ipv6Addr> {
+        let mut ips = HostResolverIter::new(servers.to_vec(), 10, true);
+        while let Some(ip) = ips.next().await {
+            let udp = Arc::new(UdpSocket::bind(format!("[::]:0")).await.unwrap());
+            let ret = StunClientBuilder::new(udp.clone())
+                .new_stun_client(ip)
+                .bind_request(false, false)
+                .await;
+            tracing::debug!(?ret, "finish ipv6 udp nat type detect");
+            match ret.map(|x| x.mapped_socket_addr.map(|x| x.ip())) {
+                Ok(Some(IpAddr::V6(v6))) => {
+                    return Some(v6);
+                }
+                _ => {}
+            }
+        }
+        None
+    }
+
     fn start_stun_routine(&self) {
         if self.started.load(std::sync::atomic::Ordering::Relaxed) {
             return;
@@ -784,6 +884,30 @@ impl StunInfoCollector {
                 }
             }
         });
+
+        // for ipv6
+        let stun_servers = self.stun_servers_v6.clone();
+        let stored_ipv6 = self.public_ipv6.clone();
+        let redetect_notify = self.redetect_notify.clone();
+        self.tasks.lock().unwrap().spawn(async move {
+            loop {
+                let servers = stun_servers.read().unwrap().clone();
+                Self::get_public_ipv6(&servers)
+                    .await
+                    .map(|x| stored_ipv6.store(Some(x)));
+
+                let sleep_sec = if stored_ipv6.load().is_none() {
+                    60
+                } else {
+                    360
+                };
+
+                tokio::select! {
+                    _ = redetect_notify.notified() => {}
+                    _ = tokio::time::sleep(Duration::from_secs(sleep_sec)) => {}
+                }
+            }
+        });
     }
 
     pub fn update_stun_info(&self) {
@@ -862,6 +986,48 @@ mod tests {
         let detector = UdpNatTypeDetector::new(stun_servers, 1);
         let ret = detector.detect_nat_type(0).await;
         println!("{:#?}, {:?}", ret, ret.as_ref().unwrap().nat_type());
-        assert_eq!(ret.unwrap().nat_type(), NatType::PortRestricted);
+        assert_eq!(ret.unwrap().nat_type(), NatType::Restricted);
+    }
+
+    #[tokio::test]
+    async fn test_txt_public_stun_server() {
+        let stun_servers = vec!["txt:stun.easytier.cn".to_string()];
+        let detector = UdpNatTypeDetector::new(stun_servers, 1);
+        let ret = detector.detect_nat_type(0).await;
+        println!("{:#?}, {:?}", ret, ret.as_ref().unwrap().nat_type());
+        assert!(!ret.unwrap().stun_resps.is_empty());
+    }
+
+    #[tokio::test]
+    async fn test_v4_stun() {
+        let mut udp_server = UdpTunnelListener::new("udp://0.0.0.0:55355".parse().unwrap());
+        let mut tasks = JoinSet::new();
+        tasks.spawn(async move {
+            udp_server.listen().await.unwrap();
+            loop {
+                udp_server.accept().await.unwrap();
+            }
+        });
+        let stun_servers = vec!["127.0.0.1:55355".to_string()];
+
+        let detector = UdpNatTypeDetector::new(stun_servers, 1);
+        let ret = detector.detect_nat_type(0).await;
+        println!("{:#?}, {:?}", ret, ret.as_ref().unwrap().nat_type());
+        assert_eq!(ret.unwrap().nat_type(), NatType::Restricted);
+    }
+
+    #[tokio::test]
+    async fn test_v6_stun() {
+        let mut udp_server = UdpTunnelListener::new("udp://[::]:55355".parse().unwrap());
+        let mut tasks = JoinSet::new();
+        tasks.spawn(async move {
+            udp_server.listen().await.unwrap();
+            loop {
+                udp_server.accept().await.unwrap();
+            }
+        });
+        let stun_servers = vec!["::1:55355".to_string()];
+        let ret = StunInfoCollector::get_public_ipv6(&stun_servers).await;
+        println!("{:#?}", ret);
     }
 }

rust/easytier/src/connector/direct.rs

@@ -1,7 +1,9 @@
 // try connect peers directly, with either its public ip or lan ip
 
 use std::{
-    net::SocketAddr,
+    collections::HashSet,
+    net::{Ipv6Addr, SocketAddr},
+    str::FromStr,
     sync::{
         atomic::{AtomicBool, Ordering},
         Arc,
@@ -79,7 +81,6 @@ struct DstListenerUrlBlackListItem(PeerId, url::Url);
 struct DirectConnectorManagerData {
     global_ctx: ArcGlobalCtx,
     peer_manager: Arc<PeerManager>,
-    dst_blacklist: timedmap::TimedMap<DstBlackListItem, ()>,
     dst_listener_blacklist: timedmap::TimedMap<DstListenerUrlBlackListItem, ()>,
 }
 
@@ -88,7 +89,6 @@ impl DirectConnectorManagerData {
         Self {
             global_ctx,
             peer_manager,
-            dst_blacklist: timedmap::TimedMap::new(),
             dst_listener_blacklist: timedmap::TimedMap::new(),
         }
     }
@@ -150,7 +150,9 @@ impl DirectConnectorManager {
                     let peers = data.peer_manager.list_peers().await;
                     let mut tasks = JoinSet::new();
                     for peer_id in peers {
-                        if peer_id == my_peer_id {
+                        if peer_id == my_peer_id
+                            || data.peer_manager.has_directly_connected_conn(peer_id)
+                        {
                             continue;
                         }
                         tasks.spawn(Self::do_try_direct_connect(data.clone(), peer_id));
@@ -173,24 +175,13 @@ impl DirectConnectorManager {
         dst_peer_id: PeerId,
         addr: String,
     ) -> Result<(), Error> {
-        data.dst_blacklist.cleanup();
-        if data
-            .dst_blacklist
-            .contains(&DstBlackListItem(dst_peer_id.clone(), addr.clone()))
-        {
-            tracing::debug!("try_connect_to_ip failed, addr in blacklist: {}", addr);
-            return Err(Error::UrlInBlacklist);
-        }
-
         let connector = create_connector_by_url(&addr, &data.global_ctx).await?;
         let (peer_id, conn_id) = timeout(
-            std::time::Duration::from_secs(5),
-            data.peer_manager.try_connect(connector),
+            std::time::Duration::from_secs(3),
+            data.peer_manager.try_direct_connect(connector),
         )
         .await??;
 
-        // let (peer_id, conn_id) = data.peer_manager.try_connect(connector).await?;
-
         if peer_id != dst_peer_id && !TESTING.load(Ordering::Relaxed) {
             tracing::info!(
                 "connect to ip succ: {}, but peer id mismatch, expect: {}, actual: {}",
@@ -204,6 +195,7 @@ impl DirectConnectorManager {
                 .await?;
             return Err(Error::InvalidUrl(addr));
         }
+
         Ok(())
     }
 
@@ -214,7 +206,7 @@ impl DirectConnectorManager {
         addr: String,
     ) -> Result<(), Error> {
         let mut rand_gen = rand::rngs::OsRng::default();
-        let backoff_ms = vec![1000, 2000, 4000];
+        let backoff_ms = vec![1000, 2000];
         let mut backoff_idx = 0;
 
         loop {
@@ -237,12 +229,6 @@ impl DirectConnectorManager {
                 backoff_idx += 1;
                 continue;
             } else {
-                data.dst_blacklist.insert(
-                    DstBlackListItem(dst_peer_id.clone(), addr.clone()),
-                    (),
-                    std::time::Duration::from_secs(DIRECT_CONNECTOR_BLACKLIST_TIMEOUT_SEC),
-                );
-
                 return ret;
             }
         }
@@ -273,61 +259,43 @@ impl DirectConnectorManager {
 
         tracing::debug!(?available_listeners, "got available listeners");
 
-        let mut listener = available_listeners.get(0).ok_or(anyhow::anyhow!(
-            "peer {} have no valid listener",
-            dst_peer_id
-        ))?;
+        if available_listeners.is_empty() {
+            return Err(anyhow::anyhow!("peer {} have no valid listener", dst_peer_id).into());
+        }
 
         // if have default listener, use it first
-        listener = available_listeners
+        let listener = available_listeners
             .iter()
             .find(|l| l.scheme() == data.global_ctx.get_flags().default_protocol)
-            .unwrap_or(listener);
+            .unwrap_or(available_listeners.get(0).unwrap());
 
-        let mut tasks = JoinSet::new();
+        let mut tasks = bounded_join_set::JoinSet::new(2);
 
         let listener_host = listener.socket_addrs(|| None).unwrap().pop();
         match listener_host {
             Some(SocketAddr::V4(s_addr)) => {
                 if s_addr.ip().is_unspecified() {
-                    ip_list.interface_ipv4s.iter().for_each(|ip| {
-                        let mut addr = (*listener).clone();
-                        if addr.set_host(Some(ip.to_string().as_str())).is_ok() {
-                            tasks.spawn(Self::try_connect_to_ip(
-                                data.clone(),
-                                dst_peer_id.clone(),
-                                addr.to_string(),
-                            ));
-                        } else {
-                            tracing::error!(
-                                ?ip,
-                                ?listener,
-                                ?dst_peer_id,
-                                "failed to set host for interface ipv4"
-                            );
-                        }
-                    });
-
-                    if let Some(public_ipv4) = ip_list.public_ipv4 {
-                        let mut addr = (*listener).clone();
-                        if addr
-                            .set_host(Some(public_ipv4.to_string().as_str()))
-                            .is_ok()
-                        {
-                            tasks.spawn(Self::try_connect_to_ip(
-                                data.clone(),
-                                dst_peer_id.clone(),
-                                addr.to_string(),
-                            ));
-                        } else {
-                            tracing::error!(
-                                ?public_ipv4,
-                                ?listener,
-                                ?dst_peer_id,
-                                "failed to set host for public ipv4"
-                            );
-                        }
-                    }
+                    ip_list
+                        .interface_ipv4s
+                        .iter()
+                        .chain(ip_list.public_ipv4.iter())
+                        .for_each(|ip| {
+                            let mut addr = (*listener).clone();
+                            if addr.set_host(Some(ip.to_string().as_str())).is_ok() {
+                                tasks.spawn(Self::try_connect_to_ip(
+                                    data.clone(),
+                                    dst_peer_id.clone(),
+                                    addr.to_string(),
+                                ));
+                            } else {
+                                tracing::error!(
+                                    ?ip,
+                                    ?listener,
+                                    ?dst_peer_id,
+                                    "failed to set host for interface ipv4"
+                                );
+                            }
+                        });
                 } else if !s_addr.ip().is_loopback() || TESTING.load(Ordering::Relaxed) {
                     tasks.spawn(Self::try_connect_to_ip(
                         data.clone(),
@@ -338,47 +306,42 @@ impl DirectConnectorManager {
             }
             Some(SocketAddr::V6(s_addr)) => {
                 if s_addr.ip().is_unspecified() {
-                    ip_list.interface_ipv6s.iter().for_each(|ip| {
-                        let mut addr = (*listener).clone();
-                        if addr
-                            .set_host(Some(format!("[{}]", ip.to_string()).as_str()))
-                            .is_ok()
-                        {
-                            tasks.spawn(Self::try_connect_to_ip(
-                                data.clone(),
-                                dst_peer_id.clone(),
-                                addr.to_string(),
-                            ));
-                        } else {
-                            tracing::error!(
-                                ?ip,
-                                ?listener,
-                                ?dst_peer_id,
-                                "failed to set host for interface ipv6"
-                            );
-                        }
-                    });
-
-                    if let Some(public_ipv6) = ip_list.public_ipv6 {
-                        let mut addr = (*listener).clone();
-                        if addr
-                            .set_host(Some(format!("[{}]", public_ipv6.to_string()).as_str()))
-                            .is_ok()
-                        {
-                            tasks.spawn(Self::try_connect_to_ip(
-                                data.clone(),
-                                dst_peer_id.clone(),
-                                addr.to_string(),
-                            ));
-                        } else {
-                            tracing::error!(
-                                ?public_ipv6,
-                                ?listener,
-                                ?dst_peer_id,
-                                "failed to set host for public ipv6"
-                            );
-                        }
-                    }
+                    // for ipv6, only try public ip
+                    ip_list
+                        .interface_ipv6s
+                        .iter()
+                        .chain(ip_list.public_ipv6.iter())
+                        .filter_map(|x| Ipv6Addr::from_str(&x.to_string()).ok())
+                        .filter(|x| {
+                            TESTING.load(Ordering::Relaxed)
+                                || (!x.is_loopback()
+                                    && !x.is_unspecified()
+                                    && !x.is_unique_local()
+                                    && !x.is_unicast_link_local()
+                                    && !x.is_multicast())
+                        })
+                        .collect::<HashSet<_>>()
+                        .iter()
+                        .for_each(|ip| {
+                            let mut addr = (*listener).clone();
+                            if addr
+                                .set_host(Some(format!("[{}]", ip.to_string()).as_str()))
+                                .is_ok()
+                            {
+                                tasks.spawn(Self::try_connect_to_ip(
+                                    data.clone(),
+                                    dst_peer_id.clone(),
+                                    addr.to_string(),
+                                ));
+                            } else {
+                                tracing::error!(
+                                    ?ip,
+                                    ?listener,
+                                    ?dst_peer_id,
+                                    "failed to set host for public ipv6"
+                                );
+                            }
+                        });
                 } else if !s_addr.ip().is_loopback() || TESTING.load(Ordering::Relaxed) {
                     tasks.spawn(Self::try_connect_to_ip(
                         data.clone(),
@@ -430,14 +393,6 @@ impl DirectConnectorManager {
         dst_peer_id: PeerId,
     ) -> Result<(), Error> {
         let peer_manager = data.peer_manager.clone();
-        // check if we have direct connection with dst_peer_id
-        if let Some(c) = peer_manager.list_peer_conns(dst_peer_id).await {
-            // currently if we have any type of direct connection (udp or tcp), we will not try to connect
-            if !c.is_empty() {
-                return Ok(());
-            }
-        }
-
         tracing::debug!("try direct connect to peer: {}", dst_peer_id);
 
         let rpc_stub = peer_manager
@@ -466,8 +421,7 @@ mod tests {
 
     use crate::{
         connector::direct::{
-            DirectConnectorManager, DirectConnectorManagerData, DstBlackListItem,
-            DstListenerUrlBlackListItem,
+            DirectConnectorManager, DirectConnectorManagerData, DstListenerUrlBlackListItem,
         },
         instance::listeners::ListenerManager,
         peers::tests::{
@@ -526,9 +480,7 @@ mod tests {
         #[values("tcp", "udp", "wg")] proto: &str,
         #[values("true", "false")] ipv6: bool,
     ) {
-        if ipv6 && proto != "udp" {
-            return;
-        }
+        TESTING.store(true, std::sync::atomic::Ordering::Relaxed);
 
         let p_a = create_mock_peer_manager().await;
         let p_b = create_mock_peer_manager().await;
@@ -544,14 +496,18 @@ mod tests {
         dm_a.run_as_client();
         dm_c.run_as_server();
 
+        let port = if proto == "wg" { 11040 } else { 11041 };
         if !ipv6 {
-            let port = if proto == "wg" { 11040 } else { 11041 };
             p_c.get_global_ctx().config.set_listeners(vec![format!(
                 "{}://0.0.0.0:{}",
                 proto, port
             )
             .parse()
             .unwrap()]);
+        } else {
+            p_c.get_global_ctx()
+                .config
+                .set_listeners(vec![format!("{}://[::]:{}", proto, port).parse().unwrap()]);
         }
         let mut f = p_c.get_global_ctx().config.get_flags();
         f.enable_ipv6 = ipv6;
@@ -592,9 +548,5 @@ mod tests {
                 1,
                 "tcp://127.0.0.1:10222".parse().unwrap()
             )));
-
-        assert!(data
-            .dst_blacklist
-            .contains(&DstBlackListItem(1, ip_list.listeners[0].to_string())));
     }
 }

rust/easytier/src/connector/dns_connector.rs

@@ -1,13 +1,17 @@
 use std::{net::SocketAddr, sync::Arc};
 
 use crate::{
-    common::{error::Error, global_ctx::ArcGlobalCtx},
-    tunnel::{Tunnel, TunnelConnector, TunnelError, PROTO_PORT_OFFSET},
+    common::{
+        error::Error,
+        global_ctx::ArcGlobalCtx,
+        stun::{get_default_resolver_config, resolve_txt_record},
+    },
+    tunnel::{IpVersion, Tunnel, TunnelConnector, TunnelError, PROTO_PORT_OFFSET},
 };
 use anyhow::Context;
 use dashmap::DashSet;
 use hickory_resolver::{
-    config::{NameServerConfig, Protocol, ResolverConfig, ResolverOpts},
+    config::{ResolverConfig, ResolverOpts},
     proto::rr::rdata::SRV,
     TokioAsyncResolver,
 };
@@ -38,6 +42,7 @@ pub struct DNSTunnelConnector {
     addr: url::Url,
     bind_addrs: Vec<SocketAddr>,
     global_ctx: ArcGlobalCtx,
+    ip_version: IpVersion,
 
     default_resolve_config: ResolverConfig,
     default_resolve_opts: ResolverOpts,
@@ -45,21 +50,13 @@ pub struct DNSTunnelConnector {
 
 impl DNSTunnelConnector {
     pub fn new(addr: url::Url, global_ctx: ArcGlobalCtx) -> Self {
-        let mut default_resolve_config = ResolverConfig::new();
-        default_resolve_config.add_name_server(NameServerConfig::new(
-            "223.5.5.5:53".parse().unwrap(),
-            Protocol::Udp,
-        ));
-        default_resolve_config.add_name_server(NameServerConfig::new(
-            "180.184.1.1:53".parse().unwrap(),
-            Protocol::Udp,
-        ));
         Self {
             addr,
             bind_addrs: Vec::new(),
             global_ctx,
+            ip_version: IpVersion::Both,
 
-            default_resolve_config,
+            default_resolve_config: get_default_resolver_config(),
             default_resolve_opts: ResolverOpts::default(),
         }
     }
@@ -69,26 +66,14 @@ impl DNSTunnelConnector {
         &self,
         domain_name: &str,
     ) -> Result<Box<dyn TunnelConnector>, Error> {
-        let resolver = TokioAsyncResolver::tokio_from_system_conf().unwrap_or(
-            TokioAsyncResolver::tokio(ResolverConfig::default(), ResolverOpts::default()),
-        );
-
-        let response = resolver.txt_lookup(domain_name).await.with_context(|| {
-            format!(
-                "txt_lookup failed, domain_name: {}",
-                domain_name.to_string()
-            )
-        })?;
-
-        let txt_record = response.iter().next().with_context(|| {
-            format!(
-                "no txt record found, domain_name: {}",
-                domain_name.to_string()
-            )
-        })?;
-
-        let txt_data = String::from_utf8_lossy(&txt_record.txt_data()[0]);
-        tracing::info!(?txt_data, ?domain_name, "get txt record");
+        let resolver =
+            TokioAsyncResolver::tokio_from_system_conf().unwrap_or(TokioAsyncResolver::tokio(
+                self.default_resolve_config.clone(),
+                self.default_resolve_opts.clone(),
+            ));
+        let txt_data = resolve_txt_record(domain_name, &resolver)
+            .await
+            .with_context(|| format!("resolve txt record failed, domain_name: {}", domain_name))?;
 
         let candidate_urls = txt_data
             .split(" ")
@@ -106,9 +91,9 @@ impl DNSTunnelConnector {
                 )
             })?;
 
-        let connector = create_connector_by_url(url.as_str(), &self.global_ctx).await;
-
-        connector
+        let mut connector = create_connector_by_url(url.as_str(), &self.global_ctx).await?;
+        connector.set_ip_version(self.ip_version);
+        Ok(connector)
     }
 
     fn handle_one_srv_record(record: &SRV, protocol: &str) -> Result<(url::Url, u64), Error> {
@@ -141,9 +126,11 @@ impl DNSTunnelConnector {
     ) -> Result<Box<dyn TunnelConnector>, Error> {
         tracing::info!("handle_srv_record: {}", domain_name);
 
-        let resolver = TokioAsyncResolver::tokio_from_system_conf().unwrap_or(
-            TokioAsyncResolver::tokio(ResolverConfig::default(), ResolverOpts::default()),
-        );
+        let resolver =
+            TokioAsyncResolver::tokio_from_system_conf().unwrap_or(TokioAsyncResolver::tokio(
+                self.default_resolve_config.clone(),
+                self.default_resolve_opts.clone(),
+            ));
 
         let srv_domains = PROTO_PORT_OFFSET
             .iter()
@@ -192,8 +179,9 @@ impl DNSTunnelConnector {
             )
         })?;
 
-        let connector = create_connector_by_url(url.as_str(), &self.global_ctx).await;
-        connector
+        let mut connector = create_connector_by_url(url.as_str(), &self.global_ctx).await?;
+        connector.set_ip_version(self.ip_version);
+        Ok(connector)
     }
 }
 
@@ -238,6 +226,10 @@ impl super::TunnelConnector for DNSTunnelConnector {
     fn set_bind_addrs(&mut self, addrs: Vec<SocketAddr>) {
         self.bind_addrs = addrs;
     }
+
+    fn set_ip_version(&mut self, ip_version: IpVersion) {
+        self.ip_version = ip_version;
+    }
 }
 
 #[cfg(test)]

rust/easytier/src/connector/manual.rs

@@ -293,7 +293,6 @@ impl ManualConnectorManager {
         ip_version: IpVersion,
     ) -> Result<ReconnResult, Error> {
         let ip_collector = data.global_ctx.get_ip_collector();
-        let net_ns = data.net_ns.clone();
 
         connector.lock().await.set_ip_version(ip_version);
 
@@ -309,18 +308,11 @@ impl ManualConnectorManager {
         data.global_ctx.issue_event(GlobalCtxEvent::Connecting(
             connector.lock().await.remote_url().clone(),
         ));
-
-        let _g = net_ns.guard();
         tracing::info!("reconnect try connect... conn: {:?}", connector);
-        let tunnel = connector.lock().await.connect().await?;
-        tracing::info!("reconnect get tunnel succ: {:?}", tunnel);
-        assert_eq!(
-            dead_url,
-            tunnel.info().unwrap().remote_addr.unwrap().to_string(),
-            "info: {:?}",
-            tunnel.info()
-        );
-        let (peer_id, conn_id) = data.peer_manager.add_client_tunnel(tunnel).await?;
+        let (peer_id, conn_id) = data
+            .peer_manager
+            .try_direct_connect(connector.lock().await.as_mut())
+            .await?;
         tracing::info!("reconnect succ: {} {} {}", peer_id, conn_id, dead_url);
         Ok(ReconnResult {
             dead_url,

rust/easytier/src/connector/udp_hole_punch/common.rs

@@ -388,7 +388,7 @@ impl UdpHolePunchListener {
                 tracing::warn!(?conn, "udp hole punching listener got peer connection");
                 let peer_mgr = peer_mgr.clone();
                 tokio::spawn(async move {
-                    if let Err(e) = peer_mgr.add_tunnel_as_server(conn).await {
+                    if let Err(e) = peer_mgr.add_tunnel_as_server(conn, false).await {
                         tracing::error!(
                             ?e,
                             "failed to add tunnel as server in hole punch listener"

rust/easytier/src/easytier-cli.rs

@@ -1,8 +1,14 @@
 use std::{
-    ffi::OsString, fmt::Write, net::SocketAddr, path::PathBuf, sync::Mutex, time::Duration, vec,
+    ffi::OsString,
+    fmt::Write,
+    net::{IpAddr, SocketAddr},
+    path::PathBuf,
+    sync::Mutex,
+    time::Duration,
+    vec,
 };
 
-use anyhow::{Context, Ok};
+use anyhow::Context;
 use clap::{command, Args, Parser, Subcommand};
 use humansize::format_size;
 use service_manager::*;
@@ -311,7 +317,11 @@ impl CommandHandler {
                     ipv4: route.ipv4_addr.map(|ip| ip.to_string()).unwrap_or_default(),
                     hostname: route.hostname.clone(),
                     cost: cost_to_str(route.cost),
-                    lat_ms: float_to_str(p.get_latency_ms().unwrap_or(0.0), 3),
+                    lat_ms: if route.cost == 1 {
+                        float_to_str(p.get_latency_ms().unwrap_or(0.0), 3)
+                    } else {
+                        route.path_latency_latency_first().to_string()
+                    },
                     loss_rate: float_to_str(p.get_loss_rate().unwrap_or(0.0), 3),
                     rx_bytes: format_size(p.get_rx_bytes().unwrap_or(0), humansize::DECIMAL),
                     tx_bytes: format_size(p.get_tx_bytes().unwrap_or(0), humansize::DECIMAL),
@@ -1036,6 +1046,7 @@ async fn main() -> Result<(), Error> {
             match sub_cmd.sub_command {
                 Some(NodeSubCommand::Info) | None => {
                     let stun_info = node_info.stun_info.clone().unwrap_or_default();
+                    let ip_list = node_info.ip_list.clone().unwrap_or_default();
 
                     let mut builder = tabled::builder::Builder::default();
                     builder.push_record(vec!["Virtual IP", node_info.ipv4_addr.as_str()]);
@@ -1045,11 +1056,32 @@ async fn main() -> Result<(), Error> {
                         node_info.proxy_cidrs.join(", ").as_str(),
                     ]);
                     builder.push_record(vec!["Peer ID", node_info.peer_id.to_string().as_str()]);
-                    builder.push_record(vec!["Public IP", stun_info.public_ip.join(", ").as_str()]);
+                    stun_info.public_ip.iter().for_each(|ip| {
+                        let Ok(ip) = ip.parse::<IpAddr>() else {
+                            return;
+                        };
+                        if ip.is_ipv4() {
+                            builder.push_record(vec!["Public IPv4", ip.to_string().as_str()]);
+                        } else {
+                            builder.push_record(vec!["Public IPv6", ip.to_string().as_str()]);
+                        }
+                    });
                     builder.push_record(vec![
                         "UDP Stun Type",
                         format!("{:?}", stun_info.udp_nat_type()).as_str(),
                     ]);
+                    ip_list.interface_ipv4s.iter().for_each(|ip| {
+                        builder.push_record(vec![
+                            "Interface IPv4",
+                            format!("{}", ip.to_string()).as_str(),
+                        ]);
+                    });
+                    ip_list.interface_ipv6s.iter().for_each(|ip| {
+                        builder.push_record(vec![
+                            "Interface IPv6",
+                            format!("{}", ip.to_string()).as_str(),
+                        ]);
+                    });
                     for (idx, l) in node_info.listeners.iter().enumerate() {
                         if l.starts_with("ring") {
                             continue;

rust/easytier/src/easytier-core.rs

@@ -308,12 +308,6 @@ struct Cli {
     )]
     socks5: Option<u16>,
 
-    #[arg(
-        long,
-        help = t!("core_clap.ipv6_listener").to_string()
-    )]
-    ipv6_listener: Option<String>,
-
     #[arg(
         long,
         help = t!("core_clap.compression").to_string(),
@@ -576,11 +570,6 @@ impl TryFrom<&Cli> for TomlConfigLoader {
         f.disable_p2p = cli.disable_p2p;
         f.disable_udp_hole_punching = cli.disable_udp_hole_punching;
         f.relay_all_peer_rpc = cli.relay_all_peer_rpc;
-        if let Some(ipv6_listener) = cli.ipv6_listener.as_ref() {
-            f.ipv6_listener = ipv6_listener
-                .parse()
-                .with_context(|| format!("failed to parse ipv6 listener: {}", ipv6_listener))?
-        }
         f.multi_thread = cli.multi_thread;
         f.data_compress_algo = match cli.compression.as_str() {
             "none" => CompressionAlgoPb::None,

rust/easytier/src/instance/listeners.rs

@@ -1,5 +1,6 @@
 use std::{fmt::Debug, sync::Arc};
 
+use anyhow::Context;
 use async_trait::async_trait;
 use tokio::task::JoinSet;
 
@@ -49,6 +50,10 @@ pub fn get_listener_by_url(
     })
 }
 
+pub fn is_url_host_ipv6(l: &url::Url) -> bool {
+    l.host_str().map_or(false, |h| h.contains(':'))
+}
+
 #[async_trait]
 pub trait TunnelHandlerForListener {
     async fn handle_tunnel(&self, tunnel: Box<dyn Tunnel>) -> Result<(), Error>;
@@ -58,7 +63,7 @@ pub trait TunnelHandlerForListener {
 impl TunnelHandlerForListener for PeerManager {
     #[tracing::instrument]
     async fn handle_tunnel(&self, tunnel: Box<dyn Tunnel>) -> Result<(), Error> {
-        self.add_tunnel_as_server(tunnel).await
+        self.add_tunnel_as_server(tunnel, true).await
     }
 }
 
@@ -113,22 +118,26 @@ impl<H: TunnelHandlerForListener + Send + Sync + 'static + Debug> ListenerManage
                 continue;
             };
             let ctx = self.global_ctx.clone();
-            self.add_listener(move || get_listener_by_url(&l, ctx.clone()).unwrap(), true)
-                .await?;
-        }
 
-        if self.global_ctx.config.get_flags().enable_ipv6 {
-            let ipv6_listener = self.global_ctx.config.get_flags().ipv6_listener.clone();
-            let _ = self
-                .add_listener(
-                    move || {
-                        Box::new(UdpTunnelListener::new(
-                            ipv6_listener.clone().parse().unwrap(),
-                        ))
-                    },
+            let listener = l.clone();
+            self.add_listener(
+                move || get_listener_by_url(&listener, ctx.clone()).unwrap(),
+                true,
+            )
+            .await?;
+
+            if self.global_ctx.config.get_flags().enable_ipv6 && !is_url_host_ipv6(&l) {
+                let mut ipv6_listener = l.clone();
+                ipv6_listener
+                    .set_host(Some("[::]".to_string().as_str()))
+                    .with_context(|| format!("failed to set ipv6 host for listener: {}", l))?;
+                let ctx = self.global_ctx.clone();
+                self.add_listener(
+                    move || get_listener_by_url(&ipv6_listener, ctx.clone()).unwrap(),
                     false,
                 )
                 .await?;
+            }
         }
 
         Ok(())
@@ -161,11 +170,11 @@ impl<H: TunnelHandlerForListener + Send + Sync + 'static + Debug> ListenerManage
                     global_ctx.issue_event(GlobalCtxEvent::ListenerAdded(l.local_url()));
                 }
                 Err(e) => {
+                    tracing::error!(?e, ?l, "listener listen error");
                     global_ctx.issue_event(GlobalCtxEvent::ListenerAddFailed(
                         l.local_url(),
                         format!("error: {:?}, retry listen later...", e),
                     ));
-                    tracing::error!(?e, ?l, "listener listen error");
                     tokio::time::sleep(std::time::Duration::from_secs(1)).await;
                     continue;
                 }
@@ -217,6 +226,15 @@ impl<H: TunnelHandlerForListener + Send + Sync + 'static + Debug> ListenerManage
 
     pub async fn run(&mut self) -> Result<(), Error> {
         for listener in &self.listeners {
+            if listener.must_succ {
+                // try listen once
+                let mut l = (listener.creator_fn)();
+                let _g = self.net_ns.guard();
+                l.listen()
+                    .await
+                    .with_context(|| format!("failed to listen on {}", l.local_url()))?;
+            }
+
             self.tasks.spawn(Self::run_listener(
                 listener.creator_fn.clone(),
                 self.peer_manager.clone(),

rust/easytier/src/peers/foreign_network_manager.rs

@@ -695,7 +695,8 @@ mod tests {
 
         let (a_ring, b_ring) = crate::tunnel::ring::create_ring_tunnel_pair();
         let b_mgr_copy = pm_center.clone();
-        let s_ret = tokio::spawn(async move { b_mgr_copy.add_tunnel_as_server(b_ring).await });
+        let s_ret =
+            tokio::spawn(async move { b_mgr_copy.add_tunnel_as_server(b_ring, true).await });
 
         pma_net1.add_client_tunnel(a_ring).await.unwrap();
 

rust/easytier/src/peers/peer.rs

@@ -11,7 +11,7 @@ use super::{
     peer_conn::{PeerConn, PeerConnId},
     PacketRecvChan,
 };
-use crate::proto::cli::PeerConnInfo;
+use crate::{common::scoped_task::ScopedTask, proto::cli::PeerConnInfo};
 use crate::{
     common::{
         error::Error,
@@ -36,7 +36,8 @@ pub struct Peer {
 
     shutdown_notifier: Arc<tokio::sync::Notify>,
 
-    default_conn_id: AtomicCell<PeerConnId>,
+    default_conn_id: Arc<AtomicCell<PeerConnId>>,
+    default_conn_id_clear_task: ScopedTask<()>,
 }
 
 impl Peer {
@@ -88,6 +89,19 @@ impl Peer {
             )),
         );
 
+        let default_conn_id = Arc::new(AtomicCell::new(PeerConnId::default()));
+
+        let conns_copy = conns.clone();
+        let default_conn_id_copy = default_conn_id.clone();
+        let default_conn_id_clear_task = ScopedTask::from(tokio::spawn(async move {
+            loop {
+                tokio::time::sleep(std::time::Duration::from_secs(5)).await;
+                if conns_copy.len() > 1 {
+                    default_conn_id_copy.store(PeerConnId::default());
+                }
+            }
+        }));
+
         Peer {
             peer_node_id,
             conns: conns.clone(),
@@ -98,7 +112,8 @@ impl Peer {
             close_event_listener,
 
             shutdown_notifier,
-            default_conn_id: AtomicCell::new(PeerConnId::default()),
+            default_conn_id,
+            default_conn_id_clear_task,
         }
     }
 
@@ -117,14 +132,19 @@ impl Peer {
             return Some(conn.clone());
         }
 
-        let conn = self.conns.iter().next();
-        if conn.is_none() {
-            return None;
+        // find a conn with the smallest latency
+        let mut min_latency = std::u64::MAX;
+        for conn in self.conns.iter() {
+            let latency = conn.value().get_stats().latency_us;
+            if latency < min_latency {
+                min_latency = latency;
+                self.default_conn_id.store(conn.get_conn_id());
+            }
         }
 
-        let conn = conn.unwrap().clone();
-        self.default_conn_id.store(conn.get_conn_id());
-        Some(conn)
+        self.conns
+            .get(&self.default_conn_id.load())
+            .map(|conn| conn.clone())
     }
 
     pub async fn send_msg(&self, msg: ZCPacket) -> Result<(), Error> {
@@ -158,6 +178,10 @@ impl Peer {
         }
         ret
     }
+
+    pub fn get_default_conn_id(&self) -> PeerConnId {
+        self.default_conn_id.load()
+    }
 }
 
 // pritn on drop

rust/easytier/src/peers/peer_manager.rs

@@ -8,7 +8,7 @@ use std::{
 use anyhow::Context;
 use async_trait::async_trait;
 
-use dashmap::DashMap;
+use dashmap::{DashMap, DashSet};
 
 use tokio::{
     sync::{
@@ -23,7 +23,7 @@ use crate::{
         compressor::{Compressor as _, DefaultCompressor},
         constants::EASYTIER_VERSION,
         error::Error,
-        global_ctx::{ArcGlobalCtx, NetworkIdentity},
+        global_ctx::{ArcGlobalCtx, GlobalCtxEvent, NetworkIdentity},
         stun::StunInfoCollectorTrait,
         PeerId,
     },
@@ -141,6 +141,9 @@ pub struct PeerManager {
     data_compress_algo: CompressorAlgo,
 
     exit_nodes: Vec<Ipv4Addr>,
+
+    // conns that are directly connected (which are not hole punched)
+    directly_connected_conn_map: Arc<DashMap<PeerId, DashSet<uuid::Uuid>>>,
 }
 
 impl Debug for PeerManager {
@@ -267,6 +270,8 @@ impl PeerManager {
             data_compress_algo,
 
             exit_nodes,
+
+            directly_connected_conn_map: Arc::new(DashMap::new()),
         }
     }
 
@@ -325,8 +330,48 @@ impl PeerManager {
         Ok((peer_id, conn_id))
     }
 
+    fn add_directly_connected_conn(&self, peer_id: PeerId, conn_id: uuid::Uuid) {
+        let _ = self
+            .directly_connected_conn_map
+            .entry(peer_id)
+            .or_insert_with(DashSet::new)
+            .insert(conn_id);
+    }
+
+    pub fn has_directly_connected_conn(&self, peer_id: PeerId) -> bool {
+        self.directly_connected_conn_map
+            .get(&peer_id)
+            .map_or(false, |x| !x.is_empty())
+    }
+
+    async fn start_peer_conn_close_event_handler(&self) {
+        let dmap = self.directly_connected_conn_map.clone();
+        let mut event_recv = self.global_ctx.subscribe();
+        self.tasks.lock().await.spawn(async move {
+            while let Ok(event) = event_recv.recv().await {
+                match event {
+                    GlobalCtxEvent::PeerConnRemoved(info) => {
+                        if let Some(set) = dmap.get_mut(&info.peer_id) {
+                            let conn_id = info.conn_id.parse().unwrap();
+                            let old = set.remove(&conn_id);
+                            tracing::info!(
+                                ?old,
+                                ?info,
+                                "try remove conn id from directly connected map"
+                            );
+                        }
+                    }
+                    _ => {}
+                }
+            }
+        });
+    }
+
     #[tracing::instrument]
-    pub async fn try_connect<C>(&self, mut connector: C) -> Result<(PeerId, PeerConnId), Error>
+    pub async fn try_direct_connect<C>(
+        &self,
+        mut connector: C,
+    ) -> Result<(PeerId, PeerConnId), Error>
     where
         C: TunnelConnector + Debug,
     {
@@ -334,18 +379,28 @@ impl PeerManager {
         let t = ns
             .run_async(|| async move { connector.connect().await })
             .await?;
-        self.add_client_tunnel(t).await
+        let (peer_id, conn_id) = self.add_client_tunnel(t).await?;
+        self.add_directly_connected_conn(peer_id, conn_id);
+        Ok((peer_id, conn_id))
     }
 
     #[tracing::instrument]
-    pub async fn add_tunnel_as_server(&self, tunnel: Box<dyn Tunnel>) -> Result<(), Error> {
+    pub async fn add_tunnel_as_server(
+        &self,
+        tunnel: Box<dyn Tunnel>,
+        is_directly_connected: bool,
+    ) -> Result<(), Error> {
         tracing::info!("add tunnel as server start");
         let mut peer = PeerConn::new(self.my_peer_id, self.global_ctx.clone(), tunnel);
         peer.do_handshake_as_server().await?;
         if peer.get_network_identity().network_name
             == self.global_ctx.get_network_identity().network_name
         {
+            let (peer_id, conn_id) = (peer.get_peer_id(), peer.get_conn_id());
             self.add_new_peer_conn(peer).await?;
+            if is_directly_connected {
+                self.add_directly_connected_conn(peer_id, conn_id);
+            }
         } else {
             self.foreign_network_manager.add_peer_conn(peer).await?;
         }
@@ -857,9 +912,11 @@ impl PeerManager {
 
     async fn run_clean_peer_without_conn_routine(&self) {
         let peer_map = self.peers.clone();
+        let dmap = self.directly_connected_conn_map.clone();
         self.tasks.lock().await.spawn(async move {
             loop {
                 peer_map.clean_peer_without_conn().await;
+                dmap.retain(|p, v| peer_map.has_peer(*p) && !v.is_empty());
                 tokio::time::sleep(std::time::Duration::from_secs(3)).await;
             }
         });
@@ -876,6 +933,8 @@ impl PeerManager {
     }
 
     pub async fn run(&self) -> Result<(), Error> {
+        self.start_peer_conn_close_event_handler().await;
+
         match &self.route_algo_inst {
             RouteAlgoInst::Ospf(route) => self.add_route(route.clone()).await,
             RouteAlgoInst::None => {}
@@ -924,7 +983,7 @@ impl PeerManager {
         self.foreign_network_client.clone()
     }
 
-    pub fn get_my_info(&self) -> cli::NodeInfo {
+    pub async fn get_my_info(&self) -> cli::NodeInfo {
         cli::NodeInfo {
             peer_id: self.my_peer_id,
             ipv4_addr: self
@@ -950,6 +1009,7 @@ impl PeerManager {
             config: self.global_ctx.config.dump(),
             version: EASYTIER_VERSION.to_string(),
             feature_flag: Some(self.global_ctx.get_feature_flags()),
+            ip_list: Some(self.global_ctx.get_ip_collector().collect_ip_addrs().await),
         }
     }
 
@@ -958,6 +1018,13 @@ impl PeerManager {
             tokio::time::sleep(std::time::Duration::from_secs(1)).await;
         }
     }
+
+    pub fn get_directly_connections(&self, peer_id: PeerId) -> DashSet<uuid::Uuid> {
+        self.directly_connected_conn_map
+            .get(&peer_id)
+            .map(|x| x.clone())
+            .unwrap_or_default()
+    }
 }
 
 #[cfg(test)]
@@ -1026,7 +1093,7 @@ mod tests {
 
         tokio::spawn(async move {
             client.set_bind_addrs(vec![]);
-            client_mgr.try_connect(client).await.unwrap();
+            client_mgr.try_direct_connect(client).await.unwrap();
         });
 
         server_mgr

rust/easytier/src/peers/peer_map.rs

@@ -212,6 +212,11 @@ impl PeerMap {
         }
     }
 
+    pub async fn get_peer_default_conn_id(&self, peer_id: PeerId) -> Option<PeerConnId> {
+        self.get_peer_by_id(peer_id)
+            .map(|p| p.get_default_conn_id())
+    }
+
     pub async fn close_peer_conn(
         &self,
         peer_id: PeerId,

rust/easytier/src/peers/rpc_service.rs

@@ -32,12 +32,23 @@ impl PeerManagerRpcService {
                 .await
                 .iter(),
         );
+        let peer_map = self.peer_manager.get_peer_map();
         let mut peer_infos = Vec::new();
         for peer in peers {
             let mut peer_info = PeerInfo::default();
             peer_info.peer_id = peer;
+            peer_info.default_conn_id = peer_map
+                .get_peer_default_conn_id(peer)
+                .await
+                .map(Into::into);
+            peer_info.directly_connected_conns = self
+                .peer_manager
+                .get_directly_connections(peer)
+                .into_iter()
+                .map(Into::into)
+                .collect();
 
-            if let Some(conns) = self.peer_manager.get_peer_map().list_peer_conns(peer).await {
+            if let Some(conns) = peer_map.list_peer_conns(peer).await {
                 peer_info.conns = conns;
             } else if let Some(conns) = self
                 .peer_manager
@@ -121,7 +132,7 @@ impl PeerManageRpc for PeerManagerRpcService {
         _request: ShowNodeInfoRequest, // Accept request of type HelloRequest
     ) -> Result<ShowNodeInfoResponse, rpc_types::error::Error> {
         Ok(ShowNodeInfoResponse {
-            node_info: Some(self.peer_manager.get_my_info()),
+            node_info: Some(self.peer_manager.get_my_info().await),
         })
     }
 }

rust/easytier/src/peers/tests.rs

@@ -45,7 +45,7 @@ pub async fn connect_peer_manager(client: Arc<PeerManager>, server: Arc<PeerMana
     });
     let b_mgr_copy = server.clone();
     tokio::spawn(async move {
-        b_mgr_copy.add_tunnel_as_server(b_ring).await.unwrap();
+        b_mgr_copy.add_tunnel_as_server(b_ring, true).await.unwrap();
     });
 }
 

rust/easytier/src/proto/cli.proto

@@ -1,6 +1,7 @@
 syntax = "proto3";
 
 import "common.proto";
+import "peer_rpc.proto";
 
 package cli;
 
@@ -34,6 +35,8 @@ message PeerConnInfo {
 message PeerInfo {
   uint32 peer_id = 1;
   repeated PeerConnInfo conns = 2;
+  common.UUID default_conn_id = 3;
+  repeated common.UUID directly_connected_conns = 4;
 }
 
 message ListPeerRequest {}
@@ -79,6 +82,7 @@ message NodeInfo {
   string config = 8;
   string version = 9;
   common.PeerFeatureFlag feature_flag = 10;
+  peer_rpc.GetIpListResponse ip_list = 11;
 }
 
 message ShowNodeInfoRequest {}

rust/easytier/src/proto/cli.rs

@@ -4,10 +4,14 @@ impl PeerRoutePair {
     pub fn get_latency_ms(&self) -> Option<f64> {
         let mut ret = u64::MAX;
         let p = self.peer.as_ref()?;
+        let default_conn_id = p.default_conn_id.map(|id| id.to_string());
         for conn in p.conns.iter() {
             let Some(stats) = &conn.stats else {
                 continue;
             };
+            if default_conn_id == Some(conn.conn_id.to_string()) {
+                return Some(f64::from(stats.latency_us as u32) / 1000.0);
+            }
             ret = ret.min(stats.latency_us);
         }
 

rust/easytier/src/proto/common.proto

@@ -18,7 +18,7 @@ message FlagsInConfig {
   bool disable_p2p = 11;
   bool relay_all_peer_rpc = 12;
   bool disable_udp_hole_punching = 13;
-  string ipv6_listener = 14;
+  // string ipv6_listener = 14; [deprecated = true]; use -l udp://[::]:12345 instead
   bool multi_thread = 15;
   CompressionAlgoPb data_compress_algo = 16;
   bool bind_device = 17;

rust/easytier/src/tunnel/common.rs

@@ -360,7 +360,13 @@ pub(crate) fn setup_sokcet2_ext(
 
     socket2_socket.set_nonblocking(true)?;
     socket2_socket.set_reuse_address(true)?;
-    socket2_socket.bind(&socket2::SockAddr::from(*bind_addr))?;
+    if let Err(e) = socket2_socket.bind(&socket2::SockAddr::from(*bind_addr)) {
+        if bind_addr.is_ipv4() {
+            return Err(e.into());
+        } else {
+            tracing::warn!(?e, "bind failed, do not return error for ipv6");
+        }
+    }
 
     // #[cfg(all(unix, not(target_os = "solaris"), not(target_os = "illumos")))]
     // socket2_socket.set_reuse_port(true)?;

rust/easytier/src/tunnel/mod.rs

@@ -126,7 +126,7 @@ pub trait TunnelListener: Send {
 }
 
 #[async_trait]
-#[auto_impl::auto_impl(Box)]
+#[auto_impl::auto_impl(Box, &mut)]
 pub trait TunnelConnector: Send {
     async fn connect(&mut self) -> Result<Box<dyn Tunnel>, TunnelError>;
     fn remote_url(&self) -> url::Url;

rust/easytier/src/tunnel/tcp.rs

@@ -150,9 +150,9 @@ impl TcpTunnelConnector {
         &mut self,
         addr: SocketAddr,
     ) -> Result<Box<dyn Tunnel>, super::TunnelError> {
-        tracing::info!(addr = ?self.addr, "connect tcp start");
+        tracing::info!(url = ?self.addr, ?addr, "connect tcp start, bind addrs: {:?}", self.bind_addrs);
         let stream = TcpStream::connect(addr).await?;
-        tracing::info!(addr = ?self.addr, "connect tcp succ");
+        tracing::info!(url = ?self.addr, ?addr, "connect tcp succ");
         return get_tunnel_with_tcp_stream(stream, self.addr.clone().into());
     }
 
@@ -190,7 +190,7 @@ impl super::TunnelConnector for TcpTunnelConnector {
     async fn connect(&mut self) -> Result<Box<dyn Tunnel>, super::TunnelError> {
         let addr =
             check_scheme_and_get_socket_addr_ext::<SocketAddr>(&self.addr, "tcp", self.ip_version)?;
-        if self.bind_addrs.is_empty() || addr.is_ipv6() {
+        if self.bind_addrs.is_empty() {
             self.connect_with_default_bind(addr).await
         } else {
             self.connect_with_custom_bind(addr).await

rust/easytier/src/tunnel/udp.rs

@@ -141,12 +141,27 @@ async fn respond_stun_packet(
         .encode_into_bytes(resp_msg.clone())
         .map_err(|e| anyhow::anyhow!("stun encode error: {:?}", e))?;
 
-    socket
-        .send_to(&rsp_buf, addr.clone())
-        .await
-        .with_context(|| "send stun response error")?;
+    let change_req = req_msg
+        .get_attribute::<ChangeRequest>()
+        .map(|r| r.ip() || r.port())
+        .unwrap_or(false);
 
-    tracing::debug!(?addr, ?req_msg, "udp respond stun packet done");
+    if !change_req {
+        socket
+            .send_to(&rsp_buf, addr.clone())
+            .await
+            .with_context(|| "send stun response error")?;
+    } else {
+        // send from a new udp socket
+        let socket = if addr.is_ipv4() {
+            UdpSocket::bind("0.0.0.0:0").await?
+        } else {
+            UdpSocket::bind("[::]:0").await?
+        };
+        socket.send_to(&rsp_buf, addr.clone()).await?;
+    }
+
+    tracing::debug!(?addr, ?req_msg, ?change_req, "udp respond stun packet done");
     Ok(())
 }
 

rust/src/api/simple.rs

@@ -292,6 +292,7 @@ pub struct KVNodeInfo {
     pub ipv4: String,
     pub latency_ms: f64,
     pub nat: String, // NAT类型
+    pub loss_rate: f32,
     pub connections: Vec<KVNodeConnectionStats>,
     pub version: String,
     pub cost: i32,
@@ -330,7 +331,6 @@ pub fn get_network_status() -> KVNetworkStatus {
                 hostname: route.hostname.clone(),
                 ipv4,
                 latency_ms: if let Some(peer) = &pair.peer {
-                    // 类似cli.rs中的get_latency_ms方法
                     let mut min_latency = u64::MAX;
                     for conn in &peer.conns {
                         if let Some(stats) = &conn.stats {
@@ -348,6 +348,15 @@ pub fn get_network_status() -> KVNetworkStatus {
                     // 如果没有peer信息，则使用路由路径延迟
                     f64::from(route.path_latency.max(0)) / 1000.0
                 },
+                loss_rate: if let Some(peer) = &pair.peer {
+                    let mut total_loss_rate = 0.0;
+                    for conn in &peer.conns {
+                        total_loss_rate += conn.loss_rate;
+                    }
+                    total_loss_rate
+                } else {
+                    0.0 // 如果没有连接信息，默认为0
+                },
                 nat: route.stun_info.as_ref().map_or_else(
                     || "Unknown".to_string(),
                     |stun| {
@@ -564,20 +573,29 @@ pub fn create_server(
     specified_ip: String,
     room_name: String,
     room_password: String,
-    severurl: String,
+    severurl: Vec<String>,
 ) {
     RT.spawn(async move {
         // 创建一个示例配置
         let cfg = create_config();
         cfg.set_hostname(Option::from(username));
         cfg.set_dhcp(enable_dhcp);
-        let peer_config = PeerConfig {
-            uri: ("tcp://".to_string() + &severurl).parse().unwrap(),
-        };
-        let peer_config2 = PeerConfig {
-            uri: ("udp://".to_string() + &severurl).parse().unwrap(),
-        };
-        cfg.set_peers(vec![peer_config, peer_config2]);
+        let mut flags = cfg.get_flags();
+        // flags.dev_name = "astral".to_string();
+        cfg.set_flags(flags);
+        // 创建TCP和UDP连接配置列表
+        let mut peer_configs = Vec::new();
+        // 为每个服务器URL创建TCP和UDP配置
+        for url in severurl {
+            peer_configs.push(PeerConfig {
+                uri: format!("tcp://{}", url).parse().unwrap(),
+            });
+            peer_configs.push(PeerConfig {
+                uri: format!("udp://{}", url).parse().unwrap(),
+            });
+        }
+        
+        cfg.set_peers(peer_configs);
         if enable_dhcp == false {
             // 使用完整路径引用 cidr 模块的 Ipv4Inet
             // 解析IP地址和子网掩码

rust/src/frb_generated.rs

@@ -107,7 +107,7 @@ fn wire__crate__api__simple__create_server_impl(
             let api_specified_ip = <String>::sse_decode(&mut deserializer);
             let api_room_name = <String>::sse_decode(&mut deserializer);
             let api_room_password = <String>::sse_decode(&mut deserializer);
-            let api_severurl = <String>::sse_decode(&mut deserializer);
+            let api_severurl = <Vec<String>>::sse_decode(&mut deserializer);
             deserializer.end();
             move |context| {
                 transform_result_sse::<_, ()>((move || {
@@ -496,6 +496,13 @@ impl SseDecode for bool {
     }
 }
 
+impl SseDecode for f32 {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
+        deserializer.cursor.read_f32::<NativeEndian>().unwrap()
+    }
+}
+
 impl SseDecode for f64 {
     // Codec=Sse (Serialization based), see doc to use other codecs
     fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
@@ -547,6 +554,7 @@ impl SseDecode for crate::api::simple::KVNodeInfo {
         let mut var_ipv4 = <String>::sse_decode(deserializer);
         let mut var_latencyMs = <f64>::sse_decode(deserializer);
         let mut var_nat = <String>::sse_decode(deserializer);
+        let mut var_lossRate = <f32>::sse_decode(deserializer);
         let mut var_connections =
             <Vec<crate::api::simple::KVNodeConnectionStats>>::sse_decode(deserializer);
         let mut var_version = <String>::sse_decode(deserializer);
@@ -556,6 +564,7 @@ impl SseDecode for crate::api::simple::KVNodeInfo {
             ipv4: var_ipv4,
             latency_ms: var_latencyMs,
             nat: var_nat,
+            loss_rate: var_lossRate,
             connections: var_connections,
             version: var_version,
             cost: var_cost,
@@ -599,6 +608,18 @@ impl SseDecode for Vec<Route> {
     }
 }
 
+impl SseDecode for Vec<String> {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
+        let mut len_ = <i32>::sse_decode(deserializer);
+        let mut ans_ = vec![];
+        for idx_ in 0..len_ {
+            ans_.push(<String>::sse_decode(deserializer));
+        }
+        return ans_;
+    }
+}
+
 impl SseDecode for Vec<crate::api::simple::KVNodeConnectionStats> {
     // Codec=Sse (Serialization based), see doc to use other codecs
     fn sse_decode(deserializer: &mut flutter_rust_bridge::for_generated::SseDeserializer) -> Self {
@@ -822,6 +843,7 @@ impl flutter_rust_bridge::IntoDart for crate::api::simple::KVNodeInfo {
             self.ipv4.into_into_dart().into_dart(),
             self.latency_ms.into_into_dart().into_dart(),
             self.nat.into_into_dart().into_dart(),
+            self.loss_rate.into_into_dart().into_dart(),
             self.connections.into_into_dart().into_dart(),
             self.version.into_into_dart().into_dart(),
             self.cost.into_into_dart().into_dart(),
@@ -928,6 +950,13 @@ impl SseEncode for bool {
     }
 }
 
+impl SseEncode for f32 {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
+        serializer.cursor.write_f32::<NativeEndian>(self).unwrap();
+    }
+}
+
 impl SseEncode for f64 {
     // Codec=Sse (Serialization based), see doc to use other codecs
     fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
@@ -968,6 +997,7 @@ impl SseEncode for crate::api::simple::KVNodeInfo {
         <String>::sse_encode(self.ipv4, serializer);
         <f64>::sse_encode(self.latency_ms, serializer);
         <String>::sse_encode(self.nat, serializer);
+        <f32>::sse_encode(self.loss_rate, serializer);
         <Vec<crate::api::simple::KVNodeConnectionStats>>::sse_encode(self.connections, serializer);
         <String>::sse_encode(self.version, serializer);
         <i32>::sse_encode(self.cost, serializer);
@@ -1004,6 +1034,16 @@ impl SseEncode for Vec<Route> {
     }
 }
 
+impl SseEncode for Vec<String> {
+    // Codec=Sse (Serialization based), see doc to use other codecs
+    fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {
+        <i32>::sse_encode(self.len() as _, serializer);
+        for item in self {
+            <String>::sse_encode(item, serializer);
+        }
+    }
+}
+
 impl SseEncode for Vec<crate::api::simple::KVNodeConnectionStats> {
     // Codec=Sse (Serialization based), see doc to use other codecs
     fn sse_encode(self, serializer: &mut flutter_rust_bridge::for_generated::SseSerializer) {

web/index.html

@@ -1,38 +0,0 @@
-<!DOCTYPE html>
-<html>
-<head>
-  <!--
-    If you are serving your web app in a path other than the root, change the
-    href value below to reflect the base path you are serving from.
-
-    The path provided below has to start and end with a slash "/" in order for
-    it to work correctly.
-
-    For more details:
-    * https://developer.mozilla.org/en-US/docs/Web/HTML/Element/base
-
-    This is a placeholder for base href that will be replaced by the value of
-    the `--base-href` argument provided to `flutter build`.
-  -->
-  <base href="$FLUTTER_BASE_HREF">
-
-  <meta charset="UTF-8">
-  <meta content="IE=Edge" http-equiv="X-UA-Compatible">
-  <meta name="description" content="A new Flutter project.">
-
-  <!-- iOS meta tags & icons -->
-  <meta name="mobile-web-app-capable" content="yes">
-  <meta name="apple-mobile-web-app-status-bar-style" content="black">
-  <meta name="apple-mobile-web-app-title" content="astral">
-  <link rel="apple-touch-icon" href="icons/Icon-192.png">
-
-  <!-- Favicon -->
-  <link rel="icon" type="image/png" href="favicon.png"/>
-
-  <title>astral</title>
-  <link rel="manifest" href="manifest.json">
-</head>
-<body>
-  <script src="flutter_bootstrap.js" async></script>
-</body>
-</html>

web/manifest.json

@@ -1,35 +0,0 @@
-{
-    "name": "astral",
-    "short_name": "astral",
-    "start_url": ".",
-    "display": "standalone",
-    "background_color": "#0175C2",
-    "theme_color": "#0175C2",
-    "description": "A new Flutter project.",
-    "orientation": "portrait-primary",
-    "prefer_related_applications": false,
-    "icons": [
-        {
-            "src": "icons/Icon-192.png",
-            "sizes": "192x192",
-            "type": "image/png"
-        },
-        {
-            "src": "icons/Icon-512.png",
-            "sizes": "512x512",
-            "type": "image/png"
-        },
-        {
-            "src": "icons/Icon-maskable-192.png",
-            "sizes": "192x192",
-            "type": "image/png",
-            "purpose": "maskable"
-        },
-        {
-            "src": "icons/Icon-maskable-512.png",
-            "sizes": "512x512",
-            "type": "image/png",
-            "purpose": "maskable"
-        }
-    ]
-}

windows/CMakeLists.txt

@@ -75,10 +75,6 @@ set(INSTALL_BUNDLE_LIB_DIR "${CMAKE_INSTALL_PREFIX}")
 install(TARGETS ${BINARY_NAME} RUNTIME DESTINATION "${CMAKE_INSTALL_PREFIX}"
   COMPONENT Runtime)
 
-# 添加管理员权限要求（修正路径格式）
-target_link_options(${BINARY_NAME} PRIVATE
-  "LINKER:/MANIFESTUAC:level='requireAdministrator' uiAccess='false'"
-  $<$<C_COMPILER_ID:MSVC>:"LINKER:/MANIFESTINPUT:${CMAKE_CURRENT_SOURCE_DIR}/runner/runner.exe.manifest">)
 
 install(FILES "${FLUTTER_ICU_DATA_FILE}" DESTINATION "${INSTALL_BUNDLE_DATA_DIR}"
   COMPONENT Runtime)

windows/runner/CMakeLists.txt

@@ -26,7 +26,7 @@ target_compile_definitions(${BINARY_NAME} PRIVATE "FLUTTER_VERSION_MAJOR=${FLUTT
 target_compile_definitions(${BINARY_NAME} PRIVATE "FLUTTER_VERSION_MINOR=${FLUTTER_VERSION_MINOR}")
 target_compile_definitions(${BINARY_NAME} PRIVATE "FLUTTER_VERSION_PATCH=${FLUTTER_VERSION_PATCH}")
 target_compile_definitions(${BINARY_NAME} PRIVATE "FLUTTER_VERSION_BUILD=${FLUTTER_VERSION_BUILD}")
-
+SET_TARGET_PROPERTIES(${BINARY_NAME} PROPERTIES LINK_FLAGS    "/MANIFESTUAC:\"level='requireAdministrator' uiAccess='false'\" /SUBSYSTEM:WINDOWS")
 # Disable Windows macros that collide with C++ standard library functions.
 target_compile_definitions(${BINARY_NAME} PRIVATE "NOMINMAX")
 

windows/runner/runner.exe.manifest

@@ -1,12 +1,6 @@
 <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
 <assembly xmlns="urn:schemas-microsoft-com:asm.v1" manifestVersion="1.0">
-  <trustInfo xmlns="urn:schemas-microsoft-com:asm.v3">
-      <security>
-        <requestedPrivileges>
-          <requestedExecutionLevel level="requireAdministrator" uiAccess="false"/>
-        </requestedPrivileges>
-      </security>
-    </trustInfo>
+ 
   <application xmlns="urn:schemas-microsoft-com:asm.v3">
     <windowsSettings>
       <dpiAwareness xmlns="http://schemas.microsoft.com/SMI/2016/WindowsSettings">PerMonitorV2</dpiAwareness>
@@ -18,4 +12,14 @@
       <supportedOS Id="{8e0f7a12-bfb3-4fe8-b9a5-48fd50a15a9a}"/>
     </application>
   </compatibility>
+
+   <trustInfo xmlns="urn:schemas-microsoft-com:asm.v3">
+      <security>
+        <requestedPrivileges>
+          <requestedExecutionLevel 
+            level="requireAdministrator" 
+            uiAccess="false"/>
+        </requestedPrivileges>
+      </security>
+    </trustInfo>
 </assembly>