.NET HTTP 请求超时在连续流式处理站点上不“中止”

本文关键字：站点 中止 处理 请求 HTTP 超时 连续 NET | 更新日期: 2023-09-27 18:36:09

Scope

我已经为Http Web Request类开发了一个包装器，以更简单的方式执行Gets和Posts。这个库已经使用了两年多，没有任何问题，但今天，我们遇到了一个奇怪的问题。

显然，有一个网站（加载需要一段时间），它会将字符流式传输到 HTML 前端，因此我们的库"Get"请求陷入了循环。

不同的超时属性

查看 Http Web 请求参考，我们发现有两个不同的timeout属性。我们正在使用它们，但它们似乎都没有正确中止。

  • 读取写入超时 - 获取或设置写入或读取流时的超时（以毫秒为单位）。
  • 超时 - 获取或设置 GetResponse 和 GetRequestStream 方法的超时值（以毫秒为单位）。

一个超时即可统治所有内容

有没有办法设置"操作超时"，在某个预先配置的时间后强制流/连接释放？

一些代码示例 

public class Program
{
public static void Main()
{
    string url = "http://anus.io";
    Console.WriteLine("Initializing Request State Object");
    RequestState myRequestState = new RequestState();
    // Creating Http Request
    myRequestState.request  =  (HttpWebRequest)WebRequest.Create(url);
    myRequestState.request.Method           = "GET";
    myRequestState.request.ReadWriteTimeout = 4000;
    myRequestState.request.Timeout          = 4000;
    Console.WriteLine("Begining Async Request");

    IAsyncResult ar = myRequestState.request.BeginGetResponse(new AsyncCallback(ResponseCallback), myRequestState);
    Console.WriteLine("Waiting for Results");
    ar.AsyncWaitHandle.WaitOne();
    myRequestState.response = (HttpWebResponse)myRequestState.request.EndGetResponse(ar);
    Console.WriteLine("Response status code = {0}", myRequestState.response.StatusCode);
}
public static void ResponseCallback (IAsyncResult asyncResult)
{
    Console.WriteLine("Completed");
}
}

这段代码似乎工作正常，但是我如何将响应读取为字符串，因为它不断被传输（如浏览器所示）？

问题

处理此类网站的正确方法是什么？（通过句柄，我的意思是能够识别和跳过服务器根本不会停止传输的情况？

.NET HTTP 请求超时在连续流式处理站点上不“中止”

试试这个：

public static void Main()
{
    string url = "http://anus.io";
    ***int DefaultTimeOut = 15000;*** //timeout after 15 sec
    Console.WriteLine("Initializing Request State Object");
    RequestState myRequestState = new RequestState();
    // Creating Http Request
    myRequestState.request  =  (HttpWebRequest)WebRequest.Create(url);
    myRequestState.request.Method           = "GET";
    myRequestState.request.ReadWriteTimeout = 4000;
    myRequestState.request.Timeout          = 4000;
    Console.WriteLine("Begining Async Request");

    IAsyncResult ar = myRequestState.request.BeginGetResponse(new AsyncCallback(ResponseCallback), myRequestState);
    ***ThreadPool.RegisterWaitForSingleObject(ar.AsyncWaitHandle, new WaitOrTimerCallback(TimeoutCallback), myRequestState.request, DefaultTimeOut, true);***
    Console.WriteLine("Waiting for Results");
    ar.AsyncWaitHandle.WaitOne();
    try{
    myRequestState.response = (HttpWebResponse)myRequestState.request.EndGetResponse(ar);
    Console.WriteLine("Response status code = {0}", myRequestState.response.StatusCode);
    }catch(Exception){
       Console.WriteLine("Request Aborted");
    }
}
public static void ResponseCallback (IAsyncResult asyncResult)
{
    Console.WriteLine("Completed");
}
//call the timeout if more than 15 seconds
**public static void TimeoutCallback(object state, bool timedOut)
{
            if (timedOut)
            {
                HttpWebRequest request = state as HttpWebRequest;
                if (request != null)
                {
                    request.Abort();
                }
            }
}**

我会将整个HTTP处理移动到Task中，并使用通用技术来暂停该任务。有许多这样的技术可用。

我不明白为什么你需要这么多单独的超时。你不能说：如果这个请求超过4秒，不管是什么原因，都要杀死它。

APM 模式和等待事件是 .NET 4.5 和 C# 5 时代的危险信号。所有这些垃圾都掩盖了代码的意图。如果使用 await 使用 WebRequest 类提供的异步 IO 并使用围绕它的通用超时技术，则垃圾会消失。

相关文章：