ASP.NET Core自定义中间件如何读取Request.Body与Response.Body的内容详解

更新时间：2020年05月25日 09:00:37 作者：Lamond Lu

这篇文章主要给大家介绍了关于在ASP.NET Core自定义中间件中如何读取Request.Body与Response.Body的内容，文中通过示例代码介绍的非常详细，对大家学习或者使用ASP.NET Core具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧

背景#

最近在徒手造轮子，编写一个ASP.NET Core的日志监控器，其中用到了自定义中间件读取Request.Body和Response.Body的内容，但是编写过程，并不像想象中的一帆风顺，ASP.NET Core针对Request.Body和Response.Body的几个特殊设计，导致了完成以上功能需要绕一些弯路。

原始代码#

为了读取Request.Body和Response.Body的内容，我的实现思路如下：

创建一个LoggerMiddleware的中间件，将它放置在项目中间件管道的头部。因为根据ASP.NET Core的中间件管道设计，只有第一个中间件才能获取到原始的请求信息和最终的响应信息。

Request.Body和Response.Body属性都是Steram类型，在LoggerMiddleware中间件的InvokeAsync方法中，我们可以分别使用StreamReader读取Request.Body和Response.Body的内容。

根据以上思路，我编写了以下代码。

LoggerMiddleware.cs

	public class LoggerMiddleware
 {
 private readonly RequestDelegate _next;

 public LoggerMiddleware(RequestDelegate next)
 {
  _next = next;
 }

 public async Task InvokeAsync(HttpContext context)
 {
  var requestReader = new StreamReader(context.Request.Body);

 		var requestContent = requestReader.ReadToEnd();
 		Console.WriteLine($"Request Body: {requestContent}");

 		await _next(context);

 		var responseReader = new StreamReader(context.Response.Body);
 		var responseContent = responseReader.ReadToEnd();
 		Console.WriteLine($"Response Body: {responseContent}");
 }
 }

Startup.cs

 public void Configure(IApplicationBuilder app, IHostingEnvironment env)
 {
 if (env.IsDevelopment())
 {
  app.UseMiddleware<LoggerMiddleware>();
  app.UseDeveloperExceptionPage();
 }
 else
 {
  app.UseHsts();
 }

 app.UseHttpsRedirection();
 app.UseMvc();
 }

问题1：Response.Body的Stream不可读#

这里为了测试我创建了一个默认的ASP.NET Core WebApi项目。当运行程序，使用GET方式调用/api/values之后，控制台会返回第一个需要处理的错误。

System.ArgumentException: Stream was not readable.

即ASP.NET Core默认创建的Response.Body属性是不可读的。

这一点我们可以通过打断点看到Response.Body属性的CanRead值是false。

这就很糟糕了，ASP.NET Core默认并不想让我们在中间件中直接读取Response.Body中的信息。

这里看似的无解，但是我们可以转换一下思路，既然ASP.NET Core默认将Response.Body是不可读的，那么我们就使用一个可读可写的Stream对象将其替换掉。这样当所有中间件都依次执行完之后，我们就可以读取Response.Body的内容了。

public async Task InvokeAsync(HttpContext context)
{
	 var requestReader = new StreamReader(context.Request.Body);

 var requestContent = requestReader.ReadToEnd();
 Console.WriteLine($"Request Body: {requestContent}");

 using (var ms = new MemoryStream())
 {
  context.Response.Body = ms;
  await _next(context);

  context.Response.Body.Position = 0;

  var responseReader = new StreamReader(context.Response.Body);

  var responseContent = responseReader.ReadToEnd();
  Console.WriteLine($"Response Body: {responseContent}");

  context.Response.Body.Position = 0;
 }
}

注意：

