eNableRewind和StreamReader上的离开并没有阻止请求被处置

Question

我正在使用applicationInsights，我想添加请求，然后响应到记录属性。

为了实现这一目标，我正在实施自己的ITelemetryInitializer。看起来完全像这样。

    public class MyInitializer : ITelemetryInitializer
    {
        private readonly IHttpContextAccessor _httpContextAccessor;
        public MyInitializer(IHttpContextAccessor httpContextAccessor)
        {
            _httpContextAccessor = httpContextAccessor;
        }
        public void Initialize(ITelemetry telemetry)
        {
            var requestTelemetry = telemetry as RequestTelemetry;
            if (requestTelemetry == null || _httpContextAccessor?.HttpContext?.Request == null 
                || requestTelemetry.Properties.ContainsKey("RequestBody"))
            {
                return;
            }
            var request = _httpContextAccessor?.HttpContext?.Request;
            request?.EnableRewind();
            if (request.Method.Equals(HttpMethod.Post.ToString(), StringComparison.InvariantCultureIgnoreCase)
                || request.Method.Equals(HttpMethod.Put.ToString(), StringComparison.InvariantCultureIgnoreCase))
            {
                using (var reader = new StreamReader(request.Body, Encoding.UTF8, true, 1024, true))
                {
                    var requestBody = reader.ReadToEnd();
                    requestTelemetry.Properties.Add("RequestBody", requestBody);
                }
            }
        }
    }

在启动中，我添加了此

services.AddHttpContextAccessor();
services.AddSingleton<ITelemetryInitializer, MyInitializer>();
services.AddApplicationInsightsTelemetry();

我遇到的错误是：

ObjectDisposedException: Cannot access a disposed object.
Object name: FileBufferingReadStream.
Microsoft.AspNetCore.WebUtilities.FileBufferingReadStream.ThrowIfDisposed()

---

我已经使用了.EnableRewind，并指示StreamReader打开文件。尽管如此，我的请求实际上击中了我的控制器时仍然是零的，甚至当它再次击中我的初始化器以获得第二次通过（设置响应信息）。

欢迎任何建议。

---

此外，我尝试添加一块中间件，以确保.EnableRewind可以使用，但这无济于事。我宁愿不必添加任何其他中间件，因为我希望没有其他依赖关系。

app.Use(async (context, next) =>
{
    context.Request.EnableRewind();
    await next();
});

谢谢。

Answer 1

一如既往的解决方案最终成为一行代码。我欠Gunnar Peipman先生，感谢他的博客文章阅读请求主体，

行： request.Body.Seek(0, SeekOrigin.Begin);

代码

public class MyInitializer : ITelemetryInitializer
{
    private readonly IHttpContextAccessor _httpContextAccessor;
    public MyInitializer(IHttpContextAccessor httpContextAccessor)
    {
        _httpContextAccessor = httpContextAccessor;
    }
    public void Initialize(ITelemetry telemetry)
    {
        var requestTelemetry = telemetry as RequestTelemetry;
        if (requestTelemetry == null || _httpContextAccessor?.HttpContext?.Request == null
                                     || requestTelemetry.Properties.ContainsKey("RequestBody"))
        {
            return;
        }
        var request = _httpContextAccessor?.HttpContext?.Request;
        request?.EnableRewind();
        if (request.Method.Equals(HttpMethod.Post.ToString(), StringComparison.InvariantCultureIgnoreCase)
            || request.Method.Equals(HttpMethod.Put.ToString(), StringComparison.InvariantCultureIgnoreCase))
        {
            using (var reader = new StreamReader(request.Body, Encoding.UTF8, true, 1024, true))
            {
                var requestBody = reader.ReadToEnd();
                request.Body.Seek(0, SeekOrigin.Begin);
                requestTelemetry.Properties.Add("RequestBody", requestBody);
            }
        }
    }
}