【愚公系列】2022年03月 ASP.NET Core中间件-条件路由

举报
愚公搬代码 发表于 2022/03/01 10:19:25 2022/03/01
【摘要】 前言 1. 条件路由简介首先我们得了解什么是路由规则?假设有这样一个场景如下图所示:上图中我们可以看到有两个机房分别是机房A、机房B,其中机房A只能访问到 Service A 和 Service B ,而机房B 只能访问到 Service C 和 Service D。要实现上面这种场景我们就需要用到所谓的路由规则。路由规则是在发起一次RPC调用前过滤目标服务器地址,而过滤后的地址列表,将作...

前言

1. 条件路由简介

首先我们得了解什么是路由规则?假设有这样一个场景如下图所示:
在这里插入图片描述

上图中我们可以看到有两个机房分别是机房A、机房B,其中机房A只能访问到 Service A 和 Service B ,而机房B 只能访问到 Service C 和 Service D。要实现上面这种场景我们就需要用到所谓的路由规则。路由规则是在发起一次RPC调用前过滤目标服务器地址,而过滤后的地址列表,将作为消费端最终发起RPC调用的备选地址。在 Dubbo 中支持两种路由规则今天我们主要讨论条件路由。

条件路由:支持以接口服务或消费者应用为粒度配置路由规则。

2.使用场景

1.黑名单: 比如我们需要禁止某些服务消费者消费服务

host = 192.168.53.10,192.168.53.11

上面配置表示禁止192.168.53.10、192.168.53.11消费者访问服务提供者。

2.服务寄宿在应用上,只暴露一部分的机器,防止整个集群挂掉

host = 192.168.53.1*,192.168.53.2*

上面配置表示只能放192.168.53.1*、192.168.53.2 ip 地址开头的服务提供者。

3.读写分离:读取数据和写入数据操作分开

method = find*,list*,get*,is* => host = 192.168.53.10,192.168.53.11,192.168.53.12
method != find*,list*,get*,is* => host = 192.168.20.97,192.168.53.21

上面配置表示以find*,list*,get*,is*方法命名开始的方法只能访问192.168.53.10,192.168.53.11,192.168.53.12服务提供者,而不是find*,list*,get*,is*方法命名开始的方法只能访问192.168.20.97,192.168.53.21服务提供者。

4.提供者与消费者部署在同集群内,本机只访问本机的服务

host = $host

上面配置表示所有消费者只能访问集群内的服务。

二、ASP.NET Core中间件条件路由

普通实现方式

endpoints.MapGet("/test2/{key:alpha}", async context =>
{
    var key = context.Request.RouteValues["key"].ToString();
    foreach (var provider in Configuration.Providers.Reverse())
    {
        if (provider.TryGet(key, out string value))
        {
            await context.Response.WriteAsync(provider.ToString());
            await context.Response.WriteAsync("\r\n");
            await context.Response.WriteAsync(value);
            break;
        }
    }
});

但确定是会在生产环境中暴露它们,要防止暴露可以使用中间件。

1.中间件代码

public class DebugMiddleware : IMiddleware
{
    public async Task InvokeAsync(HttpContext context, RequestDelegate next)
    {
        var isDebugEndpoint = context.Request.Path.Value.Contains("/test");
        var debugKey = context.Request.Query["debugKey"].ToString();
        var debugKeyInConfig = "123456";//来自于配置
        if (isDebugEndpoint && debugKey!=debugKeyInConfig)
        {
            context.SetEndpoint(new Endpoint((context) =>
            {
                context.Response.StatusCode = StatusCodes.Status403Forbidden;
                return Task.CompletedTask;
            },
                        EndpointMetadataCollection.Empty,
                        "无权访问"));
        }

        await next(context);
            
    }
}

2.在管道中的使用

app.UseMiddleware<DebugMiddleware >()
【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。