这些 HttpClient 调用是否被并行调用？

Question

我有一个 .NET Core Web 应用，一旦调用了一个 Web 方法（即 Test()），就会调用另一个远程 api。

基本上，我是这样做的（这是一个 POST 示例，在 Web 方法 Test() 中调用）：

public T PostRead<T>(string baseAddress, string url, out bool succeded, object entity = null)
{
    T returnValue = default(T);
    succeded = false;

    try
    {
        using (HttpClient client = new HttpClient())
        {
            client.DefaultRequestHeaders.Add("Authorization", MyApiKey);
            HttpResponseMessage res = null;
            string json = JsonConvert.SerializeObject(entity);
            var body = new StringContent(json, UnicodeEncoding.UTF8, "application/json");

            var task = Task.Run(() => client.PostAsync($"{baseAddress}/{url}", body));
            task.Wait();
            res = task.Result;
            succeded = res.IsSuccessStatusCode;

            if (succeded)
            {
                returnValue = JsonConvert.DeserializeObject<T>(res.Content.ReadAsStringAsync().Result);
            }
            else
            {
                Log($"PostRead failed, error: {JsonConvert.SerializeObject(res)}");
            }
        }
    }
    catch (Exception ex)
    {
        Log($"PostRead error: {baseAddress}/{url} entity: {JsonConvert.SerializeObject(entity)}");
    }

    return returnValue;
}

问题是：如果我的 Web App 中的 Test() 被并行调用 10 次，对远程服务器的 POST 请求是并行调用还是串行调用？

因为如果它们会被串行调用，最后一个会占用前一个的时间，这不是我想要的。

事实上，当我有大量的请求时，我经常会收到消息连接尝试失败，因为连接的一方在一段时间后没有正确响应，或者建立连接失败，因为连接的主机失败回应。

Answer 1

问题是：如果我的 Web App 中的 Test() 被并行调用 10 次，对远程服务器的 POST 请求是并行调用还是串行调用？

它们将被并行调用。代码中的任何内容都不会使其成为阻塞方式。

事实上，当我的请求列表很大时，我经常会收到A connection attempt failed because the connected party after a time没有正确响应，或者是因为已连接的主机没有响应而建立的连接失败。

这里至少有两点需要修复：

• 正确使用async/await
• 正确使用HttpClient

第一个很简单：

public async Task<T> PostRead<T>(string baseAddress, string url, out bool succeded, object entity = null)
{
    succeded = false;

    try
    {
        using (HttpClient client = new HttpClient())
        {
            client.DefaultRequestHeaders.Add("Authorization", MyApiKey);
            string json = JsonConvert.SerializeObject(entity);
            var body = new StringContent(json, UnicodeEncoding.UTF8, "application/json");

            var responseMessage = await client.PostAsync($"{baseAddress}/{url}", body);
            var responseContent = await responseMessage.Content.ReadAsStringAsync();

            if (responseMessage.IsSuccessStatusCode)
            {
                succeeded = true;
                return JsonConvert.DeserializeObject<T>();
            }
            else
            {
                // log...
            }
        }
    }
    catch (Exception ex)
    {
        // log...
    }

    return default; // or default(T) depending on the c# version
}

第二个有点棘手，很可能是您所看到的问题的原因。通常，除非您有一些非常具体的场景，否则new HttpClient() 是完全错误的。它浪费资源，隐藏依赖关系并防止模拟。正确的做法是使用IHttpClientFactory，在注册服务时使用AddHttpClient扩展方法可以很容易地抽象出来。

基本上是这样的：

services.AddHttpClient<YourClassName>(x => 
{
    x.BaseAddress = new Uri(baseAddress);
    x.DefaultRequestHeaders.Add("Authorization", MyApiKey);
}

然后就是把课堂上的所有using HttpClient 去掉，然后：

private readonly HttpClient _client;

public MyClassName(HttpClient client) { _client = client; }

public async Task<T> PostRead<T>(string url, out bool succeded, object entity = null)
{
    succeded = false;

    try
    {
        string json = JsonConvert.SerializeObject(entity);
        var responseMessage = await _client.PostAsync($"{baseAddress}/{url}", body);
        //...
    }
    catch (Exception ex)
    {
        // log...
    }

    return default; // or default(T) depending on the c# version
}