HttpClient SendAsync阻止主线程

问题描述

我编写了一个Winforms应用程序，该程序将http请求发送到本地网络中的每个ip地址，以发现我的某个设备。在我的特定子网掩码上，即512个地址。我已经使用backGroundWorker编写了此代码，但是我想试用httpClient和Async / Await模式来实现相同的目的。下面的代码使用httpClient的单个实例，我等待所有请求完成。这个问题是主线程被阻塞了。我知道这一点是因为我有一个PictureBox +加载gif，并且它的动画不是均匀的。我将GetAsync方法放在Task.Run中，按照建议的here运行，但这也不起作用。

    private async void button1_Click(object sender,EventArgs e)
    {
        var addresses = networkUtils.generateIPRange..
        await MakeMultipleHttpRequests(addresses);
    }


    public async Task MakeMultipleHttpRequests(IPAddress[] addresses)
    {
        List<Task<HttpResponseMessage>> httpTasks = new List<Task<HttpResponseMessage>>();
        foreach (var address in addresses)
        {
            Task<HttpResponseMessage> response = MakeHttpGetRequest(address.ToString());
            httpTasks.Add(response);
        }
        try
        {
            if (httpTasks.ToArray().Length != 0)
            {
                await Task.WhenAll(httpTasks.ToArray());
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine("\thttp tasks did not complete Exception : {0}",ex.Message);
        }

    }

    private async Task<HttpResponseMessage> MakeHttpGetRequest(string address)
    {
        var url = string.Format("http://{0}/getStatus",address);
        var cts = new System.Threading.CancellationTokenSource();
        cts.CancelAfter(TimeSpan.FromSeconds(10));
        HttpResponseMessage response = null;
        var request = new HttpRequestMessage(HttpMethod.Get,url);
        response = await httpClient.SendAsync(request,cts.Token);
        return response;
    }

我读过类似的问题here，但是我的gui线程做得并不多。我已经读过here，可能线程用完了。这是问题，我该如何解决？我知道它的Send Async，因为如果我用下面的简单任务替换代码，就不会有阻塞。

    await Task.Run(() =>
    {
       Thread.Sleep(1000);
    });

解决方法

因此，这里的问题之一是您正在快速连续地创建500多个任务，并且在任务创建之外设置了超时。

仅仅是因为您要求运行500多个任务，并不意味着500多个任务都将同时运行。当调度程序认为有可能时，它们就会排队并运行。

您在创建10秒时设置了超时。但是他们甚至可以在执行程序中坐在调度程序中10秒钟。

您希望让Http请求自然地超时，您可以在创建HttpClient时执行以下操作：

private static readonly HttpClient _httpClient = new HttpClient
{
    Timeout = TimeSpan.FromSeconds(10)
};

因此，通过将超时移至HttpClient，您的方法现在应如下所示：

private static Task<HttpResponseMessage> MakeHttpGetRequest(string address)
{
    return _httpClient.SendAsync(new HttpRequestMessage(HttpMethod.Get,new UriBuilder
    {
        Host = address,Path = "getStatus"
    }.Uri));
}

尝试使用该方法，看看它是否可以改善调试模式下的锁定问题。

关于您的问题：由于您处于“调试”模式，调试器试图说“嘿，您有一个异常”，所以它被锁定500倍，这是相同时间，因为它们都是同时产生的。在释放模式下运行它，看看它是否仍然锁定。

我认为要做的是分批进行操作。做20个，然后等到那20个完成，再做20个，依此类推。

如果您希望看到一种巧妙的批处理方式，请告诉我，我很乐意向您展示。

在.NET Framework上，与服务器的连接数由ServicePointManager Class控制。

对于客户，the default connection limit在客户进程中为 2 。

无论您执行多少次HttpClient.SendAsync调用，同一时间只有2个处于活动状态。

但是您可以manage the connections自己。

在.NET Core上，这不是服务点管理器的概念，等效的默认限制是int.MaxValue。

async-await asynchronous c#c#dotnet-httpclient multithreading