C#多线程TPL模式下使用HttpClient

C# 多线程 TPL 模式下使用 HttpClient 的攻略如下：

1. 确定使用的 HttpClient 实例

在多线程场景下使用 HttpClient，首先需要确定使用的 HttpClient 实例。可以选择以下方式：

1. 创建 HttpClient 的静态实例，多个线程共享同一个 HttpClient 实例。
2. 为每个线程创建一个 HttpClient 实例。

第一种方式可以提高性能，避免了多次创建和销毁 HttpClient 实例的开销，但需要注意的是，在高并发的情况下，可能会发生 HttpClient 实例过载的情况，造成请求的阻塞和延迟。

第二种方式可以避免多线程并发问题，但是需要在创建和销毁 HttpClient 实例的过程中，承受额外的开销。

综合考虑，建议使用第二种方式。

2. 使用 HttpClient 发送请求

在使用 HttpClient 发送请求时，需要注意以下几点：

1. HttpClient 默认是支持连接池的，因此可以重复使用同一个 HttpClient 实例，发送多个请求。

2. HttpClient 发送请求后，需要及时释放资源，避免内存泄漏。

3. 需要使用异步方式发送请求，以避免阻塞主线程。

以下是示例代码：

public static async Task<string> GetResponseAsync(string url)
{
    // 为避免 HttpClient 实例过载，为每个线程创建一个实例
    using (var client = new HttpClient())
    {
        // 发送 GET 请求
        var response = await client.GetAsync(url);

        // 确保响应成功，否则抛出异常
        response.EnsureSuccessStatusCode();

        // 解析响应内容
        var responseBody = await response.Content.ReadAsStringAsync();

        return responseBody;
    }
}

以上代码中，使用了 HttpClient 的 GetAsync 方法发送了一个 GET 请求，并使用了 EnsureSuccessStatusCode 方法确保请求成功。接着使用异步方式读取响应内容，并在使用完 HttpClient 实例后，使用 using 关键字释放资源。

示例说明

示例一：使用 HttpClient 处理多个 GET 请求

以下示例中，使用 Task.WhenAll 方法发送多个 GET 请求，并等待所有请求完成后，将响应内容输出到控制台。

public static async Task ProcessMultipleRequestsAsync()
{
    var urls = new List<string>
    {
        "https://www.example.com/api/1",
        "https://www.example.com/api/2",
        "https://www.example.com/api/3"
    };

    // 创建多个 Task，分别发送 GET 请求
    var tasks = urls.Select(url => GetResponseAsync(url));

    // 等待多个 Task 完成
    var responses = await Task.WhenAll(tasks);

    // 输出响应内容到控制台
    foreach (var response in responses)
    {
        Console.WriteLine(response);
    }
}

以上代码中，使用了 Task.WhenAll 方法等待多个异步任务完成，避免了阻塞主线程。使用 urls.Select 方法遍历多个请求地址，并创建对应的异步任务，并使用 await 等待所有请求完成。

示例二：使用 HttpClient 处理多个 POST 请求

以下示例中，使用 Task.WhenAll 方法发送多个 POST 请求，并等待所有请求完成后，将响应内容输出到控制台。

public static async Task ProcessMultiplePostsAsync()
{
    var data = new List<string>
    {
        "data1",
        "data2",
        "data3"
    };

    // 创建多个 Task，分别发送 POST 请求
    var tasks = data.Select(d => PostDataAsync(d));

    // 等待多个 Task 完成
    var responses = await Task.WhenAll(tasks);

    // 输出响应内容到控制台
    foreach (var response in responses)
    {
        Console.WriteLine(response);
    }
}

public static async Task<string> PostDataAsync(string data)
{
    var content = new StringContent(data, Encoding.UTF8, "application/json");

    // 创建使用 POST 请求的 HttpClient
    using (var client = new HttpClient())
    {
        var response = await client.PostAsync("https://www.example.com/api", content);

        response.EnsureSuccessStatusCode();

        var responseBody = await response.Content.ReadAsStringAsync();

        return responseBody;
    }
}

以上代码中，使用了 Task.WhenAll 方法等待多个异步任务完成，避免了阻塞主线程。使用 data.Select 方法遍历多个请求内容，并创建对应的异步任务，并使用 await 等待所有请求完成。同时，使用了 PostAsync 方法发送 POST 请求，并将请求内容放到 StringContent 对象中。最后，使用 using 关键字释放 HttpClient 资源。