asp.net core mvc 管道之中间件

• http请求处理管道通过注册中间件来实现各种功能，松耦合并且很灵活
• 此文简单介绍asp.net core mvc中间件的注册以及运行过程
• 通过理解中间件，将asp.net core mvc分解，以便更好地学习

中间件写法

• 先看一个简单的中间件，next是下一个委托方法，在本中间件的Invoke方法里面需要执行它，否则处理就会终止，消息处理到此中间件就会返回了
• 因此，根据这个约定，一个中间生成一个委托方法，需要把所有的委托方法处理成嵌套的委托，即每个中间件里面执行下一个委托，这样处理过程就像管道一样连接起来，每个中间件就是管道处理的节点
• 至于为什么要这样写中间件，这是约定好的，还有注意点，下面将会讲到

    public class Middleware
    {
 private readonly RequestDelegate _next;

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

 public async Task Invoke(HttpContext httpContext)
 {
     // do something
     await _next.Invoke(httpContext);
     // do something
 }
    }

中间件管道生成

• 以上中间件会通过方法生成一个委托，并添加到委托集合，中间生成委托的过程后面讲

namespace Microsoft.AspNetCore.Builder.Internal
{
    public class ApplicationBuilder : IApplicationBuilder
    {
 private readonly IList> _components = new List>();
 public IApplicationBuilder Use(Func middleware)
 {
     _components.Add(middleware);
     return this;
 }
    }
}

• 最后的ApplicationBuilder.Build方法会处理所有注册的中间件生成的委托集合，将所有中间件生成的委托集合，处理成嵌套的形式，最终得到一个委托，连成一段管道。
• 以下方法首先声明一个响应404的委托方法，把它当成所有中间件的最后一个，当然它不一定会被执行到，因为某个中间件可能不会调用它
• 然后将这个委托作为参数，传入并执行_components这个委托集合里面的每一个委托，_components就是所有注册的中间件生成的委托集合，Reverse方法将集合反转，从最后注册的中间件对应的委托开始处理
• 所以呢中间件的注册是有顺序的，也就是Startup.cs类里面的Configure方法，里面的每个Use开头的方法都对应一个中间件注册，代码的顺序就是注册的顺序，也是执行的顺序，千万不能写错了。因为MVC处于处理流程的最后面，因此UseMvc方法总是位于最后
• 在看component，是从_components委托集合里面取出来的，执行后又得到一个RequestDelegate类型的委托，因此由中间件生成的委托的类型应该是Func

 public RequestDelegate Build()
 {
     RequestDelegate app = context =>
     {
  context.Response.StatusCode = 404;
  return Task.CompletedTask;
     };

     foreach (var component in _components.Reverse())
     {
  app = component(app);
     }

     return app;
 }

中间件生成委托

• 以下是中间件注册方法，实际是调用ApplicationBuilder.Use方法，将中间件生成的委托加入委托集合，完成中间件注册
• app.Use方法参数，就是上面需要的类型Func的委托，该委托的参数next就是下一个中间件对应的委托，返回值就是中间件的Invoke方法对应的委托，该方法用到了next
• 源码位于Microsoft.AspNetCore.Builder.UseMiddlewareExtensions这个类

 public static IApplicationBuilder UseMiddleware(this IApplicationBuilder app, params object[] args)
 {
     return app.UseMiddleware(typeof(TMiddleware), args);
 }

 public static IApplicationBuilder UseMiddleware(this IApplicationBuilder app, Type middleware, params object[] args)
 {

     // 省略部分代码

     var applicationServices = app.ApplicationServices;
     return app.Use(next =>
     {      

  // 省略部分代码

  var ctorArgs = new object[args.Length + 1];
  ctorArgs[0] = next;
  Array.Copy(args, 0, ctorArgs, 1, args.Length);
  var instance = ActivatorUtilities.CreateInstance(app.ApplicationServices, middleware, ctorArgs);
  if (parameters.Length == 1)
  {
      return (RequestDelegate)methodinfo.CreateDelegate(typeof(RequestDelegate), instance);
  }

  var factory = Compile