c# - 程序在尝试同时发送数百个 http 请求时抛出 SocketException

Question

我编写了一个 API 端点并创建了一个简单的 .net 核心控制台应用程序以同时向 API 端点发送多个请求以测试 API 端点的工作方式

代码如下所示

    static async Task Main(string[] args)
    {

        // ARRANGE

        int request_number = 200;
        Task<HttpResponseMessage>[] tasks = new Task<HttpResponseMessage>[request_number];
        Action[] actions = new Action[request_number];

        for (int i = 0; i < request_number; i++)
        {
            int temp = i;
            actions[temp] = () =>
            {
                tasks[temp] = CallMyAPI();
            };
        }


        // ACT
        Parallel.Invoke(actions);
        await Task.WhenAll(tasks);


        // ASSERT
        string sample1 = await tasks[0].Content.ReadAsStringAsync();
        for (int i = 1; i < request_number; i++)
        {
            string toBeTested = await tasks[i].Content.ReadAsStringAsync();
            if (toBeTested != sample1)
            {
                Console.WriteLine("Wrong! i = " + i);
            }
        }

        Console.WriteLine("finished");

        Console.WriteLine("Press any key to complete...");
        Console.Read();
    }

    static async Task<HttpResponseMessage> CallMyAPI()
    {


        var request = new HttpRequestMessage();
        request.Method = HttpMethod.Post;

        string contentString = "some json string as http body";
        request.Content = new StringContent(contentString, System.Text.Encoding.UTF8, "application/json");

        request.RequestUri = new Uri("http://myAPIendpoint.com");

        HttpResponseMessage response;
        using (HttpClient httpClient = new HttpClient())
        {
            response = await httpClient.SendAsync(request);
        }

        return response;
    }

所以基本上我一直试图通过代码做的是一次发送多个请求，然后等待并记录所有响应。然后我比较它们以验证它们是否都返回相同的响应。

最初，当我将变量 request_number 设置为较小的数字(如 50、100)时，测试应用程序运行良好。然而，随着 request_number 上升并达到 200 左右，它开始抛出如下所示的异常:

内部异常 1:
IOException:无法从传输连接读取数据:由于线程退出或应用程序请求，I/O 操作已中止。

内部异常 2:
SocketException:由于线程退出或应用程序请求，I/O 操作已中止

这种异常是什么意思？

Answer 1

你的问题是这样的:

 using (HttpClient httpClient = new HttpClient())
        {..
}

其中每一个都使用一个新的套接字。使用单个 httpclient，例如静态的