.NET Core 6 REST请求如何实现类似SOAP的全局消息拦截？

在.NET Core 6的REST场景中，无法复用WCF的IEndpointBehavior和IClientMessageInspector，替代方案是使用HttpClient的DelegatingHandler，它能实现和SOAP拦截器完全对应的全局请求/响应处理能力。

核心对应关系 #

代码实现步骤 #

1. 自定义全局拦截Handler #

创建继承自DelegatingHandler的类，重写SendAsync方法实现请求前、响应后的处理逻辑：

public class GlobalRestInterceptor : DelegatingHandler
{
    protected override async Task<HttpResponseMessage> SendAsync(
        HttpRequestMessage request, CancellationToken cancellationToken)
    {
        // -------------- 请求发送前处理（对应BeforeSendRequest）--------------
        // 示例：打印请求信息、添加自定义请求头
        Console.WriteLine($"[REST请求拦截] URL: {request.RequestUri}, 方法: {request.Method}");
        request.Headers.Add("X-Global-Interceptor", "Core6-Rest");

        // 发送请求
        var response = await base.SendAsync(request, cancellationToken);

        // -------------- 响应接收后处理（对应AfterReceiveReply）--------------
        // 示例：打印响应状态、读取响应内容
        Console.WriteLine($"[REST响应拦截] 状态码: {response.StatusCode}");
        var content = await response.Content.ReadAsStringAsync(cancellationToken);
        Console.WriteLine($"[REST响应拦截] 内容: {content}");

        // 可修改响应后返回（比如替换内容、修改状态码）
        return response;
    }
}

2. 全局注册拦截器 #

在Program.cs中，将自定义Handler注册到DI容器，并绑定到HttpClient：

var builder = WebApplication.CreateBuilder(args);

// 注册自定义拦截Handler
builder.Services.AddTransient<GlobalRestInterceptor>();

// 方式1：全局绑定到所有HttpClient实例
builder.Services.AddHttpClient()
    .AddHttpMessageHandler<GlobalRestInterceptor>();

// 方式2：仅绑定到指定命名的HttpClient（更灵活）
builder.Services.AddHttpClient("CustomRestClient")
    .AddHttpMessageHandler<GlobalRestInterceptor>();

// 后续服务配置...
var app = builder.Build();
// ...

3. 使用带拦截的HttpClient #

通过IHttpClientFactory获取配置好的HttpClient，发起REST请求时会自动触发拦截逻辑：

public class ProductService
{
    private readonly HttpClient _httpClient;

    // 通过DI注入IHttpClientFactory
    public ProductService(IHttpClientFactory httpClientFactory)
    {
        // 可选择全局HttpClient或指定命名的HttpClient
        _httpClient = httpClientFactory.CreateClient("CustomRestClient");
    }

    public async Task<List<Product>> GetProducts()
    {
        var response = await _httpClient.GetAsync("https://api.example.com/products");
        response.EnsureSuccessStatusCode();
        return await response.Content.ReadFromJsonAsync<List<Product>>();
    }
}

额外注意事项 #

• 支持多个DelegatingHandler串联，按注册顺序依次执行请求拦截，反向执行响应拦截
• 若需针对特定请求做差异化处理，可在SendAsync中根据请求URL、方法等条件分支处理
• 处理响应时注意不要提前消耗响应流，若需多次读取可先将内容缓存到内存流

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