如何在 HttpWebRequest.BeginGetResponse 上指定超时值而不阻塞线程

Question

我正在尝试异步发出网络请求。我的代码工作正常，除了一件事：似乎没有内置方法可以在 BeginGetResponse 上指定超时。 MSDN 示例清楚地显示了一个工作示例，但其缺点是它们最终都以 ，

SomeObject.WaitOne()

这再次清楚地表明它会阻塞线程。我将处于高负载环境中并且不能阻塞，但如果请求时间超过 2 秒，我还需要超时。由于无法创建和管理单独的线程池，框架中是否已有某些内容可以帮助我？

起始示例：

• http://msdn.microsoft.com/ en-us/library/ms227433(VS.100).aspx
• http://msdn.microsoft.com/en-us/library/system.net.httpwebrequest.begingetresponse.aspx

我想要的是一种 上的异步回调方法BeginGetResponse() 在我的超时参数到期后被调用，并有一些指示发生超时。

看似明显的 TimeOut 参数在异步调用中并不适用。 在响应返回之前，ReadWriteTimeout 参数不会发挥作用。 非专有解决方案将是更好的选择。

编辑：

这是我的想法：调用BeginGetResponse后，我用我的持续时间创建一个Timer，这就是“开始”的结束处理阶段。现在，要么请求将完成并且我的“结束”阶段将被调用，要么超时期限将到期。

为了检测比赛并确定一个获胜者，我称以线程安全的方式增加“已完成”计数器。如果“超时”是第一个返回的事件，我将中止请求并停止计时器。在这种情况下，当调用“end”时，EndGetResponse 会引发错误。如果“结束”阶段首先发生，则它会增加计数器，并且“超时”会放弃中止请求。

这似乎像我想要的那样工作，同时还提供了可配置的超时。缺点是额外的计时器对象和我不努力避免的回调。我看到 1-3 个线程正在处理各个部分（开始、超时、结束），所以看起来这很有效。而且我没有任何“等待”电话。

我是否错过了太多睡眠，或者我是否找到了一种方法来满足我的请求而不会阻塞？

int completed = 0;

this.Request.BeginGetResponse(GotResponse, this.Request);
this.timer = new Timer(Timedout, this, TimeOutDuration, Timeout.Infinite);

private void Timedout(object state)
{
    if (Interlocked.Increment(ref completed) == 1)
    {
        this.Request.Abort();
    }
    this.timer.Change(Timeout.Infinite, Timeout.Infinite);
    this.timer.Dispose();
}

private void GotRecentSearches(IAsyncResult result)
{
    Interlocked.Increment(ref completed);
}

Answer 1

您可以使用 BackgroundWorker< /a> 将您的 HttpWebRequest 运行到一个单独的线程中，这样您的主线程仍然处于活动状态。因此，这个后台线程将被阻塞，但第一个线程不会。

在此上下文中，您可以使用 ManualResetEvent.WaitOne()，就像该示例中的那样：HttpWebRequest.BeginGetResponse() 方法。

Answer 2

这是一个什么样的应用程序？这是服务进程/网络应用程序/控制台应用程序吗？

您如何创建工作负载（即请求）？如果您有一个需要完成的工作队列，您可以启动“N”个异步请求（使用您构建的超时框架），然后，一旦每个请求完成（超时或成功），您就可以可以从队列中抓取下一个请求。

这将因此成为生产者/消费者模式。

因此，如果您将应用程序配置为最多有“N”个未完成的请求，则可以维护一个在请求之间重用（而不丢弃）的“N”个计时器池。

或者，您也可以使用 ThreadPool.SetTimerQueueTimer( 管理您的计时器。线程池将为您管理计时器并在请求之间重用计时器。

）来

Answer 3

看来我原来的方法是最好的方法。

Answer 4

如果您可以使用 async/await 那么

private async Task<WebResponse> getResponseAsync(HttpWebRequest request)
        {
            var responseTask = Task.Factory.FromAsync(request.BeginGetResponse, ar => (HttpWebResponse)request.EndGetResponse(ar), null);
            var winner = await (Task.WhenAny(responseTask, Task.Delay(new TimeSpan(0, 0, 20))));
            if (winner != responseTask)
            {
                throw new TimeoutException();
            }
            return await responseTask;
        }