.Net Core 3.1之管道中間件

 

 

Request請求進來，Middleware1=》Middleware2=》Middleware3，Response返回Middleware3=》Middleware2=》Middleware1

何為中間件？

public class Middleware
{
　　private readonly RequestDelegate _next;

　　public Middleware(RequestDelegate next)
　　{
　　　　_next = next;
　　}

　　public Task Invoke(HttpContext httpContext)
　　{

　　　　return _next(httpContext);
　　}
}

public delegate Task RequestDelegate(HttpContext context);

構造函數中接受一個RequestDelegate參數，invoke方法中接受HttpCointext參數。簡而言之就是Func<RequestDelegate,RequestDelegate>

中間件如何串聯？

查看源碼！

IApplicationBuilder.Use方法其實就是在往components里添加中間件。

public IApplicationBuilder Use(Func<RequestDelegate, RequestDelegate> middleware)
{
　　_components.Add(middleware);
　　return this;
}

 IApplicationBuilder.Build方法，先將compoments集合反轉循環遍歷，把結果作為參數再傳給下一個中間件。

public RequestDelegate Build()
{
　　RequestDelegate app = context =>
　　{
　　　　// If we reach the end of the pipeline, but we have an endpoint, then something unexpected has happened.
　　　　// This could happen if user code sets an endpoint, but they forgot to add the UseEndpoint middleware.
　　　　var endpoint = context.GetEndpoint();
　　　　var endpointRequestDelegate = endpoint?.RequestDelegate;
　　　　if (endpointRequestDelegate != null)
　　　　{
　　　　　　var message =
　　　　　　$"The request reached the end of the pipeline without executing the endpoint: '{endpoint.DisplayName}'. " +
　　　　　　$"Please register the EndpointMiddleware using '{nameof(IApplicationBuilder)}.UseEndpoints(...)' if using " +
　　　　　　$"routing.";
　　　　　　throw new InvalidOperationException(message);
　　　　}

　　　　context.Response.StatusCode = 404;
　　　　return Task.CompletedTask;
　　};

22 foreach (var component in _components.Reverse())
23 　　{
24 　　　　app = component(app);
25 　　}

　　return app;
}

 

 

 

app.Use(next => {
　　Console.WriteLine("step 1");
　　return async c =>
　　{
　　　　await c.Response.WriteAsync("step 1 start");
　　　　await next.Invoke(c);
　　　　await c.Response.WriteAsync("step 1 end");
　　};
});

app.Use(next => {
　　Console.WriteLine("step 2");
　　return async c =>
　　{
　　　　await c.Response.WriteAsync("step 2 start");
　　　　await next.Invoke(c);
　　　　await c.Response.WriteAsync("step 2 end");
　　};
});

app.Use(next => {
　　Console.WriteLine("step 3");
return async c =>
{
　　await c.Response.WriteAsync("step 3 start");
　　// await next.Invoke(c);
　　await c.Response.WriteAsync("step 3 end");
};
});

 

 

結果：

在控制台輸出step 3，step 2，step 1       因為有Resverse，合理！

頁面輸出 step1 start   step 2 start  step 3 start step 3 end step 2 end step 1 end   對應管道模型