以编程方式调用 ASP.NET 核心请求管道

Programmatically invoking the ASP.NET Core request pipeline

问题

如果我有一个 HTTP 动词、路由、headers 和 body 负载,是否有办法从我自己的应用程序中以编程方式调用 ASP.NET 核心请求管道?

背景

use-cases ASP.NET 核心应用程序的 WebAPI 无法访问,因为该应用程序 运行 在防火墙后面或无法访问。

为了为这种情况提供解决方案,我们希望我们的应用程序为 "work-items" 轮询一些其他服务,然后在我们的应用程序中转换为 API 调用。

我考虑过的方法

所以我确信必须有一种更清晰、更直接的方法来从我自己的应用程序中以编程方式调用请求管道...

是的,这实际上相当容易。您可以在 Startup class Configure 方法的末尾获得对请求管道的引用。保存在静态字段/单例服务/等

public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
  // ... usual configuration code

  AClass.PipelineStaticField = app.Build();
}

然后,在您希望注入请求的方法中,您必须构建一个 HttpContext 以传递到管道中。

var ctx = new DefaultHttpContext();

// setup a DI scope for scoped services in your controllers etc.
using var scope = _provider.CreateScope();
ctx.RequestServices = scope.ServiceProvider;

// prepare the request as needed
ctx.Request.Body = new MemoryStream(...);
ctx.Request.ContentType = "application/json";
ctx.Request.ContentLength = 1234;
ctx.Request.Method = "POST";
ctx.Request.Path = PathString.FromUriComponent("/mycontroller/action");

// you only need this if you are hosting in IIS (.UseIISIntegration())
ctx.Request.Headers["MS-ASPNETCORE-TOKEN"] = Environment.GetEnvironmentVariable("ASPNETCORE_TOKEN");

// setup a place to hold the response body
ctx.Response.Body = new MemoryStream();

// execute the request
await AClass.PipelineStaticField(ctx);

// interpret the result as needed, e.g. parse the body
ctx.Response.Body.Seek(0, SeekOrigin.Begin);
using var reader = new StreamReader(ctx.Response.Body);
string body = await reader.ReadToEndAsync();

这样您的请求将遍历整个管道,包括所有中间件,例如身份验证和授权。