我有一个 netcore 3 API 应用程序,它记录传入的请求,然后将其传递给控制器操作.
I have a netcore 3 API application that logs the incoming request and then passes it on to the controller action.
我的代码如下:
public RequestLoggingHandler(IHttpContextAccessor httpContextAccessor) { _httpContextAccessor = httpContextAccessor; } protected override Task HandleRequirementAsync(AuthorizationHandlerContext context, RequestLoggingRequirement requirement) { try { var httpContext = _httpContextAccessor.HttpContext; var request = httpContext.Request; _repository = (ICleanupOrderRepository)httpContext.RequestServices.GetService(typeof(ICleanupOrderRepository)); _cache = (IMemoryCache)httpContext.RequestServices.GetService(typeof(IMemoryCache)); httpContext.Items["requestId"] = SaveRequest(request); context.Succeed(requirement); return Task.CompletedTask; } catch (Exception ex) { throw ex; } } private int SaveRequest(HttpRequest request) { try { // Allows using several time the stream in ASP.Net Core var buffer = new byte[Convert.ToInt32(request.ContentLength)]; request.Body.ReadAsync(buffer, 0, buffer.Length); var requestContent = Encoding.UTF8.GetString(buffer); var requestId = _repository.SaveRawHandlerRequest($"{request.Scheme} {request.Host}{request.Path} {request.QueryString} {requestContent}"); return requestId; } catch (Exception ex) { throw ex; } }但是,当此请求传递给控制器时,请求正文为空.
However when this request is passed on to the Controller the request body is null.
以前在 Core2.x 中你可以这样做
Previously in Core2.x you could do
request.EnableRewind();我的理解是现在替换为
httpContext.Request.EnableBuffering();然而,即使有
httpContext.Request.EnableBuffering();一旦请求正文被读取,请求正文仍然为空.
the request body is still null once the request body is read.
我该如何解决这个问题?
How can I get around this ?
推荐答案这是一个已知的问题 在 github 上.
It is a known issue on github.
临时解决方法是在调用 EnableBuffering 后立即拉出主体,然后将流倒回 0 并且不处理它:
A temp workaround is to pull out the body right after the call to EnableBuffering and then rewinding the stream to 0 and not disposing it:
public class RequestLoggingHandler : AuthorizationHandler<RequestLoggingRequirement> { private readonly IHttpContextAccessor _httpContextAccessor; public RequestLoggingHandler(IHttpContextAccessor httpContextAccessor) { _httpContextAccessor = httpContextAccessor; } protected override Task HandleRequirementAsync(AuthorizationHandlerContext context, RequestLoggingRequirement requirement) { try { var httpContext = _httpContextAccessor.HttpContext; var request = httpContext.Request; request.EnableBuffering(); httpContext.Items["requestId"] = SaveRequest(request); context.Succeed(requirement); return Task.CompletedTask; } catch (Exception ex) { throw ex; } } private int SaveRequest(HttpRequest request) { try { // Allows using several time the stream in ASP.Net Core var buffer = new byte[Convert.ToInt32(request.ContentLength)]; request.Body.ReadAsync(buffer, 0, buffer.Length); var requestContent = Encoding.UTF8.GetString(buffer); var requestId = _repository.SaveRawHandlerRequest($"{request.Scheme} {request.Host}{request.Path} {request.QueryString} {requestContent}"); request.Body.Position = 0;//rewinding the stream to 0 return requestId; } catch (Exception ex) { throw ex; } } }更多推荐
如何在 netcore 3 中多次读取 http 请求正文?
发布评论