一键导入
aspnetcore-middleware-headers
// How to safely set response headers in ASP.NET Core middleware
// How to safely set response headers in ASP.NET Core middleware
| name | aspnetcore-middleware-headers |
| description | How to safely set response headers in ASP.NET Core middleware |
| domain | aspnetcore, middleware, http |
| confidence | high |
| source | earned (bug fix 2026-02-24) |
When writing custom ASP.NET Core middleware that needs to set response headers, the timing of when you set headers matters. Kestrel begins streaming response bodies once the initial buffer (~16KB) is filled, at which point response headers become read-only.
OnStarting callbackSet response headers using the context.Response.OnStarting() callback before calling await next():
app.Use(async (context, next) =>
{
// Register header-setting logic before response starts
context.Response.OnStarting(() =>
{
if (!context.Response.Headers.ContainsKey("X-Custom-Header"))
{
context.Response.Headers["X-Custom-Header"] = "value";
}
return Task.CompletedTask;
});
await next();
});
Why this works: The OnStarting callback is guaranteed to execute before the first byte of the response body is written, regardless of response size or buffering behavior.
HasStarted flagIf you must set headers after next(), check Response.HasStarted first:
app.Use(async (context, next) =>
{
await next();
if (!context.Response.HasStarted && !context.Response.Headers.ContainsKey("X-Custom-Header"))
{
context.Response.Headers["X-Custom-Header"] = "value";
}
});
Caveat: This approach means headers won't be present on responses that started streaming early. Use OnStarting if you need guaranteed header presence.
next() without checkingapp.Use(async (context, next) =>
{
await next();
// ❌ CRASHES if response body > initial buffer size
context.Response.Headers["X-Custom-Header"] = "value";
});
Why this fails:
Response.HasStarted is true and headers are read-onlyInvalidOperationException: Headers are read-only, response has already startedSymptoms:
Real-world example from SquadPlaces (2026-02-24):
Before (broken):
app.Use(async (context, next) =>
{
var blocklist = context.RequestServices.GetRequiredService<IpBlocklistService>();
var ip = context.Connection.RemoteIpAddress?.ToString() ?? "unknown";
if (blocklist.IsBlocked(ip))
{
context.Response.StatusCode = StatusCodes.Status403Forbidden;
await context.Response.WriteAsJsonAsync(new { error = "Blocked" });
return;
}
await next();
// ❌ Crashes on large responses
if (!context.Response.Headers.ContainsKey("X-RateLimit-Limit"))
{
var isWrite = HttpMethods.IsPost(context.Request.Method);
context.Response.Headers["X-RateLimit-Limit"] = isWrite ? "30" : "60";
}
});
After (fixed):
app.Use(async (context, next) =>
{
var blocklist = context.RequestServices.GetRequiredService<IpBlocklistService>();
var ip = context.Connection.RemoteIpAddress?.ToString() ?? "unknown";
if (blocklist.IsBlocked(ip))
{
context.Response.StatusCode = StatusCodes.Status403Forbidden;
await context.Response.WriteAsJsonAsync(new { error = "Blocked" });
return;
}
// ✅ Headers set before response starts
context.Response.OnStarting(() =>
{
if (!context.Response.Headers.ContainsKey("X-RateLimit-Limit"))
{
var isWrite = HttpMethods.IsPost(context.Request.Method);
context.Response.Headers["X-RateLimit-Limit"] = isWrite ? "30" : "60";
}
return Task.CompletedTask;
});
await next();
});