.NET 反向代理 YARP 自定義配置提供程式（Configuration Providers）

介紹

　　基本 Yarp 示例顯示從 appsettings.json 載入的代理配置。相反，代理配置可以從您選擇的源以編程方式載入。您可以通過提供幾個實現 IProxyConfigProvider 和 IProxyConfig 的類來做到這一點。

　　可以使用配置過濾器在載入序列期間修改配置。

結構

　　IProxyConfigProvider 有一個方法應該返回一個 IProxyConfig 實例。 IProxyConfig 具有當前路由和集群的列表，以及在此信息過期並應重新載入時通知代理，這將導致再次調用（GetConfig()IChangeTokenGetConfig()）

路線

　　路由部分是命名路由的無序集合。路由包含匹配項及其相關配置。一條路線至少需要以下欄位：

　　RouteId - 一個唯一的名稱

　　ClusterId - 指集群部分中的條目名稱。

　　Match - 包含 Hosts 數組或 Path 模式字元串。 Path 是一個 ASP.NET Core 路由模板，可以按照此處的說明進行定義。

　　可以在每個路由條目上配置標頭、授權、CORS 和其他基於路由的策略。

　　代理將應用給定的匹配條件和策略，然後將請求傳遞給指定的集群。

集群

　　集群部分是命名集群的無序集合。集群主要包含命名目的地及其地址的集合，其中任何一個都被認為能夠處理給定路由的請求。代理將根據路由和集群配置處理請求以選擇目的地。

生命周期

啟動

　　應該在 DI 容器中註冊為單例。啟動時，代理將解析此實例並調用 .在第一次調用時，提供者可以選擇：IProxyConfigProviderGetConfig()

　　如果提供者出於任何原因無法生成有效的代理配置，則拋出異常。這將阻止應用程式啟動。

　　在載入配置時同步阻塞。這將阻止應用程式啟動，直到有效的路線數據可用。

　　或者，它可以選擇在後臺載入配置時返回一個空實例。提供者將需要在配置可用時觸發（IProxyConfigIChangeToken）

　　代理將驗證給定的配置，如果它無效，將引發異常，阻止應用程式啟動。提供者可以通過使用 IConfigValidator 來預先驗證路由和集群並採取它認為適當的任何操作（例如排除無效條目）來避免這種情況。

原子性

　　提供給代理的配置對象和集合應該是只讀的，一旦通過 .GetConfig() 傳遞給代理就不能修改

重新載入

　　如果支持，一旦代理處理了初始配置集，它將使用此令牌註冊回調。如果提供者不支持回調，則每 5 分鐘輪詢一次（IChangeTokenActiveChangeCallbacksHasChanged）

　　1、當提供者想要為代理提供新配置時，它應該：

　　（1）在後臺載入該配置。

　　　　a. 路由和集群對象是不可變的，因此必須為任何新數據創建新實例。

　　　　b. 可以重新使用未更改的路由和集群的對象，或者可以創建新的實例 - 將通過區分它們來檢測更改。

　　（2）可選地使用 IConfigValidator 驗證配置，然後才從先前的實例發出新數據可用的信號。代理將再次調用以檢索新數據（IChangeTokenIProxyConfigGetConfig()）

　　2、重新載入配置與第一次配置載入時存在重要差異。

　　（1）新配置將與當前配置不同，並且只會更新修改後的路由或集群。更新將自動應用，並且只會影響新請求，而不影響當前正在進行的請求。

　　（2）重新載入過程中的任何錯誤都將被記錄並抑制。應用程式將繼續使用上次已知的正確配置。

　　（3）如果拋出代理將無法監聽未來的變化，因為 s 是一次性的（GetConfig()IChangeToken）

　　驗證並應用新配置後，代理將使用新的 .請註意，如果連續發出多次重新載入信號，代理可能會跳過一些併在準備好後立即載入下一個可用配置。每個都包含完整的配置狀態，因此不會丟失任何內容（IChangeTokenIProxyConfig）

