让 Ocelot 与 asp.net core “共存”
2019-05-22 17:28
2166 查看
让 Ocelot 与 asp.net core “共存”
Intro
我们的 API 之前是一个单体应用,各个模块的服务是通过 Assembly 集成在一起,最后部署在一个 web server 下的。
我们已经在拆分服务并且在 Ocelot 的基础上封装了我们自己的网关,但是服务还没有完全拆分,于是有这么一个需求,对于 Ocelot 配置的路由去交给 Ocelot 去转发到真正的服务地址,而那些 Ocelot 没有定义的路由则让交给
AspNetCore去处理。
实现原理
实现原理是让 Ocelot 作为一个动态分支路由,只有当 Ocelot 配置了对应路由的下游地址才走 Ocelot 的分支,才把请求交给 Ocelot 处理。
我们可以使用
MapWhen来处理,接下来就需要知道怎么样判断
Ocelot是否配置了某一个路由,Ocelot 内部的处理管道,在向下游请求之前是要找到对应匹配的下游路由,所以我们去看一看 Ocelot 的源码,看看 Ocelot 内部是怎么找下游路由的,Ocelot 找下游路由中间件源码
public async Task Invoke(DownstreamContext context) { var upstreamUrlPath = context.HttpContext.Request.Path.ToString(); var upstreamQueryString = context.HttpContext.Request.QueryString.ToString(); var upstreamHost = context.HttpContext.Request.Headers["Host"]; Logger.LogDebug($"Upstream url path is {upstreamUrlPath}"); var provider = _factory.Get(context.Configuration); // 获取下游路由 var downstreamRoute = provider.Get(upstreamUrlPath, upstreamQueryString, context.HttpContext.Request.Method, context.Configuration, upstreamHost); if (downstreamRoute.IsError) { Logger.LogWarning($"{MiddlewareName} setting pipeline errors. IDownstreamRouteFinder returned {downstreamRoute.Errors.ToErrorString()}"); SetPipelineError(context, downstreamRoute.Errors); return; } var downstreamPathTemplates = string.Join(", ", downstreamRoute.Data.ReRoute.DownstreamReRoute.Select(r => r.DownstreamPathTemplate.Value)); Logger.LogDebug($"downstream templates are {downstreamPathTemplates}"); context.TemplatePlaceholderNameAndValues = downstreamRoute.Data.TemplatePlaceholderNameAndValues; await _multiplexer.Multiplex(context, downstreamRoute.Data.ReRoute, _next); }
通过上面的源码,我们就可以判断 Ocelot 是否有与请求相匹配的下游路由信息
实现
既然找到了 Ocelot 如何找下游路由,就先给 Ocelot 加一个扩展吧,实现代码如下,Ocelot 扩展完整代码
public static IApplicationBuilder UseOcelotWhenRouteMatch(this IApplicationBuilder app, Action<IOcelotPipelineBuilder, OcelotPipelineConfiguration> builderAction) => UseOcelotWhenRouteMatch(app, builderAction, new OcelotPipelineConfiguration()); public static IApplicationBuilder UseOcelotWhenRouteMatch(this IApplicationBuilder app, Action<OcelotPipelineConfiguration> pipelineConfigurationAction, Action<IOcelotPipelineBuilder, OcelotPipelineConfiguration> builderAction) { var pipelineConfiguration = new OcelotPipelineConfiguration(); pipelineConfigurationAction?.Invoke(pipelineConfiguration); return UseOcelotWhenRouteMatch(app, builderAction, pipelineConfiguration); } public static IApplicationBuilder UseOcelotWhenRouteMatch(this IApplicationBuilder app, Action<IOcelotPipelineBuilder, OcelotPipelineConfiguration> builderAction, OcelotPipelineConfiguration configuration) { app.MapWhen(context => { // 获取 OcelotConfiguration var internalConfigurationResponse = context.RequestServices.GetRequiredService<IInternalConfigurationRepository>().Get(); if (internalConfigurationResponse.IsError || internalConfigurationResponse.Data.ReRoutes.Count == 0) { // 如果没有配置路由信息,不符合分支路由的条件,直接退出 return false; } var internalConfiguration = internalConfigurationResponse.Data; var downstreamRouteFinder = context.RequestServices .GetRequiredService<IDownstreamRouteProviderFactory>() .Get(internalConfiguration); // 根据请求以及上面获取的Ocelot配置获取下游路由 var response = downstreamRouteFinder.Get(context.Request.Path, context.Request.QueryString.ToString(), context.Request.Method, internalConfiguration, context.Request.Host.ToString()); // 如果有匹配路由则满足该分支路由的条件,交给 Ocelot 处理 return !response.IsError && !string.IsNullOrEmpty(response.Data?.ReRoute?.DownstreamReRoute?.FirstOrDefault() ?.DownstreamScheme); }, appBuilder => appBuilder.UseOcelot(builderAction, configuration).Wait()); return app; }
使用
在 Startup 里
ConfigurationServices配置 mvc 和 Ocelot
Configure方法里配置 ocelot 和 mvc
app.UseOcelotWhenRouteMatch((ocelotBuilder, pipelineConfiguration) => { // This is registered to catch any global exceptions that are not handled // It also sets the Request Id if anything is set globally ocelotBuilder.UseExceptionHandlerMiddleware(); // This is registered first so it can catch any errors and issue an appropriate response ocelotBuilder.UseResponderMiddleware(); ocelotBuilder.UseDownstreamRouteFinderMiddleware(); ocelotBuilder.UseDownstreamRequestInitialiser(); ocelotBuilder.UseRequestIdMiddleware(); ocelotBuilder.UseMiddleware<ClaimsToHeadersMiddleware>(); ocelotBuilder.UseLoadBalancingMiddleware(); ocelotBuilder.UseDownstreamUrlCreatorMiddleware(); ocelotBuilder.UseOutputCacheMiddleware(); ocelotBuilder.UseMiddleware<HttpRequesterMiddleware>(); // cors headers ocelotBuilder.UseMiddleware<CorsMiddleware>(); }); app.UseMvc();
新建一个 TestController
[Route("/api/[controller]")] public class TestController : ControllerBase { public IActionResult Get() { return Ok(new { Tick = DateTime.UtcNow.Ticks, Msg = "Hello Ocelot", }); } }
具体代码可以参考这个 网关示例项目
示例项目的 Ocelot 配置是存在 Redis 里面的,配置的 ReRoutes 如下:
{ "ReRoutes": [ { "DownstreamPathTemplate": "/api.php?key=free&appid=0&msg={everything}", "UpstreamPathTemplate": "/api/chat/{everything}", "UpstreamHttpMethod": [ "Get", "POST", "PUT", "PATCH", "DELETE", "OPTIONS" ], "AddHeadersToRequest": { }, "RequestIdKey": "RequestId", "ReRouteIsCaseSensitive": false, "ServiceName": "", "DownstreamScheme": "http", "DownstreamHostAndPorts": [ { "Host": "api.qingyunke.com", "Port": 80 } ], "DangerousAcceptAnyServerCertificateValidator": false } ], "GlobalConfiguration": { "HttpHandlerOptions": { "AllowAutoRedirect": false, "UseCookieContainer": false, "UseTracing": false } } }
运行项目进行测试:
访问 Ocelot 定义的路由 http://localhost:65125/api/chat/hello ,返回信息如图所示:
访问 Mvc 定义的路由 http://localhost:65125/api/test,返回信息如图所示:
上面正常的返回就表示我们的 Ocelot 和 Mvc 同时工作了~
Reference
相关文章推荐
- asp.net core系列 59 Ocelot 构建基础项目示例
- (8)学习笔记 ) ASP.NET CORE微服务 Micro-Service ---- Ocelot网关(Api GateWay)
- Asp.Net Core + Ocelot 网关搭建:路由简单配置
- asp.net core系列 60 Ocelot 构建服务认证示例
- Asp.Net Core API网关Ocelot
- Asp.Net Core + Ocelot 网关搭建:负载均衡的配置
- asp.net core系列 61 Ocelot 构建服务发现简单示例
- (10)学习笔记 ) ASP.NET CORE微服务 Micro-Service ---- Ocelot+Identity Server
- 学习 ASP.NET Core 2.1:集成测试中使用 WebApplicationFactory
- ASP.NET Core 2.1 : 十一. 如何在后台运行一个任务
- 一起学ASP.NET Core 2.0学习笔记(一): CentOS下 .net core2 sdk nginx、supervisor、mysql环境搭建
- 基于Asp.Net Core的简单社区项目源代码开源
- ASP.NET Core中的依赖注入(1):控制反转(IoC)
- ASP.NET与ASP.NET Core用户验证Cookie并存解决方案
- Asp.Net Core-配置
- asp.net core系列 51 Identity 授权(下)
- asp.net core系列 54 IS4用客户端凭据保护API
- CentOS 部署asp.net core
- 详解ASP.NET Core 中的多语言支持(Localization)
- ASP.NET Core 介绍和项目解读