aspnetcore的中间件

Run会终止中间件继续传递

app.Run(new RequestDelegate(async context =>
{
        await Task.Run(() =>
        {
                context.Response.WriteAsync("被Run截取到了");
         });
}));

app.Run(new RequestDelegate(async context =>
{
        await context.Response.WriteAsync("被Run截取到了");
}));

 Use 会继续传递

app.Use(async (context, next) =>
{
        context.Response.Headers.Add("ResponseAt", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ffff"));
        await next();
});

Map和MapWhen

app.Map("/Test", configuration =>
            {
                configuration.Run(async context =>
                {
                    await context.Response.WriteAsync("Test被截取了");
                });
            });

            app.MapWhen(
                context => context.Request.Path.Value.Contains("Test", StringComparison.CurrentCultureIgnoreCase),
                configuration => configuration.Run(async context =>
                {
                    await context.Response.WriteAsync("带Test的被截取了");
                }));

使用UseMiddleware

public class MyMiddleware
    {
        private readonly RequestDelegate _next;

        private readonly ILogger _logger;

        private readonly string _prefix;

        public MyMiddleware(RequestDelegate next, ILoggerFactory factory, string prefix)
        {
            _next = next;
            _logger = factory.CreateLogger<MyMiddleware>();
            _prefix = prefix;
        }


        public async Task Invoke(HttpContext context)
        {
            _logger.LogInformation("【" + _prefix + "】" + context.Request.Path.Value);
            context.Response.Headers.Add("ResponseAt", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss ffff"));
            await _next(context);
        }
    }

app.UseMiddleware<MyMiddleware>("博客");