WinForm中如何实现每秒50次HTTP请求且无需额外等待1秒

你的现有实现本质是用SemaphoreSlim控制并发数，无法直接限制时间窗口内的请求总量，所以才需要额外等待1秒再释放信号量，会导致信号量资源被无效占用，吞吐量低下。以下是更优的实现方案：

方案1：使用.NET官方内置速率限制器（推荐，.NET 7+适用） #

.NET 7及以上版本官方提供了System.Threading.RateLimiting库，内置的固定窗口限流器可以完美匹配你每秒最多50次请求的需求，无需手动处理时间等待逻辑：

步骤1：全局声明限流器 #

using System.Threading.RateLimiting;

// 配置固定窗口规则：1秒窗口内最多允许50个请求
private readonly RateLimiter _requestLimiter = new FixedWindowRateLimiter(new FixedWindowRateLimiterOptions
{
    PermitLimit = 50,
    Window = TimeSpan.FromSeconds(1),
    QueueProcessingOrder = QueueProcessingOrder.OldestFirst,
    QueueLimit = 10000 // 可根据你的实际请求总量调整队列上限
});

步骤2：修改请求方法 #

private async Task CallAsyncMtd(int item, IProgress<int> progress)
{
    // 自动等待直到1秒窗口内有可用请求配额
    using var lease = await _requestLimiter.AcquireAsync(permitCount: 1);
    if (!lease.IsAcquired)
    {
        // 自定义配额获取失败的处理逻辑，队列上限足够时不会触发
        return;
    }

    try
    {
        // 你的实际HTTP POST调用逻辑
        await Task.Delay(1000).ConfigureAwait(false); 
        // 保存响应到数据库，推荐使用异步MySQL操作提升性能
        // await SaveResponseToMySQLAsync(response);
        progress.Report(1);
    }
    catch (Exception e)
    {
        // 你的异常处理逻辑
    }
    // 无需手动释放配额，也不需要额外等待1秒，lease离开作用域自动处理
}

按钮点击的遍历逻辑不需要修改，原有逻辑即可正常运行。

方案2：自定义固定窗口限流（.NET 6及更低版本适用） #

如果你的项目版本低于.NET 7，可以自己实现简单的固定窗口限流，无需额外等待1秒：

步骤1：全局声明限流相关变量 #

private readonly object _timeLock = new object();
private readonly Queue<DateTime> _requestTimeQueue = new Queue<DateTime>();
// 保留并发控制，避免瞬间并发过高
private readonly SemaphoreSlim _concurrencyThrottler = new SemaphoreSlim(50);

步骤2：修改请求方法 #

private async Task CallAsyncMtd(int item, IProgress<int> progress)
{
    await _concurrencyThrottler.WaitAsync();
    try
    {
        // 等待直到当前1秒窗口有可用配额
        while (true)
        {
            lock (_timeLock)
            {
                // 清理1秒之前的请求记录
                while (_requestTimeQueue.Count > 0 
                    && DateTime.Now - _requestTimeQueue.Peek() > TimeSpan.FromSeconds(1))
                {
                    _requestTimeQueue.Dequeue();
                }
                if (_requestTimeQueue.Count < 50)
                {
                    _requestTimeQueue.Enqueue(DateTime.Now);
                    break;
                }
            }
            // 配额已满，等待100ms再重试
            await Task.Delay(100);
        }

        // 你的实际HTTP POST调用逻辑
        await Task.Delay(1000).ConfigureAwait(false);
        // saveResponseToMySQL(response);
        progress.Report(1);
    }
    catch (Exception e)
    {
        // 异常处理逻辑
    }
    finally
    {
        _concurrencyThrottler.Release();
    }
}

额外优化建议 #

• HttpClient建议使用全局单例，避免频繁创建销毁导致的socket资源耗尽问题
• 保存数据到MySQL的操作可替换为异步API（比如MySqlConnector提供的异步方法），避免阻塞线程
• WinForm中IProgress.Report会自动回调到UI线程，可直接用于更新进度条等UI组件，无需额外处理线程调度

内容的提问来源于stack exchange，提问作者variable