fix：修复私有测速节点可能存在部分上传下载测速失败的问题，自动轮换

goecs.go

@@ -27,7 +27,7 @@ import (
 )
 
 var (
-	ecsVersion   = "v0.1.111"                   // 融合怪版本号
+	ecsVersion   = "v0.1.112"                   // 融合怪版本号
 	configs      = params.NewConfig(ecsVersion) // 全局配置实例
 	userSetFlags = make(map[string]bool)        // 用于跟踪哪些参数是用户显式设置的
 )

internal/runner/runner.go

@@ -330,6 +330,8 @@ func RunNetworkTests(config *params.Config, wg3 *sync.WaitGroup, ptInfo *string,
 				fmt.Println(pt.WebsiteTest())
 			}
 		}
+		// 等待第三方库的输出完全刷新到标准输出
+		time.Sleep(300 * time.Millisecond)
 	}, tempOutput, output)
 }
 
@@ -362,6 +364,8 @@ func RunSpeedTests(config *params.Config, output, tempOutput string, outputMutex
 			} else if config.Choice == "6" {
 				tests.CustomSP("net", "global", 11, config.Language)
 			}
+			// 等待第三方库的输出完全刷新到标准输出
+			time.Sleep(500 * time.Millisecond)
 		}
 	}, tempOutput, output)
 }
@@ -380,6 +384,8 @@ func RunEnglishNetworkTests(config *params.Config, wg3 *sync.WaitGroup, ptInfo *
 				fmt.Println(pt.WebsiteTest())
 			}
 		}
+		// 等待第三方库的输出完全刷新到标准输出
+		time.Sleep(300 * time.Millisecond)
 	}, tempOutput, output)
 }
 
@@ -393,6 +399,8 @@ func RunEnglishSpeedTests(config *params.Config, output, tempOutput string, outp
 			tests.ShowHead(config.Language)
 			tests.NearbySP()
 			tests.CustomSP("net", "global", -1, config.Language)
+			// 等待第三方库的输出完全刷新到标准输出
+			time.Sleep(500 * time.Millisecond)
 		}
 	}, tempOutput, output)
 }

internal/tests/speed.go

@@ -135,6 +135,8 @@ func privateSpeedTest(num int, operator string) (int, error) {
 	// 去重：确保同一运营商内城市不重复
 	seenCities := make(map[string]bool)
 	var bestServers []pst.ServerWithLatencyInfo
+	// 保留更多备用节点，以应对测速失败的情况（保留 serversPerISP * 2 个备用节点）
+	maxBackupServers := serversPerISP * 2
 	for _, serverInfo := range candidateServers {
 		city := serverInfo.Server.City
 		if city == "" {
@@ -143,8 +145,8 @@ func privateSpeedTest(num int, operator string) (int, error) {
 		if !seenCities[city] {
 			seenCities[city] = true
 			bestServers = append(bestServers, serverInfo)
-			// 去重后取前 serversPerISP 个
-			if len(bestServers) >= serversPerISP {
+			// 去重后保留足够的备用节点
+			if len(bestServers) >= maxBackupServers {
 				break
 			}
 		}
@@ -153,7 +155,13 @@ func privateSpeedTest(num int, operator string) (int, error) {
 		return 0, fmt.Errorf("去重后没有可用的服务器")
 	}
 	// 执行测速并逐个打印结果（不打印表头）
+	// 统计成功输出的节点数
+	successCount := 0
 	for i, serverInfo := range bestServers {
+		// 如果已经成功输出了足够的节点，则停止测试
+		if successCount >= serversPerISP {
+			break
+		}
 		result := pst.RunSpeedTest(
 			serverInfo.Server,
 			false,          // 不禁用下载测试
@@ -163,16 +171,18 @@ func privateSpeedTest(num int, operator string) (int, error) {
 			&serverInfo,
 			false, // 不显示进度条
 		)
-		if result.Success {
+		// 只有当测试成功且上传和下载速度都有效时，才输出结果
+		if result.Success && result.UploadMbps > 0 && result.DownloadMbps > 0 {
 			printTableRow(result)
+			successCount++
 		}
-		// 在测试之间暂停（除了最后一个）
-		if i < len(bestServers)-1 {
+		// 在测试之间暂停（如果还需要继续测试的话）
+		if successCount < serversPerISP && i < len(bestServers)-1 {
 			time.Sleep(1 * time.Second)
 		}
 	}
-	// 返回实际测试的节点数量
-	return len(bestServers), nil
+	// 返回实际成功输出的节点数量
+	return successCount, nil
 }
 
 // privateSpeedTestWithFallback 使用私有测速，如果失败则回退到 global 节点

utils/utils.go

@@ -219,6 +219,11 @@ func CaptureOutput(f func()) string {
 	}()
 	// 执行函数
 	f()
+	// 确保所有输出都已经刷新
+	os.Stdout.Sync()
+	os.Stderr.Sync()
+	// 等待一小段时间，确保后台goroutine的输出完成
+	time.Sleep(100 * time.Millisecond)
 	// 关闭管道写入端，让管道读取端可以读取所有数据
 	stdoutPipeW.Close()
 	stderrPipeW.Close()