聊聊 ASP.NET Core 中间件（三）：如何创建自己的中间件？-Step By Step 步骤

1. 创建一个空 ASP.NET Core webapi 项目

2. 定义一个用于中间件的实体类

   public class CheckAndParsingMiddlewareModel
   {
   	public int i { get; set; }
   	public int j { get; set; }
   }
   

3. 定义一个中间件类 CheckAndParsingMiddleware，留意注释

   using System.Text.Json;
   using System.Text;
   
   /// <summary>
   /// 自定义中间类，要求如注释的 1~5 点
   /// </summary>
   public class CheckAndParsingMiddleware
   {
   	private readonly RequestDelegate next;
   
   	// 1. 需要有一个构造方法
   	// 2. 构造方法需要有一个 RequestDelegate 类型的参数，用于指向下一个中间件
   	public CheckAndParsingMiddleware(RequestDelegate next)
   	{
   		this.next = next;
   	}
   
   	// 3. 需要有一个名为 Invoke 或 InvokeAsync 的方法
   	// 4. 此方法至少要有一个 HttpContext 类型参数
   	// 5. 此方法的返回值必须是 Task 类型
   	public async Task InvokeAsync(HttpContext context)
   	{
   		string pwd = context.Request.Query["password"];
   		if (pwd == "123")
   		{
   			if (context.Request.HasJsonContentType())
   			{
   				// 解析 Body 参数的值
   				var reqStream = context.Request.BodyReader.AsStream();
   				var jsonObj = JsonSerializer.Deserialize<CheckAndParsingMiddlewareModel>(reqStream);
   
   				// 将数据存在Items中
   				// HttpContext.Items 在同一个请求中是共享的，可以用它在多个中间件之间来传递数据
   				context.Items["BodyJson"] = jsonObj; 
   			}
   			// 把请求转给下一个中间件
   			await next(context); 
   		}
   		else
   		{
   			context.Response.StatusCode = 401;
   		}
   	}
   }
   

4. 打开 Program.cs，编写使用自定义的中间件的代码，如：

   var builder = WebApplication.CreateBuilder(args);
   var app = builder.Build();
   
   app.Map("/testForCustomMiddleware", async appbuild => { 
   	// 使用自定义的中间件
   	appbuild.UseMiddleware<CheckAndParsingMiddleware>();
   	
   	// 执行
   	appbuild.Run(async ctx => {
   		ctx.Response.ContentType = "text/html";
   		ctx.Response.StatusCode = 200;
   		var jsonObj = (CheckAndParsingMiddlewareModel)ctx.Items["BodyJson"];
   		int i = jsonObj.i;
   		int j = jsonObj.j;
   		await ctx.Response.WriteAsync($"{i}+{j}={i+j}");
   	});
   });
   
   app.Run();
   

5. 其它：解析 Body 参数值的方法

   // 方法 1
   var reqStream = context.Request.BodyReader.AsStream();
   var jsonObj = JsonSerializer.Deserialize<CheckAndParsingMiddlewareModel>(reqStream);
   
   // 方法 2
   Stream reqStream = context.Request.Body;
   byte[] buffer = new byte[context.Request.ContentLength!.Value];
   await reqStream.ReadAsync(buffer, 0, buffer.Length);
   var reqStr = Encoding.UTF8.GetString(buffer);
   dynamic jsonObj = JsonSerializer.Deserialize<dynamic>(reqStr)!;