多個配置源

　　從 1.1 開始，YARP 支持從多個來源載入代理配置。 多個可以註冊為單例服務，所有將被解析和組合。 源可以是相同或不同的類型，例如 IConfiguration 或 InMemory。 路由可以引用其他來源的集群。 請註意，不支持為給定路由或集群合併來自不同來源的部分配置（IProxyConfigProvider）

services.AddReverseProxy()
        .LoadFromConfig(Configuration.GetSection("ReverseProxy1"))
        .LoadFromConfig(Configuration.GetSection("ReverseProxy2"));

或者

services.AddReverseProxy()
        .LoadFromMemory(routes, clusters)
        .LoadFromConfig(Configuration.GetSection("ReverseProxy"));

Example

　　以下是手動載入路由和集群的示例（IProxyConfigProvider）

using System.Collections.Generic;
using System.Threading;
using Microsoft.Extensions.Primitives;
using Yarp.ReverseProxy.Configuration;

namespace Microsoft.Extensions.DependencyInjection
{
    public static class InMemoryConfigProviderExtensions
    {
        public static IReverseProxyBuilder LoadFromMemory(this IReverseProxyBuilder builder, IReadOnlyList<RouteConfig> routes, IReadOnlyList<ClusterConfig> clusters)
        {
            builder.Services.AddSingleton<IProxyConfigProvider>(new InMemoryConfigProvider(routes, clusters));
            return builder;
        }
    }
}

namespace Yarp.ReverseProxy.Configuration
{
    public class InMemoryConfigProvider : IProxyConfigProvider
    {
        private volatile InMemoryConfig _config;

        public InMemoryConfigProvider(IReadOnlyList<RouteConfig> routes, IReadOnlyList<ClusterConfig> clusters)
        {
            _config = new InMemoryConfig(routes, clusters);
        }

        public IProxyConfig GetConfig() => _config;

        public void Update(IReadOnlyList<RouteConfig> routes, IReadOnlyList<ClusterConfig> clusters)
        {
            var oldConfig = _config;
            _config = new InMemoryConfig(routes, clusters);
            oldConfig.SignalChange();
        }

        private class InMemoryConfig : IProxyConfig
        {
            private readonly CancellationTokenSource _cts = new CancellationTokenSource();

            public InMemoryConfig(IReadOnlyList<RouteConfig> routes, IReadOnlyList<ClusterConfig> clusters)
            {
                Routes = routes;
                Clusters = clusters;
                ChangeToken = new CancellationChangeToken(_cts.Token);
            }

            public IReadOnlyList<RouteConfig> Routes { get; }

            public IReadOnlyList<ClusterConfig> Clusters { get; }

            public IChangeToken ChangeToken { get; }

            internal void SignalChange()
            {
                _cts.Cancel();
            }
        }
    }
}

　　下麵是它在 Startup.cs 中的調用方式：

public void ConfigureServices(IServiceCollection services)
{
    var routes = new[]
    {
        new RouteConfig()
        {
            RouteId = "route1",
            ClusterId = "cluster1",
            Match = new RouteMatch
            {
                Path = "{**catch-all}"
            }
        }
    };
    var clusters = new[]
    {
        new ClusterConfig()
        {
            ClusterId = "cluster1",
            Destinations = new Dictionary<string, DestinationConfig>(StringComparer.OrdinalIgnoreCase)
            {
                { "destination1", new DestinationConfig() { Address = "https://example.com" } }
            }
        }
    };

    services.AddReverseProxy()
        .LoadFromMemory(routes, clusters);
}

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
    if (env.IsDevelopment())
    {
        app.UseDeveloperExceptionPage();
    }

    app.UseRouting();
    app.UseEndpoints(endpoints =>
    {
        endpoints.MapReverseProxy();
    });
}

原文鏈接：https://www.cnblogs.com/ysmc/p/16727084.html