读取Response.Body的时候，需要设置Position = 0, 这样是为了重置指针，如果不这样做的话，会导致读取的流不正确。
这里千万不要用using包裹StreamReader, 因为StreamReader会在读取完Stream内容之后，将Stream关闭，导致后续由于Stream关闭，而不能再次读取Stream中的内容。如果必须使用，请使用StreamReader的以下重载，将leaveOpen参数设置为true, 确保StreamReader对象被销毁的时候不会自动关闭读取的Stream.

public StreamReader(Stream stream, Encoding encoding, bool detectEncodingFromByteOrderMarks, int bufferSize, bool leaveOpen);

重新启动程序，请求/api/values, 我们就得到的正确的结果。

进一步完善代码#

以上代码实现，看似已经能够读取Response.Body的内容了，但是其实还是有问题的。

回想一下，我们做出以上方案的前提是，当前LoggerMiddleware中间件必须位于中间件管道的头部。

如果不能保证这个约定, 就会出现问题，因为我们在LoggerMiddleware中间件中将Response.Body属性指向了一个新的可读可写的Stream对象。如果LoggerMiddleware中间件之前的某个中间件中设置过Response.Body, 就会导致这部分设置丢失。

因此正确的设置方式应该是这样的：

 public async Task InvokeAsync(HttpContext context)
 {
 var originalResponseStream = context.Response.Body;

 var requestReader = new StreamReader(context.Request.Body);
 
 var requestContent = requestReader.ReadToEnd();
 Console.WriteLine($"Request Body: {requestContent}");
 

 using (var ms = new MemoryStream())
 {
  context.Response.Body = ms;
  await _next(context);


  ms.Position = 0;
  var responseReader = new StreamReader(ms);

  var responseContent = responseReader.ReadToEnd();
  Console.WriteLine($"Response Body: {responseContent}");

  ms.Position = 0;

  await ms.CopyToAsync(originalResponseStream);
  context.Response.Body = originalResponseStream;
 }
 }

代码解释：

这里当进入LoggerMiddleware中间件时，我们将之前中间件操作完成之后的Response.Body对象对应的原始Stream, 保存在一个临时变量中
当LoggerMiddelware中间件的任务完成之后，我们需要将后续产生的Response.Body流追加到原始Stream中，然后将Response.Body对象重置为这个新的Stream。

至此Repsonse.Body的问题都解决，下面我们再来看一下Request.Body的问题。

问题2：Request.Body的内容可以正确的显示，但是后续的ModelBinding都失败了#

下面我们来请求POST /api/values, Request.Body里面的内容是字符串"123123"

服务器端返回了400错误，错误信息

A non-empty request body is required.

这里就很奇怪，为啥请求体是空呢？我们回到中间件部分代码，这里我们在读取完Request.Body中的Stream之后，没有将Stream的指针重置，当前指针已经是Stream的尾部，所以后续ModelBinding的时候，读取不到Stream的内容了。

 public async Task InvokeAsync(HttpContext context)
 {
 ...
 var requestReader = new StreamReader(context.Request.Body);
 
 var requestContent = requestReader.ReadToEnd();
 Console.WriteLine($"Request Body: {requestContent}");
 ...
 }

于是，这里我们需要采取和Response.Body相同的处理方式，在读取完Request.Body之后，我们需要将Request.Body的Stream指针重置

 public async Task InvokeAsync(HttpContext context)
 {
 ...
 var requestReader = new StreamReader(context.Request.Body);
 
 var requestContent = requestReader.ReadToEnd();
 Console.WriteLine($"Request Body: {requestContent}");
 context.Request.Body.Position = 0;
 ...
 }

你一定觉着至此问题就解决了，不过ASP.NET Core和你又开了一个玩笑。

当你重新请求POST /api/values之后，你会得到以下结果。

错误原因：

System.NotSupportedException: Specified method is not supported.

翻译过来就是指定方法不支持。到底不支持啥呢？在代码上打上断点，你会发现Request.Body的CanSeek属性是false, 即Request.Body的Stream, 你是不能随便移动指针的，只能按顺序读取一次，默认不支持反复读取。

