文章目录
- 前言
- 1. 条件路由简介
- 2.使用场景
- 二、ASP.NET Core中间件条件路由
- 1.中间件代码
- 2.在管道中的使用
前言
1. 条件路由简介
首先我们得了解什么是路由规则？假设有这样一个场景如下图所示：
上图中我们可以看到有两个机房分别是机房A、机房B，其中机房A只能访问到 Service A 和 Service B ，而机房B 只能访问到 Service C 和 Service D。要实现上面这种场景我们就需要用到所谓的路由规则。路由规则是在发起一次RPC调用前过滤目标服务器地址，而过滤后的地址列表，将作为消费端最终发起RPC调用的备选地址。在 Dubbo 中支持两种路由规则今天我们主要讨论条件路由。
条件路由：支持以接口服务或消费者应用为粒度配置路由规则。
2.使用场景
1.黑名单： 比如我们需要禁止某些服务消费者消费服务
代码语言：javascript复制host = 192.168.53.10,192.168.53.11上面配置表示禁止192.168.53.10、192.168.53.11消费者访问服务提供者。
2.服务寄宿在应用上，只暴露一部分的机器，防止整个集群挂掉
代码语言：javascript复制host = 192.168.53.1*,192.168.53.2*上面配置表示只能放192.168.53.1*、192.168.53.2 ip 地址开头的服务提供者。
3.读写分离：读取数据和写入数据操作分开
代码语言：javascript复制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.提供者与消费者部署在同集群内，本机只访问本机的服务
代码语言：javascript复制host = $host上面配置表示所有消费者只能访问集群内的服务。
二、ASP.NET Core中间件条件路由
普通实现方式
代码语言：javascript复制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("rn");
await context.Response.WriteAsync(value);
break;
}
}
});但确定是会在生产环境中暴露它们，要防止暴露可以使用中间件。
1.中间件代码
代码语言：javascript复制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.在管道中的使用
代码语言：javascript复制app.UseMiddleware<DebugMiddleware >()
