ASP.NET MVC 随想录（8）——创建自定义的 Middleware 中间件

经过前 2 篇文章的介绍，相信大家已经对 OWIN 和 Katana 有了基本的了解，那么这篇文章我将继续OWIN 和 Katana 之旅——创建自定义的 Middleware 中间件。

何为 Middleware 中间件

Middleware 中间件从功能上可以理解为用来处理 Http 请求，当 Server 将 Http 请求封装成符合 OWIN 规范的字典后，交由 Middleware 去处理，一般情况下， Pipeline 中的 Middleware 以链式的形式处理 Http 请求，即每一个 Middleware 都是最小的模块化，彼此独立、高效。

从语法上理解 Middleware 的话，他是一个应用程序委托（Func<IDictionary<string,object>, Task>）的实例，通过使用 IAppBuilder 接口的 Use 或者 Run 方法将一个 Middleware 插入到 Pipeline 中，不同的是使用 Run 方法不需要引用下一个 Middleware，即他是 Pipeline 中最后的处理元素。

使用 Inline 方式注册 Middleware

使用 Use 方法可以将一个 Middleware 插入到 Pipeline 中，值得注意的是需要传入下一个 Middleware 的引用，代码如下所示：

app.Use(new Func<Func<IDictionary<string, object>, Task>/*Next*/,
 Func<IDictionary<string, object>/*Environment Dictionary*/, Task>>(next => async env =>
 {
     string before = "Middleware1--Before(inline)"+Environment.NewLine;
     string after = "Middleware1--After(inline)"+Environment.NewLine;
     var response = env["owin.ResponseBody"] as Stream;
     await response.WriteAsync(Encoding.UTF8.GetBytes(before), 0, before.Length);
     await next.Invoke(env);
     await response.WriteAsync(Encoding.UTF8.GetBytes(after), 0, after.Length);
 }));

上述代码中，实例化了一个委托，它需要传入下一个 Pipeline 中的 Middleware 引用同时返回一个新的 Middleware 并插入到 Pipeline 中。因为是异步的，所以别忘了 async、await 关键字。

使用 Inline+ AppFunc 方式注册 Middleware

为了简化书写，我为应用程序委托（Func<IDictionary<string,object>, Task>）类型创建了别名 AppFunc：

using AppFunc=Func<IDictionary<string,object>/*Environment Dictionary*/,Task/*Task*/>;

所以又可以使用如下方式来讲 Middleware 添加到 Pipeline 中：

app.Use(new Func<AppFunc, AppFunc>(next => async env =>
{
    string before = "\tMiddleware2--Before(inline+AppFunc)" + Environment.NewLine;

    string after = "\tMiddleware2--After(inline+AppFunc)" + Environment.NewLine;

    var response = env["owin.ResponseBody"] as Stream;

    await response.WriteAsync(Encoding.UTF8.GetBytes(before), 0, before.Length);

    await next.Invoke(env);

    await response.WriteAsync(Encoding.UTF8.GetBytes(after), 0, after.Length);

}));

考虑到业务逻辑的增长，有必要将 Lambda 表达式中的处理逻辑给分离开来，所以对上述代码稍作修改，提取到一个名为 Invoke 的方法内：

app.Use(new Func<AppFunc, AppFunc>(next => env => Invoke(next, env)));
private async Task Invoke(Func<IDictionary<string, object>, Task> next, IDictionary<string, object> env)
{

    var response = env["owin.ResponseBody"] as Stream;

    string pre = "\t\tMiddleware 3 - Before (inline+AppFunc+Invoke)" + Environment.NewLine;

    string post = "\t\tMiddleware 3 - After (inline+AppFunc+Invoke)" + Environment.NewLine;

    await response.WriteAsync(Encoding.UTF8.GetBytes(pre), 0, pre.Length);

    await next.Invoke(env);

    await response.WriteAsync(Encoding.UTF8.GetBytes(post), 0, post.Length);

}

虽然将业务逻辑抽取到一个方法中，但 Inline 这种模式对于复杂的 Middleware 还是显得不够简洁、易懂。我们更倾向于创建一个单独的类来表示。

