HttpWebRequest 异步与开始/结束

Question

我有一个 Web API 项目，其控制器依次向第三方 REST 接口发出 Web 请求。我的控制器 CRUD 函数已标记为异步，但实现方式是我使用 HttpWebRequest 阻塞函数 GetRequestStream 和 GetResponse。

这是否合适或者我也应该使用 HttpWebRequest 的 Begin/End 方法。这似乎有点矫枉过正，因为它会异步一个已经异步的操作，还是允许更多并发的传出 Web 请求？

寻找传入和传出吞吐量的最佳解决方案。

Answer 1

控制器被标记为异步，但实现使用同步 HttpWebRequest 调用，因为我的控制器正在等待 Task.Run(sync web request)

想想请求中发生了什么。请求进来，ASP.NET 采用线程池线程来处理请求。控制器操作将工作排队到线程池（占用另一个线程），然后awaits 工作，释放原始请求线程。使用await 并没有获得任何好处，因为仍然有一个线程池线程阻塞了 Web 请求。

因此，您几乎应该从不在 ASP.NET 上使用Task.Run（或任何其他将工作排队到线程池的方法）。

这是否合适或者我也应该使用 HttpWebRequest 的 Begin/End 方法。这似乎有点矫枉过正，因为它会异步一个已经异步的操作

现在真的不是异步的；仍然有一个线程被阻塞。我将此称为“队列阻塞工作到线程池线程，然后等待它”技术假异步。

适当的解决方法是使用为异步使用而设计的HttpClient；或者，您可以使用TaskFactory<T>.FromAsync to wrap the Begin/End methods into an awaitable task。

但我不明白的是，如果我使用 await HttpClient.SendAsync，那么某处肯定会阻塞等待响应

不，不一定有什么东西在某处阻塞。正如我在博客中所描述的，在真正的异步场景中（即，不是假异步），there is no thread。

Answer 2

服务器上的异步独立于客户端的异步。

您可以使用WebRequest.GetResponseAsync 从客户端异步调用同步 Web API 方法，也可以调用异步 Web API 方法同步来自客户端WebRequest.GetResponse，或者你可以在双方都有异步，这可能是最好的方法。您不需要使用 Begin/End APM 风格的 WebRequest API，除非您在客户端上以 .NET 4.0 为目标。请改用基于 Task 的异步 API。

在任何一种情况下，当您的 Web API 控制器方法完全完成时，将向客户端发送一个完整的 HTTP 请求，无论它是实现为同步还是异步（基于Task）。

Answer 3

我建议您保留异步方法，并使用HttpClient 而不是 HttpWebRequest，因为它也支持异步调用。

让我们看一个 CarsController 调用第三方服务的伪示例。

 public class CarsController : ApiController
    {
        [Route("cars/{id}")]
        public async Task<IHttpActionResult> Get(int id)
        {

            //Get a car by its id

            HttpClient client = new HttpClient();

            //Read the content directly
            string result = await client.GetStringAsync("http://www.google.com");

            //process the result returns from the thrid party REST service

            return Ok(result);
        }

}

如您所见，HttpClient支持通过GetXXXAsync()方法异步读取String/Stream/ByteArray。

如果你想访问底层的响应内容，可以使用下面的代码来实现：

        [Route("responsecars/{id}")]
        public async Task<IHttpActionResult> GetResponseStream(int id)
        {
            HttpClient client = new HttpClient();
            HttpResponseMessage responseMessage =await client.GetAsync("http://www.google.com", HttpCompletionOption.ResponseContentRead);

            HttpContent content = responseMessage.Content;

            //using one of the ReadAsync methods
            string text =await content.ReadAsStringAsync();

            return Ok(text);

        }

希望对您有所帮助。