如何让C# HttpClient每次请求都通过DNS重新解析主机？

核心问题分析 #

Docker Compose的服务主机名（如myservice）会解析为所有副本的IP，但HttpClient默认会缓存DNS解析结果、复用长连接，导致请求无法轮询到不同的服务实例。下面针对你覆盖的.NET Standard 2.0/2.1、.NET Framework 4.8、.NET 6/8提供跨平台兼容的解决方案，无需依赖Nginx。

方案1：自定义DNS解析（全框架通用） #

手动解析服务IP并轮询选择，绕开HttpClient的DNS缓存，适用于所有目标框架。

实现代码 #

using System;
using System.Net;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;

public class MyServiceClient
{
    private readonly HttpClient _httpClient;
    private int _ipIndex = -1;

    public MyServiceClient(HttpClient httpClient)
    {
        _httpClient = httpClient;
    }

    public async Task<HttpResponseMessage> SendRequestAsync(string path, HttpMethod method)
    {
        // 解析myservice的所有副本IP
        var ips = await Dns.GetHostAddressesAsync("myservice");
        if (ips.Length == 0)
            throw new InvalidOperationException("未找到myservice的可用IP");

        // 轮询选择下一个IP
        var selectedIp = GetNextRoundRobinIp(ips);

        // 构造请求URI，替换为选中的IP，保留路径和参数
        var baseUri = new UriBuilder($"http://{selectedIp}:8000{path}");
        var request = new HttpRequestMessage(method, baseUri.Uri);

        // 手动设置Host头，确保服务端识别正确的服务名（若服务依赖Host头）
        request.Headers.Host = "myservice";

        return await _httpClient.SendAsync(request);
    }

    private IPAddress GetNextRoundRobinIp(IPAddress[] ips)
    {
        var index = Interlocked.Increment(ref _ipIndex);
        return ips[index % ips.Length];
    }
}

注意事项 #

• 若消费端不在Docker容器内，需确保能解析myservice的IP（如配置宿主机DNS指向Docker内置DNS）
• 可根据需求替换轮询逻辑为随机选择或加权轮询

方案2：.NET 6+原生DNS配置优化 #

针对.NET 6.0+，利用SocketsHttpHandler的原生配置，强制刷新DNS并限制连接复用时长：

using System;
using System.Net.Http;
using System.Net.Http.SocketsHttpHandler;

var handler = new SocketsHttpHandler
{
    // 每秒刷新DNS解析结果
    DnsRefreshTimeout = TimeSpan.FromSeconds(1),
    // 连接池中的连接1秒后失效，避免复用绑定旧IP的长连接
    PooledConnectionLifetime = TimeSpan.FromSeconds(1),
    PooledConnectionIdleTimeout = TimeSpan.FromSeconds(1)
};

var httpClient = new HttpClient(handler);

方案3：.NET Framework 4.8特殊处理 #

在.NET Framework中，通过ServicePointManager调整连接和DNS缓存策略：

using System;
using System.Net;

// 针对myservice单独配置
var servicePoint = ServicePointManager.FindServicePoint(new Uri("http://myservice:8000"));
// 1秒后释放连接，触发重新解析DNS
servicePoint.ConnectionLeaseTimeout = 1000;
servicePoint.MaxIdleTime = 1000;

// 或全局配置（影响所有HttpClient请求）
// ServicePointManager.DnsRefreshTimeout = 1000;
// ServicePointManager.ConnectionLeaseTimeout = 1000;

方案4：依赖注入封装（跨框架统一适配） #

若项目使用依赖注入，可封装扩展方法自动适配不同框架：

using System;
using System.Net;
using System.Net.Http;
using System.Net.Http.SocketsHttpHandler;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;

public static class HttpClientExtensions
{
    public static IHttpClientBuilder AddMyServiceHttpClient(this IHttpClientBuilder builder)
    {
#if NET6_0_OR_GREATER
        builder.ConfigurePrimaryHttpMessageHandler(() => new SocketsHttpHandler
        {
            DnsRefreshTimeout = TimeSpan.FromSeconds(1),
            PooledConnectionLifetime = TimeSpan.FromSeconds(1),
            PooledConnectionIdleTimeout = TimeSpan.FromSeconds(1)
        });
#elif NET48
        builder.ConfigurePrimaryHttpMessageHandler(() => new HttpClientHandler());
        // 单独配置myservice的连接超时
        ServicePointManager.FindServicePoint(new Uri("http://myservice:8000")).ConnectionLeaseTimeout = 1000;
#else
        // .NET Standard 2.0/2.1使用自定义Handler
        builder.AddHttpMessageHandler(() => new CustomDnsHandler());
#endif
        return builder;
    }
}

// .NET Standard 2.0/2.1自定义DNS处理Handler
public class CustomDnsHandler : DelegatingHandler
{
    private int _ipIndex = -1;

    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
    {
        if (request.RequestUri?.Host == "myservice")
        {
            var ips = await Dns.GetHostAddressesAsync("myservice", cancellationToken);
            if (ips.Length == 0)
                throw new InvalidOperationException("未找到myservice的可用IP");

            var index = Interlocked.Increment(ref _ipIndex);
            var selectedIp = ips[index % ips.Length];

            var uriBuilder = new UriBuilder(request.RequestUri);
            uriBuilder.Host = selectedIp.ToString();
            request.RequestUri = uriBuilder.Uri;
            request.Headers.Host = "myservice";
        }

        return await base.SendAsync(request, cancellationToken);
    }
}

验证方法 #

在消费端添加日志，记录每次请求的目标IP，确认是否轮询到myservice-1至myservice-4的不同实例IP，即可验证方案有效性。

内容的提问来源于stack exchange，提问作者joelc