c# - 如何在传输过程中关闭请求流时获取 HTTP 响应

Question

TL;DR 版本

当写入请求流时发生传输错误，我无法访问响应，即使服务器发送了它也是如此。

---

完整版

我有一个使用 HttpWebRequest 将文件上传到 Tomcat 服务器的 .NET 应用程序。在某些情况下，服务器会提前关闭请求流(因为它出于某种原因拒绝该文件，例如无效的文件名)，并发送带有自定义 header 的 400 响应以指示错误原因。

问题是如果上传的文件很大，请求流在我写完请求体之前关闭，我得到一个IOException:

Message: Unable to write data to the transport connection: An existing connection was forcibly closed by the remote host.
InnerException: SocketException: An existing connection was forcibly closed by the remote host

我可以捕获此异常，但是随后，当我调用 GetResponse 时，我得到一个 WebException，其中先前的 IOException 作为其内部异常，以及一个空的 Response 属性。 所以我永远得不到响应，即使服务器发送了响应(已使用 WireShark 检查)。

由于无法得到响应，我不知道实际问题是什么。从我的应用程序的角度来看，它看起来像是连接中断了，所以我将其视为与网络相关的错误并重试上传......当然，它再次失败。

如何解决此问题并从服务器检索实际响应？有可能吗？对我来说，当前的行为看起来像是 HttpWebRequest 中的错误，或者至少是一个严重的设计问题...

---

这是我用来重现问题的代码:

var request = HttpWebRequest.CreateHttp(uri);
request.Method = "POST";
string filename = "foo\u00A0bar.dat"; // Invalid characters in filename, the server will refuse it
request.Headers["Content-Disposition"] = string.Format("attachment; filename*=utf-8''{0}", Uri.EscapeDataString(filename));
request.AllowWriteStreamBuffering = false;
request.ContentType = "application/octet-stream";
request.ContentLength = 100 * 1024 * 1024;

// Upload the "file" (just random data in this case)
try
{
    using (var stream = request.GetRequestStream())
    {
        byte[] buffer = new byte[1024 * 1024];
        new Random().NextBytes(buffer);
        for (int i = 0; i < 100; i++)
        {
            stream.Write(buffer, 0, buffer.Length);
        }
    }
}
catch(Exception ex)
{
    // here I get an IOException; InnerException is a SocketException
    Console.WriteLine("Error writing to stream: {0}", ex);
}

// Now try to read the response
try
{
    using (var response = (HttpWebResponse)request.GetResponse())
    {
        Console.WriteLine("{0} - {1}", (int)response.StatusCode, response.StatusDescription);
    }
}
catch(Exception ex)
{
    // here I get a WebException; InnerException is the IOException from the previous catch
    Console.WriteLine("Error getting the response: {0}", ex);
    var webEx = ex as WebException;
    if (webEx != null)
    {
        Console.WriteLine(webEx.Status); // SendFailure
        var response = (HttpWebResponse)webEx.Response;
        if (response != null)
        {
            Console.WriteLine("{0} - {1}", (int)response.StatusCode, response.StatusDescription);
        }
        else
        {
            Console.WriteLine("No response");
        }
    }
}

---

补充说明:

如果我正确理解了 100 Continue 状态的作用，那么如果服务器要拒绝该文件，它就不应将其发送给我。不过这个状态好像是Tomcat直接控制的，应用程序是控制不了的。理想情况下，我希望服务器在这种情况下不要向我发送 100 Continue，但据我负责后端的同事说，没有简单的方法可以做到这一点。所以我现在正在寻找客户端解决方案；但如果您恰好知道如何解决服务器端的问题，也将不胜感激。

我遇到问题的应用程序针对 .NET 4.0，但我也用 4.5 重现了它。

我没有超时。异常在超时前很久就被抛出。

我尝试了一个异步请求。它不会改变任何东西。

我尝试将请求协议(protocol)版本设置为 HTTP 1.0，结果相同。

---

其他人已经针对此问题在 Connect 上提交了错误:https://connect.microsoft.com/VisualStudio/feedback/details/779622/unable-to-get-servers-error-response-when-uploading-file-with-httpwebrequest

Answer 1

我不知道什么可以作为您问题的客户端解决方案。但我仍然认为使用自定义 tomcat 阀的服务器端解决方案在这里可以提供帮助。我目前没有可以测试它的 tomcat 设置，但我认为这里的服务器端解决方案将遵循以下几行:

RFC 第 8.2.3 节明确指出: HTTP/1.1 源服务器要求:

  - Upon receiving a request which includes an Expect request-header
    field with the "100-continue" expectation, an origin server MUST
    either respond with 100 (Continue) status and continue to read
    from the input stream, or respond with a final status code. The
    origin server MUST NOT wait for the request body before sending
    the 100 (Continue) response. If it responds with a final status
    code, it MAY close the transport connection or it MAY continue
    to read and discard the rest of the request.  It MUST NOT
    perform the requested method if it returns a final status code.

因此假设 tomcat 向 RFC 确认，而在自定义阀中您会收到 HTTP 请求 header ，但不会发送请求正文，因为控件尚未在读取正文的 servlet 中。

所以你可以实现一个自定义阀，类似于:

import org.apache.catalina.connector.Request;
import org.apache.catalina.connector.Response;
import org.apache.catalina.valves.ErrorReportValve;

public class CustomUploadHandlerValve extends ValveBase {

    @Override
    public void invoke(Request request, Response response) throws IOException, ServletException {
         HttpServletRequest httpRequest = (HttpServletRequest) request;
         String fileName = httpRequest.getHeader("Filename");  // get the filename or whatever other parameters required as per your code
         bool validationSuccess = Validate(); // perform filename check or anyother validation here
         if(!validationSuccess)
         {
             response = CreateResponse(); //create your custom 400 response here
             request.SetResponse(response);
             // return the response here
         }
         else
         {
             getNext().invoke(request, response); // to pass to the next valve/ servlet in the chain
         }
    }
    ...
}

免责声明:同样，我还没有尝试成功，需要一些时间和一个 tomcat 设置来尝试它；)。 认为这可能是您的起点。