如何通过依赖注入创建多配置、对接不同服务器的HttpClient实例

问题背景 #

需要对接两台不同服务器，使用两个HttpClient，服务器配置及地址均来自配置文件，且需支持后续扩展更多客户端。现有强类型客户端TestClient及基础DI注册代码，但默认注册会导致同类型客户端共用BaseAddress，需解决该问题，同时验证工厂类方案是否为最佳实践，寻求其他可行方案。

现有TestClient代码：

public class TestClient
{
    private HttpClient Client { get; }
    public TestClient(HttpClient client)
    {
        Client = client;
    }

    public Task<HttpResponseMessage> CallAsync(CancellationToken cancellation = default)
    {
        return Client.GetAsync("/", cancellation);
    }
}

基础DI注册代码：

var services = new ServiceCollection();
services.AddHttpClient("test", httpClient =>
{
    httpClient.BaseAddress = new Uri("https://localhost");                    
});

services.AddScoped<TestClient>();

解决方案 #

方案一：命名客户端+强类型客户端（官方推荐） #

通过为每个端点配置命名HttpClient，结合DI注册不同实例，既保留强类型客户端的类型安全，又能灵活区分不同服务器配置。

步骤1：配置文件定义端点

在appsettings.json中添加端点配置：

"Endpoints": [
  {
    "Name": "ServerA",
    "BaseAddress": "https://server-a.example.com"
  },
  {
    "Name": "ServerB",
    "BaseAddress": "https://server-b.example.com"
  }
]

步骤2：批量注册命名HttpClient与强类型客户端

读取配置并批量注册，支持后续扩展：

var services = new ServiceCollection();
var configuration = new ConfigurationBuilder()
    .AddJsonFile("appsettings.json")
    .Build();

// 读取端点配置模型
var endpoints = configuration.GetSection("Endpoints").Get<List<EndPointConfig>>();

foreach (var endpoint in endpoints)
{
    // 注册命名HttpClient，配置BaseAddress及其他参数
    services.AddHttpClient(endpoint.Name, client =>
    {
        client.BaseAddress = new Uri(endpoint.BaseAddress);
        client.Timeout = TimeSpan.FromSeconds(30); // 可添加超时、请求头等通用配置
    });

    // 注册对应强类型客户端
    services.AddScoped<TestClient>(sp => 
        new TestClient(sp.GetRequiredService<IHttpClientFactory>().CreateClient(endpoint.Name)));
}

// 辅助配置类
public class EndPointConfig
{
    public string Name { get; set; }
    public string BaseAddress { get; set; }
}

扩展：创建专属强类型客户端

若不同服务器的业务逻辑存在差异，可创建子类区分：

public class ServerAClient : TestClient
{
    public ServerAClient(HttpClient client) : base(client) { }

    // 添加ServerA专属方法
    public Task<HttpResponseMessage> GetServerADataAsync()
    {
        return Client.GetAsync("/server-a/data");
    }
}

注册时对应绑定：

switch (endpoint.Name)
{
    case "ServerA":
        services.AddScoped<ServerAClient>(sp => 
            new ServerAClient(sp.GetRequiredService<IHttpClientFactory>().CreateClient(endpoint.Name)));
        break;
    case "ServerB":
        services.AddScoped<ServerBClient>(sp => 
            new ServerBClient(sp.GetRequiredService<IHttpClientFactory>().CreateClient(endpoint.Name)));
        break;
}

方案二：工厂类+IHttpClientFactory（动态多实例） #

若无需区分强类型子类，可通过工厂类统一管理不同配置的TestClient实例，核心是利用IHttpClientFactory创建HttpClient，避免手动创建导致的套接字资源泄漏。

实现工厂类

public interface ITestClientFactory
{
    TestClient GetClient(string endpointName);
    IEnumerable<TestClient> GetAllClients();
}

public class TestClientFactory : ITestClientFactory
{
    private readonly IHttpClientFactory _httpClientFactory;
    private readonly List<EndPointConfig> _endpoints;

    public TestClientFactory(IHttpClientFactory httpClientFactory, IConfiguration configuration)
    {
        _httpClientFactory = httpClientFactory;
        _endpoints = configuration.GetSection("Endpoints").Get<List<EndPointConfig>>();
    }

    public TestClient GetClient(string endpointName)
    {
        var endpoint = _endpoints.FirstOrDefault(e => e.Name.Equals(endpointName, StringComparison.OrdinalIgnoreCase));
        if (endpoint == null)
            throw new ArgumentException($"端点 {endpointName} 未配置");
        
        var httpClient = _httpClientFactory.CreateClient(endpoint.Name);
        return new TestClient(httpClient);
    }

    public IEnumerable<TestClient> GetAllClients()
    {
        return _endpoints.Select(e => 
            new TestClient(_httpClientFactory.CreateClient(e.Name)));
    }
}

注册工厂与命名HttpClient

services.AddSingleton<ITestClientFactory, TestClientFactory>();

// 批量注册命名HttpClient
var endpoints = configuration.GetSection("Endpoints").Get<List<EndPointConfig>>();
foreach (var endpoint in endpoints)
{
    services.AddHttpClient(endpoint.Name, client =>
    {
        client.BaseAddress = new Uri(endpoint.BaseAddress);
    });
}

使用示例

public class BusinessService
{
    private readonly ITestClientFactory _clientFactory;

    public BusinessService(ITestClientFactory clientFactory)
    {
        _clientFactory = clientFactory;
    }

    public async Task CallAllServers()
    {
        var clients = _clientFactory.GetAllClients();
        foreach (var client in clients)
        {
            var response = await client.CallAsync();
            // 处理响应逻辑
        }
    }

    public async Task CallServerA()
    {
        var client = _clientFactory.GetClient("ServerA");
        var response = await client.CallAsync();
        // 处理ServerA响应
    }
}

关键注意事项 #

• 禁止手动创建HttpClient：手动new HttpClient()会导致底层套接字资源泄漏，IHttpClientFactory会自动管理Handler的生命周期，实现资源复用与回收。
• 配置驱动扩展：所有端点配置从配置文件读取，新增服务器只需修改配置并补充注册逻辑（或通过反射自动扫描注册）。

内容的提问来源于stack exchange，提问作者Álvaro García