src/Library/NetPro.ShareRequestData/ShareRequestBodyMiddleware.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.Logging;
using System;
using System.Threading.Tasks;

namespace NetPro.ShareRequestBody
{
    /// <summary>
    /// 
    /// </summary>
    public class ShareRequestBodyMiddleware
    {
        private readonly ILogger _logger;
        private readonly RequestDelegate _next;

        /// <summary>
        /// 
        /// </summary>
        /// <param name="next"></param>
        /// <param name="logger"></param>
        public ShareRequestBodyMiddleware(RequestDelegate next
            , ILogger<ShareRequestBodyMiddleware> logger)
        {
            _next = next;
            _logger = logger;
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="context"></param>
        /// <param name="requestCacheData"></param>
        /// <returns></returns>
        /// <remarks>错误： OnStarting cannot be set because the response has already started.</remarks>
        public async Task InvokeAsync(HttpContext context, RequestCacheData requestCacheData)
        {
            context.Request.EnableBuffering();
            var token = context.RequestAborted.Register(async () =>
            {
                await Task.CompletedTask;
                return;
            });

            if (context.Request.ContentType?.Contains("multipart/form-data") ?? false || context.Request.Method.Equals("get", StringComparison.OrdinalIgnoreCase) || context.Request.Method.Equals("head", StringComparison.OrdinalIgnoreCase))
            {
                await _next(context);
            }
            else
            {
                string bodyValue;
                bodyValue = await Common.ReadAsString(context);
                if (requestCacheData == null)
                {
                    requestCacheData = new RequestCacheData { Body = bodyValue };
                }
                else if (string.IsNullOrEmpty(requestCacheData.Body))
                {
                    requestCacheData.Body = bodyValue;
                    await _next(context);