0

我创建了一个 C# 微服务，它提供了几个不同（但相关）的功能。

我现在正在为一个客户端创建一个 C# Nuget 包，它将帮助其他 C# 微服务利用这个微服务。这将包括一个服务集合扩展类，以方便将客户端添加到这些微服务中。

为了分离关注点，在客户端中，我将功能分为三类：

  • SalesforceCacheQuerier
  • SalesforceCacheSyncDataManipulator
  • SalesforceCacheAsyncDataManipulator

这些中的每一个都需要调用同一台服务器。

作为一个幼稚的第一个实现，我编写了这个方法：

        public static IServiceCollection AddSalesforceClients(this IServiceCollection services)
        {
            services.AddTransient<SalesforceCacheAuthenticationHandler>();
            ConfigureClient(services.AddHttpClient<ISalesforceCacheQuerier, SalesforceCacheQuerier>());
            ConfigureClient(services.AddHttpClient<ISalesforceCacheSyncDataManipulator, SalesforceCacheSyncDataManipulator>());
            ConfigureClient(services.AddHttpClient<ISalesforceCacheAsyncDataManipulator, SalesforceCacheAsyncDataManipulator>());
            return services;
        }

        private static IHttpClientBuilder? ConfigureClient(IHttpClientBuilder? clientBuilder)
            => clientBuilder.ConfigureHttpClient(ConfigureClient)
            .ConfigurePrimaryHttpMessageHandler(() => new SocketsHttpHandler())
            .AddHttpMessageHandler<SalesforceCacheAuthenticationHandler>();

        private static void ConfigureClient(IServiceProvider provider, HttpClient client)
        {
            SalesforceCacheSettings? settings = provider.GetRequiredService<SalesforceCacheSettings>();
            client.BaseAddress = new Uri(settings.BaseUrl, settings.ApiEndpoint);
            client.DefaultRequestHeaders.ExpectContinue = true;
        }

但是，这会生成三个单独的 HttpClient，并使用于提供 Jwt 令牌的“身份服务器”的流量增加三倍。

如何重构它以仅创建和重用一个 HttpClient？

4

2 回答 2

0

您可以使用 HttpClientFactory 并将其注入到 稍后ConfigureServices 需要services.AddHttpClient(); 客户端对象的地方，只需IHttpClientFactory httpClientFactory在构造函数中提供，您就可以通过要求工厂创建客户端来访问客户端对象。

HttpClient = HttpClientFactory.CreateClient();以这种方式。

如果您想为客户端保留身份验证并重用它。我建议为每种请求类型维护一个字典。

var HttpClients = new Dictionary<string, HttpClient>();

HttpClients.Add(SalesforceCacheQuerierKey, SalesforceCacheQuerierClient);

//假设所有与身份验证相关的标头都添加到此客户端对象 //SalesforceCacheQuerierClient

并从启动级别传递这些。

于 2021-02-05T16:15:09.880 回答
0

我需要的是这样的：

            services.AddHttpClient(SALESFORCE_CACHE_CLIENT, (provider, client) =>
            {
                SalesforceCacheClientSettings? settings = provider.GetRequiredService<SalesforceCacheClientSettings>();
                client.BaseAddress = new Uri(settings.BaseUrl, settings.ApiEndpoint);
                client.DefaultRequestHeaders.ExpectContinue = true;
            })
                .AddHttpMessageHandler<SalesforceCacheAuthenticationHandler>();

            services.AddHttpClient<ISalesforceCacheQuerier, SalesforceCacheQuerier>(SALESFORCE_CACHE_CLIENT);
            services.AddHttpClient<ISalesforceCacheSyncDataManipulator, SalesforceCacheSyncDataManipulator>(SALESFORCE_CACHE_CLIENT);
            services.AddHttpClient<ISalesforceCacheAsyncDataManipulator, SalesforceCacheAsyncDataManipulator>(SALESFORCE_CACHE_CLIENT);
于 2021-02-08T15:56:03.877 回答