使用具有不同配置的自定义 HttpMessageHandler

Question

我有一个自定义的HttpMessageHandler 实现：

public class MyHandler : DelegatingHandler
{
    private readonly HttpClient _httpClient;
    private readonly MyHandlerOptions _config;

    public MyHandler(
        HttpClient httpClient,
        IOptions<MyHandlerOptions> options)
    {
        _httpClient = httpClient;
        _config = options.Value;
    }

    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
    {
        request.Headers.Authorization = await GetAccessToken()
        return await base.SendAsync(request, cancellationToken);
    }

    private async Task<string> GetAccessToken()
    {
        //some logic to get access token using _httpClient and _config
    }

}

它需要配置对象MyHandlerOptions。它的形式在这里并不那么重要。它基本上包含处理程序知道如何获取访问令牌所需的 clientId、clientSecret 等。

我有一些需要使用MyHandler 的服务（键入的http 客户端）：

//registration of MyHandler itself
builder.Services.AddHttpClient<MyHandler>();

//configuration of MyHandler
builder.Services.AddOptions<MyHandlerOptions>()
.Configure<IConfiguration>((config, configuration) =>
{
    configuration.GetSection("MyHandlerOptions").Bind(config);
});

//Services that need to use MyHandler:
services.AddHttpClient<Service1>()
    .AddHttpMessageHandler<MyHandler>();
services.AddHttpClient<Service2>()
    .AddHttpMessageHandler<MyHandler>();
services.AddHttpClient<Service3>()
    .AddHttpMessageHandler<MyHandler>();

问题是我注册的MyHandlerOptions实例只有在与Service1一起使用时才有效。但是Service2和Service3需要其他配置（不同的clientId、clientSecret等）。我怎样才能实现它？

我想到的可能解决方案：

1. 创建新服务：

public class AccessTokenGetter 
{
    Task<string> GetAccessToken(AccessTokenConfig config) 
    {
        //get the access token...
    }
}

1. 为每个配置不同的情况创建单独的HttpMessageHandlers：

public class MyHandler1 : DelegatingHandler
{
    private readonly MyHandler1Options _config;
    private readonly AccessTokenGetter _accessTokenGetter;

    public MyHandler(AccessTokenGetter accessTokenGetter, IOptions<MyHandlerOptions1> options)
    {
        _accessTokenGetter = accessTokenGetter;
        _config = options.Value;
    }

    protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
    {
        //somehow convert _config to AccessTokenConfig
        request.Headers.Authorization = await _accessTokenGetter.GetAccessToken(_config)
        return await base.SendAsync(request, cancellationToken);
    }
}

public class MyHandler2 : DelegatingHandler
{
    //same implementation as MyHandler1, just use MyHandler2Options instead
}

1. 注册我的服务：

//configurations
builder.Services.AddOptions<MyHandler1Options>()
.Configure<IConfiguration>((config, configuration) =>
{
    configuration.GetSection("MyHandler1Options").Bind(config);
});

builder.Services.AddOptions<MyHandler2Options>()
.Configure<IConfiguration>((config, configuration) =>
{
    configuration.GetSection("MyHandler2Options").Bind(config);
});

//AccessTokenGetter
services.AddHttpClient<AccessTokenGetter>()

//Services that need to use MyHandlers:
services.AddHttpClient<Service1>()
    .AddHttpMessageHandler<MyHandler1>();
services.AddHttpClient<Service2>()
    .AddHttpMessageHandler<MyHandler2>();
services.AddHttpClient<Service3>()
    .AddHttpMessageHandler<MyHandler2>();

有没有更好的解决方案？我不是我的想法的忠实拥护者，它不是很灵活。

Answer 1

services.AddHttpClient<Service1>()
    .AddHttpMessageHandler(sp => 
    {
         var handler = sp.GetRequiredService<MyHandler>();
         handler.Foo = "Bar";
         return handler;
    });

services.AddHttpClient<Service2>()
    .AddHttpMessageHandler(sp => 
    {
         var handler = sp.GetRequiredService<MyHandler>();
         handler.Foo = "Baz";
         return handler;
    });