那么如何解决这个问题呢？

你可以在使用Request对象中的EnableRewind或者EnableBuffering。这2个方法的作用都是在内存中创建缓冲区存放Request.Body的内容，从而允许反复读取Request.Body的Stream。

说明：其实EnableBuffering方法内部就只直接调用的EnableRewind方法。

下面我们修改代码

 public async Task InvokeAsync(HttpContext context)
 {
 context.Request.EnableBuffering();
 var requestReader = new StreamReader(context.Request.Body);

 var requestContent = requestReader.ReadToEnd();
 Console.WriteLine($"Request Body: {requestContent}");
 context.Request.Body.Position = 0;


 using (var ms = new MemoryStream())
 {
  context.Response.Body = ms;
  await _next(context);


  ms.Position = 0;
  var responseReader = new StreamReader(ms);

  var responseContent = responseReader.ReadToEnd();
  Console.WriteLine($"Response Body: {responseContent}");

  ms.Position = 0;
 }
 }

再次请求POST /api/values, api请求被正确的处理了。

源代码： https://github.com/lamondlu/webapi-logger

总结

到此这篇关于ASP.NET Core自定义中间件中如何读取Request.Body与Response.Body的内容的文章就介绍到这了,更多相关ASP.NET Core自定义中间件读取Request.Body与Response.Body内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

ASP.NET的实用技巧详细介绍
本文介绍的是ASP.NET的实用技巧，从跟踪页面，表单数据的服务器端验证和跳过表单验证等方面为大家介绍的。希望对你有帮助，一起来看。
2015-10-10
浅谈AjaxPro.dll,asp.net 前台js调用后台方法
这篇文章主要介绍了浅谈AjaxPro.dll,asp.net 前台js调用后台方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-07-07
聊聊.Net,Core配置Nlog.md的问题
这篇文章主要介绍了.Net Coer配置Nlog.md的相关知识，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2022-03-03
asp.net core 实现一个简单的仓储的方法
本篇文章主要介绍了asp.net core 实现一个简单的仓储的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-12-12
asp.net 读取并显示excel数据的实现代码
Microsoft Office Excel是一个很好的电子表格应用程序，在本文中，it同学会将教给你看到如何使用ASP.NET从Excel电子表格读取并显示显示数据。
2010-02-02
asp.net Gridview行绑定事件新体会
最近在做统计GridView中某一列的加总值，之前有在RowDataBound事件中中逐笔加总，经过测试才知道，这是不正确的，并不能得到所有资料的加总值。
2009-11-11
aspx与ascx,ashx的用法总结
这篇文章主要是对aspx与ascx,ashx的用法进行了详细的总结介绍，需要的朋友可以过来参考下，希望对大家有所帮助
2013-12-12
asp.net关于Cookie跨域（域名）的问题
Cookie是一个伟大的发明，它允许Web开发者保留他们的用户的登录状态。但是当你的站点有一个以上的域名时就会出现问题了。在Cookie规范上说，一个cookie只能用于一个域名，不能够发给其它的域名。因此，如果在浏览器中对一个域名设置了一个cookie，这个cookie对于其它的域名将无效。如果你想让你的用户从你的站点中的其中一个进行登录，同时也可以在其它域名上进行登录，这可真是一个大难题。
2012-12-12
Grid或者DataTable中数据导出为Excel原来这么简单
以前一直认为，将Grid 或者DataTable中的数据导出到Excel功能实现会非常复杂，可能会想用什么类库什么的或者实在太难就用csv算了,没想到真的很简单，需要了解的朋友可以参考下
2012-12-12
无法将类型为“System.Web.UI.WebControls.HiddenField”的对象强制转换为类型的错误的解
无法将类型为“System.Web.UI.WebControls.HiddenField”的对象强制转换为类型的错误的解决方法
2011-12-12

ASP.NET Core自定义中间件如何读取Request.Body与Response.Body的内容详解

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具