定义原生 Middleware 类的形式来注册 Middleware

如果你只想简单的跟踪一下请求，使用 Inline 也是可行的，但对于复杂的 Middleware，我倾向于创建一个单独的类，如下所示：

public class RawMiddleware
{
      private readonly AppFunc _next;
      public RawMiddleware(AppFunc next)
      {
        this._next = next;
      }

      public async Task Invoke(IDictionary<string,object> env )
      {
          var response = env["owin.ResponseBody"] as Stream;

          string pre = "\t\t\tMiddleware 4 - Before (RawMiddleware)" + Environment.NewLine;

          string post = "\t\t\tMiddleware 4 - After (RawMiddleware)rn" + Environment.NewLine;

          await response.WriteAsync(Encoding.UTF8.GetBytes(pre), 0, pre.Length);

          await _next.Invoke(env);

          await response.WriteAsync(Encoding.UTF8.GetBytes(post), 0, post.Length);

      }

  }

最后，依旧是通过 Use 方法来将 Middleware 添加到 Pipeline 中：

//两者方式皆可
//app.Use<rawmiddleware>();
app.Use(typeof (RawMiddleware));

上述代码中，IAppBuilder 实例的 Use 方法添加 Middleware 至 Pipeline 与 Inline 方式有很大不同，它接受一个 Type 而非 Lambda 表达式。在这种情形下，创建了一个 Middleware 类型的实例，并将 Pipeline 中下一个 Middleware 传递到构造函数中，最后当 Middleware 被执行时调用 Invoke 方法。

注意 Middleware 是基于约定的形式定义的，需要满足如下条件：

构造函数的第一个参数必须是 Pipeline 中下一个 Middleware

必须包含一个 Invoke 方法，它接收 Owin 环境字典，并返回 Task

使用Katana Helper来注册Middleware

程序集 Microsoft.Owin 包含了 Katana 为我们提供的 Helper，通过他，可以简化我们的开发，比如 IOwinContext 封装了 Owin 的环境字典，强类型对象可以通过属性的形式获取相关数据，同时为 IAppBuilder 提供了丰富的扩展方法来简化 Middleware 的注册，如下所示：

app.Use(async (context, next) =>
   {
   await context.Response.WriteAsync("\t\t\t\tMiddleware 5--Befone(inline+katana helper)"+Environment.NewLine);

   await next();

   await context.Response.WriteAsync("\t\t\t\tMiddleware 5--After(inline+katana helper)"+Environment.NewLine);

   });

当然我们也可以定义一个 Middleware 类并继承 OwinMiddleware，如下所示：

public class MyMiddleware : OwinMiddleware
{
   public MyMiddleware(OwinMiddleware next)
   : base(next)
   {

   }

   public override async Task Invoke(IOwinContext context)
   {
       await context.Response.WriteAsync("tttttMiddleware 6 - Before (Katana helped middleware class)"+Environment.NewLine);

       await this.Next.Invoke(context);

       await context.Response.WriteAsync("tttttMiddleware 6 - After (Katana helped middleware class)"+Environment.NewLine);

   }

  }

然后将其添加到 Pipeline 中：

 app.Use<mymiddleware>();

Middleware 的执行顺序

在完成上面 Middleware 注册之后，在 Configuration 方法的最后添加最后一个的 Middleware 中间件，注意它并不需要对下一个 Middleware 的引用了，我们可以使用 Run 方法来完成注册：

app.Run(context=>context.Response.WriteAsync("\t\t\t\t\t\tHello World"+Environment.NewLine));

值得注意的是，Pipeline 中 Middleware 处理 Http Request 顺序同注册顺序保持一致，即和 Configuration 方法中书写的顺序保持一致，Response 顺序则正好相反，如下图所示：

最后，运行程序，查看具体的输出结果是否和我们分析的保持一致：

小结

在这篇文章中，我为大家讲解了有关自定义 Middleware 的创建的相关知识，Katana 为我们提供了非常多的方式来创建和注册 Middleware，在下一篇文章中，我将继续为大家讲解 OWIN 和 Katana 的其他知识，和大家一起探索 Katana 和其他 Web Framework 的集成。