using System.Collections.Concurrent; using System.Diagnostics; using System.Net; using System.Net.Sockets; namespace ServiceLib.Services; public class SpeedtestService(Config config, Func updateFunc) { private static readonly string _tag = "SpeedtestService"; private readonly Config? _config = config; private readonly Func? _updateFunc = updateFunc; private static readonly ConcurrentBag _lstExitLoop = new(); public void RunLoop(ESpeedActionType actionType, List selecteds) { Task.Run(async () => { await RunAsync(actionType, selecteds); await ProfileExManager.Instance.SaveTo(); await UpdateFunc("", ResUI.SpeedtestingCompleted); }); } public void ExitLoop() { if (_lstExitLoop.Count > 0) { UpdateFunc("", ResUI.SpeedtestingStop); _lstExitLoop.Clear(); } } private async Task RunAsync(ESpeedActionType actionType, List selecteds) { var exitLoopKey = Utils.GetGuid(false); _lstExitLoop.Add(exitLoopKey); var lstSelected = await GetClearItem(actionType, selecteds); switch (actionType) { case ESpeedActionType.Tcping: await RunTcpingAsync(lstSelected); break; case ESpeedActionType.Realping: await RunRealPingBatchAsync(lstSelected, exitLoopKey); break; case ESpeedActionType.Speedtest: await RunMixedTestAsync(lstSelected, 1, true, exitLoopKey); break; case ESpeedActionType.Mixedtest: await RunMixedTestAsync(lstSelected, _config.SpeedTestItem.MixedConcurrencyCount, true, exitLoopKey); break; } } private async Task> GetClearItem(ESpeedActionType actionType, List selecteds) { var lstSelected = new List(); foreach (var it in selecteds) { if (it.ConfigType.IsComplexType()) { continue; } if (it.Port <= 0) { continue; } lstSelected.Add(new ServerTestItem() { IndexId = it.IndexId, Address = it.Address, Port = it.Port, ConfigType = it.ConfigType, QueueNum = selecteds.IndexOf(it) }); } //clear test result foreach (var it in lstSelected) { switch (actionType) { case ESpeedActionType.Tcping: case ESpeedActionType.Realping: await UpdateFunc(it.IndexId, ResUI.Speedtesting, ""); ProfileExManager.Instance.SetTestDelay(it.IndexId, 0); break; case ESpeedActionType.Speedtest: await UpdateFunc(it.IndexId, "", ResUI.SpeedtestingWait); ProfileExManager.Instance.SetTestSpeed(it.IndexId, 0); break; case ESpeedActionType.Mixedtest: await UpdateFunc(it.IndexId, ResUI.Speedtesting, ResUI.SpeedtestingWait); ProfileExManager.Instance.SetTestDelay(it.IndexId, 0); ProfileExManager.Instance.SetTestSpeed(it.IndexId, 0); break; } } return lstSelected; } private async Task RunTcpingAsync(List selecteds) { List tasks = []; foreach (var it in selecteds) { tasks.Add(Task.Run(async () => { try { var responseTime = await GetTcpingTime(it.Address, it.Port); ProfileExManager.Instance.SetTestDelay(it.IndexId, responseTime); await UpdateFunc(it.IndexId, responseTime.ToString()); } catch (Exception ex) { Logging.SaveLog(_tag, ex); } })); } await Task.WhenAll(tasks); } private async Task RunRealPingBatchAsync(List lstSelected, string exitLoopKey, int pageSize = 0) { if (pageSize <= 0) { pageSize = lstSelected.Count < Global.SpeedTestPageSize ? lstSelected.Count : Global.SpeedTestPageSize; } var lstTest = GetTestBatchItem(lstSelected, pageSize); List lstFailed = new(); foreach (var lst in lstTest) { var ret = await RunRealPingAsync(lst, exitLoopKey); if (ret == false) { lstFailed.AddRange(lst); } await Task.Delay(100); } //Retest the failed part var pageSizeNext = pageSize / 2; if (lstFailed.Count > 0 && pageSizeNext > 0) { if (_lstExitLoop.Any(p => p == exitLoopKey) == false) { await UpdateFunc("", ResUI.SpeedtestingSkip); return; } await UpdateFunc("", string.Format(ResUI.SpeedtestingTestFailedPart, lstFailed.Count)); if (pageSizeNext > _config.SpeedTestItem.MixedConcurrencyCount) { await RunRealPingBatchAsync(lstFailed, exitLoopKey, pageSizeNext); } else { await RunMixedTestAsync(lstSelected, _config.SpeedTestItem.MixedConcurrencyCount, false, exitLoopKey); } } } private async Task RunRealPingAsync(List selecteds, string exitLoopKey) { ProcessService processService = null; try { processService = await CoreManager.Instance.LoadCoreConfigSpeedtest(selecteds); if (processService is null) { return false; } await Task.Delay(1000); List tasks = new(); foreach (var it in selecteds) { if (!it.AllowTest) { continue; } tasks.Add(Task.Run(async () => { await DoRealPing(it); })); } await Task.WhenAll(tasks); } catch (Exception ex) { Logging.SaveLog(_tag, ex); } finally { if (processService != null) { await processService?.StopAsync(); } } return true; } private async Task RunMixedTestAsync(List selecteds, int concurrencyCount, bool blSpeedTest, string exitLoopKey) { using var concurrencySemaphore = new SemaphoreSlim(concurrencyCount); var downloadHandle = new DownloadService(); List tasks = new(); foreach (var it in selecteds) { if (_lstExitLoop.Any(p => p == exitLoopKey) == false) { await UpdateFunc(it.IndexId, "", ResUI.SpeedtestingSkip); continue; } await concurrencySemaphore.WaitAsync(); tasks.Add(Task.Run(async () => { ProcessService processService = null; try { processService = await CoreManager.Instance.LoadCoreConfigSpeedtest(it); if (processService is null) { await UpdateFunc(it.IndexId, "", ResUI.FailedToRunCore); } else { await Task.Delay(1000); var delay = await DoRealPing(it); if (blSpeedTest) { if (delay > 0) { await DoSpeedTest(downloadHandle, it); } else { await UpdateFunc(it.IndexId, "", ResUI.SpeedtestingSkip); } } } } catch (Exception ex) { Logging.SaveLog(_tag, ex); } finally { if (processService != null) { await processService?.StopAsync(); } concurrencySemaphore.Release(); } })); } await Task.WhenAll(tasks); } private async Task DoRealPing(ServerTestItem it) { var webProxy = new WebProxy($"socks5://{Global.Loopback}:{it.Port}"); var responseTime = await HttpClientHelper.Instance.GetRealPingTime(_config.SpeedTestItem.SpeedPingTestUrl, webProxy, 10); ProfileExManager.Instance.SetTestDelay(it.IndexId, responseTime); await UpdateFunc(it.IndexId, responseTime.ToString()); return responseTime; } private async Task DoSpeedTest(DownloadService downloadHandle, ServerTestItem it) { await UpdateFunc(it.IndexId, "", ResUI.Speedtesting); var webProxy = new WebProxy($"socks5://{Global.Loopback}:{it.Port}"); var url = _config.SpeedTestItem.SpeedTestUrl; var timeout = _config.SpeedTestItem.SpeedTestTimeout; await downloadHandle.DownloadDataAsync(url, webProxy, timeout, async (success, msg) => { decimal.TryParse(msg, out var dec); if (dec > 0) { ProfileExManager.Instance.SetTestSpeed(it.IndexId, dec); } await UpdateFunc(it.IndexId, "", msg); }); } private async Task GetTcpingTime(string url, int port) { var responseTime = -1; try { if (!IPAddress.TryParse(url, out var ipAddress)) { var ipHostInfo = await Dns.GetHostEntryAsync(url); ipAddress = ipHostInfo.AddressList.First(); } IPEndPoint endPoint = new(ipAddress, port); using Socket clientSocket = new(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp); var timer = Stopwatch.StartNew(); var result = clientSocket.BeginConnect(endPoint, null, null); if (!result.AsyncWaitHandle.WaitOne(TimeSpan.FromSeconds(5))) { throw new TimeoutException("connect timeout (5s): " + url); } timer.Stop(); responseTime = (int)timer.Elapsed.TotalMilliseconds; clientSocket.EndConnect(result); } catch (Exception ex) { Logging.SaveLog(_tag, ex); } return responseTime; } private List> GetTestBatchItem(List lstSelected, int pageSize) { List> lstTest = new(); var lst1 = lstSelected.Where(t => Global.XraySupportConfigType.Contains(t.ConfigType)).ToList(); var lst2 = lstSelected.Where(t => Global.SingboxOnlyConfigType.Contains(t.ConfigType)).ToList(); for (var num = 0; num < (int)Math.Ceiling(lst1.Count * 1.0 / pageSize); num++) { lstTest.Add(lst1.Skip(num * pageSize).Take(pageSize).ToList()); } for (var num = 0; num < (int)Math.Ceiling(lst2.Count * 1.0 / pageSize); num++) { lstTest.Add(lst2.Skip(num * pageSize).Take(pageSize).ToList()); } return lstTest; } private async Task UpdateFunc(string indexId, string delay, string speed = "") { await _updateFunc?.Invoke(new() { IndexId = indexId, Delay = delay, Speed = speed }); if (indexId.IsNotEmpty() && speed.IsNotEmpty()) { ProfileExManager.Instance.SetTestMessage(indexId, speed); } } }