ocelot 中间件的变化

ocelot 中间件的变化

Intro

之前我们使用 ocelot 的时候自定义了一些中间件来实现我们定制化的一些需求，最近博客园上有小伙伴问我怎么使用，他用的版本是 16.0 版本，16.0 和 17.0 版本的差异不是特别大，就以 17.0 版本为例看一下 ocelot 中间件的变化

Sample

还是拿之前的一个自定义认证授权的一个中间件为例，中间件做的事情主要是

  1. 基于 Resource（API Path） 以及 请求 Method 查询需要的权限

  2. 如果不需要用户登录就可以访问，就直接往下游服务转发

  3. 如果需要权限，判断当前登录用户的角色是否有对应的角色可以访问

  4. 如果可以访问就转发到下游服务，如果没有权限访问根据用户是否登录，已登录返回 403 Forbidden，未登录返回 401 Unauthorized

Before

之前的实现（基于 13.x 版本）详细可以参考：https://www.cnblogs.com/weihanli/p/custom-authentication-authorization-in-ocelot.html

大致代码如下：

public class UrlBasedAuthenticationMiddleware : Ocelot.Middleware.OcelotMiddleware
{private readonly IConfiguration _configuration;private readonly IMemoryCache _memoryCache;private readonly OcelotRequestDelegate _next;public UrlBasedAuthenticationMiddleware(OcelotRequestDelegate next, IConfiguration configuration, IMemoryCache memoryCache, IOcelotLoggerFactory loggerFactory) : base(loggerFactory.CreateLogger<UrlBasedAuthenticationMiddleware>()){_next = next;_configuration = configuration;_memoryCache = memoryCache;}public async Task Invoke(DownstreamContext context){var permissions = await _memoryCache.GetOrCreateAsync("ApiPermissions", async entry =>{using (var conn = new SqlConnection(_configuration.GetConnectionString("ApiPermissions"))){entry.AbsoluteExpirationRelativeToNow = TimeSpan.FromHours(1);return (await conn.QueryAsync<ApiPermission>("SELECT * FROM dbo.ApiPermissions")).ToArray();}});var result = await context.HttpContext.AuthenticateAsync(context.DownstreamReRoute.AuthenticationOptions.AuthenticationProviderKey);context.HttpContext.User = result.Principal;var user = context.HttpContext.User;var request = context.HttpContext.Request;var permission = permissions.FirstOrDefault(p =>request.Path.Value.Equals(p.PathPattern, StringComparison.OrdinalIgnoreCase) && p.Method.ToUpper() == request.Method.ToUpper());if (permission == null)// 完全匹配不到，再根据正则匹配{permission =permissions.FirstOrDefault(p =>Regex.IsMatch(request.Path.Value, p.PathPattern, RegexOptions.IgnoreCase) && p.Method.ToUpper() == request.Method.ToUpper());}if (!user.Identity.IsAuthenticated){if (permission != null && string.IsNullOrWhiteSpace(permission.AllowedRoles)) //默认需要登录才能访问{//context.HttpContext.User = new ClaimsPrincipal(new ClaimsIdentity(new[] { new Claim(ClaimTypes.Name, "Anonymous") }, context.DownstreamReRoute.AuthenticationOptions.AuthenticationProviderKey));}else{SetPipelineError(context, new UnauthenticatedError("unauthorized, need login"));return;}}else{if (!string.IsNullOrWhiteSpace(permission?.AllowedRoles) &&!permission.AllowedRoles.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries).Any(r => user.IsInRole(r))){SetPipelineError(context, new UnauthorisedError("forbidden, have no permission"));return;}}await _next.Invoke(context);}
}

New

来看一下在新版本（16.x/17.x）的 ocelot 中实现代码是怎样的

public class ApiPermission
{public string AllowedRoles { get; set; }public string PathPattern { get; set; }public string Method { get; set; }
}public class UrlBasedAuthenticationMiddleware : Ocelot.Middleware.OcelotMiddleware
{private readonly IConfiguration _configuration;private readonly IMemoryCache _memoryCache;private readonly RequestDelegate _next;public UrlBasedAuthenticationMiddleware(RequestDelegate next, IConfiguration configuration, IMemoryCache memoryCache, IOcelotLoggerFactory loggerFactory) : base(loggerFactory.CreateLogger<UrlBasedAuthenticationMiddleware>()){_next = next;_configuration = configuration;_memoryCache = memoryCache;}public async Task Invoke(HttpContext httpContext){// var permissions = await _memoryCache.GetOrCreateAsync("ApiPermissions", async entry =>//{//    using (var conn = new SqlConnection(_configuration.GetConnectionString("ApiPermissions")))//    {//        entry.AbsoluteExpirationRelativeToNow = TimeSpan.FromHours(1);//        return (await conn.QueryAsync<ApiPermission>("SELECT * FROM dbo.ApiPermissions")).ToArray();//    }//});var permissions = new[]{new ApiPermission(){PathPattern = "/api/test/values",Method = "GET",AllowedRoles = ""},new ApiPermission(){PathPattern = "/api/test/user",Method = "GET",AllowedRoles = "User"},new ApiPermission(){PathPattern = "/api/test/admin",Method = "GET",AllowedRoles = "Admin"},};var downstreamRoute = httpContext.Items.DownstreamRoute();var result = await httpContext.AuthenticateAsync(downstreamRoute.AuthenticationOptions.AuthenticationProviderKey);if (result.Principal != null){httpContext.User = result.Principal;}var user = httpContext.User;var request = httpContext.Request;var permission = permissions.FirstOrDefault(p =>request.Path.ToString().Equals(p.PathPattern, StringComparison.OrdinalIgnoreCase) && p.Method.ToUpper() == request.Method.ToUpper());if (permission == null){permission =permissions.FirstOrDefault(p =>Regex.IsMatch(request.Path.ToString(), p.PathPattern, RegexOptions.IgnoreCase) && p.Method.ToUpper() == request.Method.ToUpper());}if (user.Identity?.IsAuthenticated == true){if (!string.IsNullOrWhiteSpace(permission?.AllowedRoles) &&!permission.AllowedRoles.Split(new[] { ',' }, StringSplitOptions.RemoveEmptyEntries).Any(r => user.IsInRole(r))){httpContext.Items.SetError(new UnauthorizedError("forbidden, have no permission"));return;}}else{if (permission != null && string.IsNullOrWhiteSpace(permission.AllowedRoles)){}else{httpContext.Items.SetError(new UnauthenticatedError("unauthorized, need login"));return;}}await _next.Invoke(httpContext);}
}

Diff

主要的区别在于 ocelot 中间件的变化，在之前的版本，ocelot 是自己的中间件，签名是 Task Invoke(DownstreamContext context) 是 ocelot 自己的 DownstreamContext，在之后 ，Ocelot 为了和 asp.net core 中间件保持一样的签名，以更好的复用 asp.net core 中的中间件，更新了自己的中间件， ocelot 自己的 context 等信息现在放在了 HttpContext.Items 中，并通过一系列的扩展方法来获取和更新对应的信息

但是目前的实现并不能够完全等同于 asp.net core 中间件，因为如果你想要中断某一个中间件的话现在大概是有问题的，因为现在 ocelot 中间件里的 HttpContext 并不是原始的 HttpContext ocelot 会在真正开始处理请求之前新建一个 HttpContext 把基本的请求信息复制过去，主要实现代码: https://github.com/ThreeMammals/Ocelot/blob/17.0.0/src/Ocelot/Multiplexer/MultiplexingMiddleware.cs

如果想要在自定义中间件中实现中断，需要使用 ocelot 的中间件，通过 SetError 来去处理而不要直接使用 httpContext.Response 去中断请求

API Diff

  1. 中间件 Invoke 方法签名，从原来的 Task Invoke(DownstreamContext context) 更新成 Task Invoke(HttpContext context)

  2. SetPipelineError 不再是 OcelotMiddleware 中的一个方法，通过 httpContext.Items.SetError 方法来代替

  3. 通过 httpContext.Items.DownstreamRoute() 来获取当前请求的 DownstreamRoute 信息

More

除了中间件的变化，配置也发生了变化，原来的 ReRoute 也变成了 Route，升级的时候需要注意一下配置的变化，否则可能就会 404 了，在 17.0 之后，authorisation 更新成了 authorization, authorise 也更新成了 authorize

更多更新可以参考 ocelot 的 PR changes 和文档

文中提到的示例在 Github 上可以获取完整的代码 https://github.com/WeihanLi/AspNetCorePlayground/tree/master/OcelotDemo

Reference

  • https://github.com/ThreeMammals/Ocelot/compare/15.0.0...16.0.0

  • https://github.com/ThreeMammals/Ocelot/compare/16.0.0...17.0.0

  • https://github.com/WeihanLi/AspNetCorePlayground/tree/master/OcelotDemo

  • https://www.cnblogs.com/weihanli/p/custom-authentication-authorization-in-ocelot.html

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/305841.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

mybatis mysql usegeneratedkeys_mybatis中useGeneratedKeys用法--插入数据库后获取主键值

mybatis mysql usegeneratedkeys_mybatis中useGeneratedKeys用法--插入数据库后获取主键值

前言&#xff1a;今天无意在mapper文件中看到useGeneratedKeys这个词&#xff0c;好奇就查了下&#xff0c;发现能解决我之前插入有外键表数据时&#xff0c;这个外键获取繁琐的问题&#xff0c;于是学习敲DEMO记录在项目中经常需要获取到插入数据的主键来保障后续操作&#xf…
阅读更多...
Istio 知多少 | 下一代微服务的守护者

Istio 知多少 | 下一代微服务的守护者

1. 引言在写完eShopOnContainers 知多少[12]&#xff1a;Envoy gateways后&#xff0c;就一直想进一步探索Service Mesh&#xff0c;最近刚在极客时间上学完《Service Mesh入门》&#xff0c;又大致浏览了一遍官方文档&#xff0c;对Istio也算有了基本的认识。下面就根据自己的…
阅读更多...
微软家也会出错

微软家也会出错

下图是2006年2月8日微软WebCast首页的截图转载于:https://www.cnblogs.com/mssite/archive/2006/02/08/327130.html
阅读更多...
mysql 基础视图_MySQL基础（4） | 视图

mysql 基础视图_MySQL基础（4） | 视图

MySQL基础(4) | 视图基本语法1.创建CREATE VIEW AS 语法说明如下。&#xff1a;指定视图的名称。该名称在数据库中必须是唯一的&#xff0c;不能与其他表或视图同名。&#xff1a;指定创建视图的 SELECT 语句&#xff0c;可用于查询多个基础表或源视图。对于创建视图中的 SELEC…
阅读更多...
C# 中的 null 包容运算符 “!” —— 概念、由来、用法和注意事项

C# 中的 null 包容运算符 “!” —— 概念、由来、用法和注意事项

在 2020 年的最后一天&#xff0c;博客园发起了一个开源项目&#xff1a;基于 .NET 的博客引擎 fluss&#xff0c;我抽空把源码下载下来看了下&#xff0c;发现在属性的定义中&#xff0c;有很多地方都用到了 null!&#xff0c;如下图所示&#xff1a;这是什么用法呢&#xff1…
阅读更多...
[转]不找情人的七种理由(献给已婚的男人)

[转]不找情人的七种理由(献给已婚的男人)

献给已婚的男人不找情人的七种理由 　　好像有个曾一度风靡的短信&#xff0c;“结婚是错误,离婚是觉悟,婚外恋是醒悟,再婚是执迷不悟,没有情人是废物,情人太多是动物。”咱不怕犯错误&#xff0c;可没办法不当废物&#xff0c;三十好几还没混上个情人&#xff0c;想起来就惭…
阅读更多...
无法初始化java类_myeclip运行java程序不能初始化类 NoClassDefFoundError

无法初始化java类_myeclip运行java程序不能初始化类 NoClassDefFoundError

引用 3 楼 Menglinyang 的回复:是就这个项目有问题还是所有的都是这样&#xff1f;package cn.itcast.utils;import java.io.InputStream;import java.sql.Connection;import java.sql.DriverManager;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.…
阅读更多...
C#学习笔记（十四）：StatusBar控件

C#学习笔记（十四）：StatusBar控件

状态栏控件StatusBar<?xml:namespace prefix o ns "urn:schemas-microsoft-com:office:office" />StatusBar的一些常用属性&#xff1a;名称可用性描述BackgroundImage读写可以给状态栏赋予一个图像&#xff0c;显示在背景上。Panels只读这是状态栏上的面板…
阅读更多...
微前端架构在容器平台的应用

微前端架构在容器平台的应用

源宝导读&#xff1a;随着业务的发展&#xff0c;天际-星舟平台未来需要解决与其他云共创共建&#xff0c;跨团队高效协作等诸多问题&#xff0c;而星舟现有的技术架构将难以支撑。本文将介绍星舟平台如何通过向更先进的“微前端”架构演进落地&#xff0c;以应对将来快速增长的…
阅读更多...
java八皇后问题穷举算法_穷举法和回溯法解n皇后问题

java八皇后问题穷举算法_穷举法和回溯法解n皇后问题

八皇后问题是一个以国际象棋为背景的问题&#xff1a;如何能够在88的国际象棋棋盘上放置八个皇后&#xff0c;使得任何一个皇后都无法直接吃掉其他的皇后&#xff1f;为了达到此目的&#xff0c;任两个皇后都不能处于同一条横行、纵行或斜线上。八皇后问题可以推广为更一般的n皇…
阅读更多...
Microsoft PHP.Net ?

Microsoft PHP.Net ?

居然发现老外有个项目在把PHP搞成象。NET那样咯&#xff0c;核心是Framework 上把 PHP 编译为MSIL。居然见http://www.php-compiler.net/&#xff0c;而且今年居然还FINAL 1.0出来了&#xff0c;这对象把PHP放到.NET平台上来的人说是好消息。20 February 2006: Phalanger versi…
阅读更多...
巧用 Lazy 解决.NET Core中的循环依赖关系

巧用 Lazy 解决.NET Core中的循环依赖关系

原文作者: Thomas Levesque 原文链接&#xff1a;https://thomaslevesque.com/2020/03/18/lazily-resolving-services-to-fix-circular-dependencies-in-net-core/循环依赖的问题在构建应用程序时&#xff0c;良好的设计应该应避免服务之间的循环依赖, 循环依赖是指某些组件直接…
阅读更多...
绝句

绝句

新世纪“绝”句上联:男生&#xff0c;女生&#xff0c;穷书生&#xff0c;生生不息&#xff01; 下联:初恋&#xff0c;热恋&#xff0c;婚外恋&#xff0c;恋恋不舍!横批&#xff1a;生无可恋 上联:博士生&#xff0c;研究生&#xff0c;本科生&#xff0c;生生不息&#xff…
阅读更多...
java的编译器怎么出来_怎样掌握ava编译器的使用，教程在这里，如何进行Java初级学习...

java的编译器怎么出来_怎样掌握ava编译器的使用，教程在这里，如何进行Java初级学习...

原标题&#xff1a;怎样掌握ava编译器的使用&#xff0c;教程在这里&#xff0c;如何进行Java初级学习Java的学习中&#xff0c;并没有那么的繁琐&#xff0c;只需要我们逐步掌握&#xff0c;就能够发觉java是全世界最好的编程语言之一。那么今天就带领大家进行简单的JAVA初级学…
阅读更多...
小试elsa

小试elsa

最近工作需要&#xff0c;在调研BMP产品&#xff08;开源和商用&#xff09;&#xff0c;重点了解了activiti和它的商业产品Alfresco Process Services&#xff0c;这是java的体系&#xff0c;成熟&#xff0c;完善(三方开源库是java多年开源积累下的最宝贵的财富)&#xff0c;…
阅读更多...
如何判断当面的网页加载完成?

如何判断当面的网页加载完成?

if(document.readyStatecomplete){ window.alert(加载完成&#xff01;); } 转载于:https://www.cnblogs.com/MaxIE/archive/2006/03/24/357504.html
阅读更多...
java抠图人物背景图片_如何进行人物抠图？让你快速完成复杂背景人像的在线抠图...

java抠图人物背景图片_如何进行人物抠图？让你快速完成复杂背景人像的在线抠图...

大多数男生心目中都有一个女神&#xff0c;虽然在其他人眼中不过是普通人&#xff0c;但是在自己眼中她怎么看怎么有魅力。当然对于女神提出的各种各样的“要求”或是请求&#xff0c;你们定然是不会轻易拒绝的。但若是女神需要你帮忙抠图&#xff0c;你知道如何进行人物抠图吗…
阅读更多...
如何在 C# 中使用 MSMQ

如何在 C# 中使用 MSMQ

MSMQ 是 Windows 自带的消息队列&#xff0c;它提供了在多机器&#xff0c;多系统之间实现可靠的消息互联&#xff0c;MSMQ 支持可扩展&#xff0c;线程安全&#xff0c;使用简单等强势特性。MSDN 上说&#xff1a;消息队列技术使不同时刻运行的程序可以在异构网络或者异构系统…
阅读更多...
關于招聘新人

關于招聘新人

時間真的是過得很快﹐自2004年接手web團隊﹐一晃都2年多了﹐在這期間﹐目睹了單位上發生的一些事情﹐感受頗多﹐在這里﹐把有關"招收新人員"一些經驗﹐總結如下﹐備以后參考﹕(1) 選一個合適的人 在一個團隊中﹐最忌諱那種"心高氣傲"之人﹐這種人如果…
阅读更多...
卡屏java_Java drawImage到屏幕上一卡一卡的

卡屏java_Java drawImage到屏幕上一卡一卡的

该楼层疑似违规已被系统折叠 隐藏此楼查看此楼public void run() {while(T1.isAlive()true){try {Thread.sleep(FrameRate);} catch (InterruptedException e) {}if(this.NowIndex{this.NowIndex;}else{this.NowIndex0;}}}这是一组图片的线程NowIndex代表这组线程需要读取的那张…
阅读更多...
最新文章

Copyright @ 2022~2023