consul：啥？我被优化没了？AgileConfig+Yarp替代Ocelot+Consul实现服务发

爱丽摄影摄像

现在软件就业环境不景气，各行各业都忙着裁员优化。作为一个小开发，咱也不能光等着别人来优化咱，也得想办法优化下自己。就拿手头上的工作来说吧，我发现我的微服务应用里，既有AgileConfig这个配置中心组件，又有一个Consul 服务发现组件。本来吧他俩也没啥事，各干个的。但是，我在操作AgileConfig的时候发现了一个事

然后我又一百度发现了这个AgileConfig 1.6.0 发布 - 支持服务注册与发现 - Agile.Zhou - 博客园 (cnblogs.com)，有点意思。稍微一思索，我们现在的微服务解决方案里网关用的ocelot+consul 作为HTTP api网关，同时 还是用了 yarp做 grpc的网关，明显可以看出来有一套多余的网关在这里。基于目前的情况，我是一直想优化掉 ocelot+consul这个组合。改用 agileConfig+yarp，奈何前期对微服务机制不是很熟悉，有堆坑要填。现在看到agileconfig的服务列表，又勾起了我这个优化的想法。说干就干，我理想的目标是可以直接从agileconfig上获取到所有注册的服务，然后用代码来动态给yarp添加代理配置。这样既可以优化掉一个consul服务，又可以免去每次服务部署时繁琐的网关配置。
首先第一个任务就是解决yarp如何用代码实现动态配置的问题。bing 里搜索 yarp 动态配置 ，优先看博客园的博主发的文章，事实上我也就只看了这一篇Welcome to YARP - 2.2 配置功能 - 配置提供者(Configuration Providers) - coding-y - 博客园 (cnblogs.com) 。完美，问题解决。下面就是代码时间。
通过上面两篇文章我们知道，agileconfig会提供一个IDiscoveryService 接口来供程序获取注册的服务信息。同时 yarp也提供了从内存中提供配置的 InMemoryConfigProvider ,那我们只需要在agileconfig 注册之后 通过 IDisconverService接口 获取所有已注册服务，然后再让yarp应用上内存中的配置即可实现服务注册后自动配置代理的需求。
下面我们动动手指头 按下 ctrl c ,ctrl v实现如下代码：代码不具备通用性 需要进一步优化 建议已给出。

1. using AgileConfig.Client;
2. using AgileConfig.Client.RegisterCenter;
3. using Newtonsoft.Json.Linq;
5. using Yarp.ReverseProxy.Configuration;
6. using Yarp.ReverseProxy.Transforms;
8. namespace Microsoft.Extensions.DependencyInjection
9. {
10.     public static class AgileConfigProxyConfigProviderExtend
11.     {
12.         const string NotProxyStr = "notProxy";
13.         const string TransformsStr = "Transforms";
14.         static readonly ILogger _Logger = LoggerFactory.Create(b => { }).CreateLogger("AgileConfigProxyConfigProviderExtend");
15.         public static RouteConfig[] GetRoutes(this IDiscoveryService discoveryService)
16.         {
17.             var routes = new List<RouteConfig>();
18.             foreach (var item in discoveryService.Services)
19.             {
20.                 if (item.MetaData.Any(r=>r.Equals(NotProxyStr, StringComparison.OrdinalIgnoreCase)))
21.                 {
22.                     continue;
23.                 }
24.                 var route = new RouteConfig
25.                 {
26.                     RouteId = item.ServiceId,
27.                     ClusterId = item.ServiceName,
28.                     Match = new RouteMatch
29.                     {
30.                         Path = $"/{item.ServiceName}/{{**all}}"
31.                     }
32.                 };
33.                 //.WithTransformPathRouteValues(pattern: new PathString("/{**all}"))
34.                 try
35.                 {
36.                     var transformStr = item.MetaData.FirstOrDefault(r => r.StartsWith(TransformsStr));
37.                     if (transformStr is not null)
38.                     {
39.                         var jobj = JObject.Parse(transformStr.Split(':')[1]);
40.                         foreach (var k in jobj)
41.                         {
42.                             route.WithTransform(d => d.Add(k.Key, k.Value?.ToString() ?? ""));
43.                         }
44.                     }
45.                 }
46.                 catch (Exception e)
47.                 {
48.                     _Logger.LogError(e,"生成路由【转换】配置时出错");
49.                 }
51.                 routes.Add(route);
52.                 _Logger.LogTrace("添加路由{RouteId}", route.RouteId);
53.             }
54.             return routes.ToArray();
55.         }
56.         public static ClusterConfig[] GetClusters(this IDiscoveryService discoveryService)
57.         {
58.             var clusters = new List<ClusterConfig>();
59.             var proxyServices = discoveryService.Services
60.                                     .Where(r => !r.MetaData.Any(r => r.Equals(NotProxyStr, StringComparison.OrdinalIgnoreCase)))
61.                                     .GroupBy(p => p.ServiceName);
63.             foreach (var item in proxyServices)
64.             {
65.                 var destinations = new Dictionary<string, DestinationConfig>(StringComparer.OrdinalIgnoreCase);
66.                 foreach (var service in item)
67.                 {
68.                     destinations.Add(service.ServiceId, new DestinationConfig() {
69.                         Address=service.AsHttpHost()
70.                     });
71.                 }
73.                 clusters.Add(new ClusterConfig
74.                 {
75.                     ClusterId = item.Key,
76.                     Destinations = destinations
77.                 });
78.             }
80.             return clusters.ToArray();
81.         }
82.         //可以再加一个重载 支持传入一个委托 来自定义构造配置。
83.         public static IReverseProxyBuilder LoadFromAgileConfigByInMemoryConfigProvider(this IReverseProxyBuilder builder, ConfigClient client)
84.         {
85.             var discoveryService = client.DiscoveryService();
86.             discoveryService ??= new DiscoveryService(client, LoggerFactory.Create(b => b.SetMinimumLevel(LogLevel.Information)));
88.             var configProvider = new InMemoryConfigProvider(discoveryService.GetRoutes(), discoveryService.GetClusters());
90.             builder.Services.AddSingleton(configProvider);
91.             builder.Services.AddSingleton<IProxyConfigProvider>(configProvider);
93.             discoveryService.ReLoaded += () =>
94.             {
95.                 configProvider.Update(discoveryService.GetRoutes(), discoveryService.GetClusters());
96.             };
97.             return builder;
98.         }
99.     }
100. }

复制代码

现在只需要调用如下代码，即可给原有的yarp服务加上自动生成代理配置的功能了。

1. builder.Services.AddReverseProxy()//添加ReverseProxy相关服务到DI
3. .LoadFromAgileConfigByInMemoryConfigProvider((ConfigClient)client);

复制代码

注意：注册AgileConfig时候请使用 UseAgileConfig()方法注册。Addxxx方法会导致无法获取到agileConfig上的已注册服务对信息。
代码已传gitee:https://gitee.com/dotnetfans/yarp-auto-proxy.-agile-config
同时也个给agileConfig 提交了合并请求。

来源:https://www.cnblogs.com/xdq-zh/p/18122481
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！