'# ASP.NET Core中创建中间件的几种方式
一、背景与问题
在ASP.NET Core应用中，中间件（Middleware）是处理HTTP请求的核心机制。它通过构建管道（Pipeline）将请求分发到各个处理节点，支持身份验证、日志记录、异常处理等核心功能。然而，开发者在实际开发中常遇到以下问题：
- 中间件调用顺序错误：例如将日志中间件放在身份验证中间件之后，导致无法记录未授权请求的详细信息。
- 性能瓶颈：某些中间件在处理请求时引入不必要的计算开销。
- 安全风险：未正确配置中间件可能导致敏感信息泄露或跨站攻击（XSS）。
- 可维护性问题：不同团队对中间件的实现方式差异大，导致代码难以统一管理。
本文将深入剖析ASP.NET Core中间件的实现原理，结合实际开发场景，对比三种主流创建方式，并提供完整的代码示例和性能优化方案。
二、基本原理
ASP.NET Core的中间件通过IApplicationBuilder接口构建管道。每个中间件本质上是一个Func<RequestDelegate, RequestDelegate>的委托函数，其核心逻辑如下：
public delegate RequestDelegate RequestDelegate(HttpContext context);中间件的执行流程遵循以下规则：
- 每个中间件接收一个
RequestDelegate参数（即下一个中间件的处理函数）。 - 当调用
next()时，控制权传递给下一个中间件。 - 中间件可对当前请求进行处理（如日志记录、修改响应头等），再调用
next()继续执行。
这种链式调用机制使得中间件可以灵活地控制请求的处理流程，同时支持条件执行（如仅在特定路径时触发）。
三、环境准备
确保开发环境满足以下条件：
- .NET SDK 6.0及以上版本
- Visual Studio或Visual Studio Code
- 项目结构如下（可选）：
MyApp/
├── Controllers/
├── Services/
├── Middlewares/
│ ├── LoggingMiddleware.cs
│ ├── AuthMiddleware.cs
│ └── ErrorMiddleware.cs
├── Startup.cs
└── Program.cs四、核心实现
方式一：通过Use方法注册中间件（推荐）
这是最常见的方式，适用于简单逻辑的中间件。核心代码如下：
// Startup.cs
public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
{
if (env.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
app.Use(async (context, next) =>
{
// 记录请求信息
Console.WriteLine($"Request: {context.Request.Method} {context.Request.Path}");
// 调用下一个中间件
await next();
});
app.UseRouting();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllers();
});
}关键点解释：
Use方法注册的中间件会自动加入管道末尾。- 每个中间件的
next()调用必须显式执行，否则请求将被阻断。
方式二：通过自定义中间件类（灵活控制）
适用于需要复杂逻辑或依赖注入的场景。代码示例：
// Middlewares/LoggingMiddleware.cs
public class LoggingMiddleware
{
private readonly RequestDelegate _next;
private readonly ILogger<LoggingMiddleware> _logger;
public LoggingMiddleware(RequestDelegate next, ILogger<LoggingMiddleware> logger)
{
_next = next;
_logger = logger;
}
public async Task InvokeAsync(HttpContext context)
{
_logger.LogInformation($"Request: {context.Request.Method} {context.Request.Path}");
await _next(context);
}
}注册方式：
// Startup.cs
services.AddLogging();
public void Configure(IApplicationBuilder app)
{
app.UseMiddleware<LoggingMiddleware>();
}关键点解释：
- 中间件类必须包含
InvokeAsync方法，且接受HttpContext参数。 - 通过依赖注入可注入日志、配置等服务。
方式三：通过AddXxx方法注册内置中间件
ASP.NET Core内置了大量中间件（如身份验证、CORS），其注册方式与自定义中间件类似：
// Startup.cs
services.AddAuthentication(JwtBearerDefaults.AuthenticationScheme)
.AddJwtBearer(options =>
{
options.TokenValidationParameters = new TokenValidationParameters
{
ValidateIssuer = true,
ValidateAudience = true,
ValidateLifetime = true,
ValidateIssuerSigningKey = true,
ClockSkew = TimeSpan.FromMinutes(5),
IssuerSigningKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes("YourSecretKeyHere"))
};
});
public void Configure(IApplicationBuilder app)
{
app.UseAuthentication();
app.UseAuthorization();
}关键点解释：
- 内置中间件通常需要先通过
AddXxx方法注册服务，再通过Use方法调用。 - 配置项通过
options参数传递，支持链式调用。
五、完整案例
案例：构建一个带有日志、身份验证和错误处理的Web API
1. 项目结构
MyApp/
├── Controllers/
│ └── ValuesController.cs
├── Middlewares/
│ ├── LoggingMiddleware.cs
│ ├── AuthMiddleware.cs
│ └── ErrorMiddleware.cs
├── Startup.cs
└── Program.cs2. 日志中间件实现
// Middlewares/LoggingMiddleware.cs
public class LoggingMiddleware
{
private readonly RequestDelegate _next;
private readonly ILogger<LoggingMiddleware> _logger;
public LoggingMiddleware(RequestDelegate next, ILogger<LoggingMiddleware> logger)
{
_next = next;
_logger = logger;
}
public async Task InvokeAsync(HttpContext context)
{
_logger.LogInformation($"[Logging] {context.Request.Method} {context.Request.Path}");
await _next(context);
}
}3. 身份验证中间件实现
// Middlewares/AuthMiddleware.cs
public class AuthMiddleware
{
private readonly RequestDelegate _next;
private readonly IAuthenticationService _authService;
public AuthMiddleware(RequestDelegate next, IAuthenticationService authService)
{
_next = next;
_authService = authService;
}
public async Task InvokeAsync(HttpContext context)
{
var token = context.Request.Headers["Authorization"].ToString().Replace("Bearer ", "");
if (!_authService.ValidateToken(token))
{
context.Response.StatusCode = 401;
await context.Response.WriteAsync("Unauthorized");
return;
}
await _next(context);
}
}4. 错误处理中间件实现
// Middlewares/ErrorMiddleware.cs
public class ErrorMiddleware
{
private readonly RequestDelegate _next;
private readonly ILogger<ErrorMiddleware> _logger;
public ErrorMiddleware(RequestDelegate next, ILogger<ErrorMiddleware> logger)
{
_next = next;
_logger = logger;
}
public async Task InvokeAsync(HttpContext context)
{
try
{
await _next(context);
}
catch (Exception ex)
{
_logger.LogError(ex, "An error occurred.");
context.Response.StatusCode = 500;
await context.Response.WriteAsync("Internal Server Error");
}
}
}5. 服务注册
// Startup.cs
public void ConfigureServices(IServiceCollection services)
{
services.AddControllers();
services.AddLogging();
services.AddSingleton<IAuthenticationService, AuthenticationService>();
}6. 中间件注册
// Startup.cs
public void Configure(IApplicationBuilder app)
{
app.UseMiddleware<LoggingMiddleware>();
app.UseMiddleware<AuthMiddleware>();
app.UseMiddleware<ErrorMiddleware>();
app.UseRouting();
app.UseEndpoints(endpoints =>
{
endpoints.MapControllers();
});
}7. 控制器示例
// Controllers/ValuesController.cs
[ApiController]
[Route("[controller]")]
public class ValuesController : ControllerBase
{
[HttpGet]
public IActionResult Get()
{
return Ok(new { message = "Hello from ASP.NET Core!" });
}
}8. 运行测试
启动应用后，访问https://localhost:5001/values，需在请求头中添加Authorization: Bearer <valid_token>，否则会返回401错误。
六、源码解析
以UseMiddleware<T>方法为例，其底层实现如下：
public static IApplicationBuilder UseMiddleware<TMiddleware>(this IApplicationBuilder app) where TMiddleware : IMiddleware, new()
{
var middleware = new TMiddleware();
return app.UseMiddleware(middleware);
}其中IMiddleware接口定义为：
public interface IMiddleware
{
Task Invoke(HttpContext context);
}通过这种方式，ASP.NET Core将自定义中间件实例化并加入管道。
七、进阶使用
1. 条件执行中间件
通过检查请求路径或头信息来决定是否执行中间件：
app.Use(async (context, next) =>
{
if (context.Request.Path == "/secure")
{
await next();
}
else
{
await context.Response.WriteAsync("Not secure");
}
});2. 中间件管道的动态控制
通过IApplicationBuilder的Use方法实现动态管道：
var app = new ApplicationBuilder();
app.UseMiddleware<LoggingMiddleware>();
app.UseMiddleware<AuthMiddleware>();
app.UseMiddleware<ErrorMiddleware>();3. 中间件的依赖注入
在中间件类中注入服务时，需在Startup.cs中注册服务：
services.AddTransient<ILoggingService, LoggingService>();八、性能与工程实践
1. 性能优化策略
- 避免不必要的中间件：仅在必要时注册中间件，例如开发环境下的调试中间件应通过
env.IsDevelopment()条件控制。 - 按顺序优化：将最常访问的资源处理逻辑放在管道前面，减少不必要的处理。
- 异步处理：确保中间件使用
async/await避免阻塞主线程。
2. 异常处理安全
- 防止信息泄露：在
ErrorMiddleware中统一返回标准错误信息，避免暴露堆栈跟踪。 - 日志安全：记录日志时过滤敏感信息（如用户输入），使用
ILogger的LogCritical方法。
3. 配置管理
- 使用配置文件：通过
appsettings.json存储中间件的配置项，例如日志级别或令牌验证参数。 - 环境变量：通过
Environment.GetEnvironmentVariable读取不同环境的配置。
九、常见问题与踩坑
1. 中间件顺序错误
错误示例：
app.UseMiddleware<AuthMiddleware>(); // 错误：身份验证在日志中间件之前
app.UseMiddleware<LoggingMiddleware>();后果：未授权请求会被直接拒绝，无法记录日志。
解决方案：将日志中间件放在身份验证之前。
2. 未处理异常
错误示例：
app.Use(async (context, next) =>
{
await next(); // 忘记处理异常
});后果：未处理的异常会导致应用崩溃。
解决方案：使用try/catch块包裹await next()调用。
3. 依赖注入失效
错误示例：
public class LoggingMiddleware
{
private readonly ILogger<LoggingMiddleware> _logger;
public LoggingMiddleware(ILogger<LoggingMiddleware> logger)
{
_logger = logger;
}
}后果：如果未在Startup.cs中注册日志服务，logger会为null。
解决方案：确保services.AddLogging()已调用。
十、最佳实践
- 按功能分类中间件：将日志、验证、错误处理等逻辑分开展示，提高可维护性。
- 使用条件注册：通过
env.IsDevelopment()控制调试中间件的启用。 - 统一错误处理：通过
ErrorMiddleware集中处理所有异常，避免分散在各个中间件中。 - 避免过度依赖注入：仅在需要时注入服务，减少依赖项复杂度。
- 使用内置中间件：优先使用内置的
UseAuthentication、UseCors等中间件，避免重复造轮子。
十一、总结
ASP.NET Core中间件是构建高性能Web应用的核心机制。通过三种主要实现方式（Use、自定义类、内置中间件），开发者可以灵活控制请求处理流程。实际开发中需注意：
- 中间件顺序对功能的影响
- 异常处理和日志安全
- 依赖注入的正确配置
在性能优化方面，应避免不必要的处理和阻塞操作，同时合理利用异步编程。安全方面需严格控制敏感信息泄露，统一处理异常。通过合理选择中间件创建方式，可以显著提升应用的可维护性和稳定性。