Asp.net Core 中间件获取调用接口的信息并记录到nlog日志文件中

CustomExceptionMiddleware类代码 如下：

using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Http.Internal;
using Microsoft.Extensions.Logging;
using Nestle.Portal.Utility.Models;
using Newtonsoft.Json;
using NLog;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Text;
using System.Threading.Tasks;

namespace DuratiMiddlewareonCollectService.
{
    /// <summary>
    /// 自定义异常中间件
    /// </summary>
    public class CustomExceptionMiddleware
    {
        private readonly RequestDelegate _next;
        private readonly ILogger<CustomExceptionMiddleware> _logger;
        public CustomExceptionMiddleware(RequestDelegate next, ILogger<CustomExceptionMiddleware> logger)
        {
            _next = next;
            _logger = logger;
        }

        public async Task Invoke(HttpContext httpContext)
        {
            try
            {
                HttpRequest request = httpContext.Request;
                Dictionary<string, object> errorData = new Dictionary<string, object>();
                errorData.Add("URL", request.Path.ToString());
                errorData.Add("Method", request.Method);
                if (request.Method.ToLower().Equals("post"))
                {
                    request.EnableRewind();
                    Stream stream = request.Body;
                    byte[] buffer = new byte[request.ContentLength.Value];
                    stream.Read(buffer, 0, buffer.Length);
                    errorData.Add("Body", Encoding.UTF8.GetString(buffer));
                    request.Body.Position = 0;
                }
                else if (request.Method.ToLower().Equals("get"))
                {
                    errorData.Add("Body", request.QueryString.Value);
                }
                _logger.LogInformation(JsonConvert.SerializeObject(errorData));
                await _next(httpContext);
            }
            catch (Exception ex)
            {
                HttpRequest request = httpContext.Request;
                Dictionary<string, object> errorData = new Dictionary<string, object>();
                var trace = new StackTrace(ex, true);
                StackFrame frame = trace.GetFrames()[0];
                errorData.Add("MethodName", frame?.GetMethod().Name);
                errorData.Add("FileLineNumber", frame?.GetFileLineNumber());
                errorData.Add("URL", request.Path.ToString());
                errorData.Add("Method", request.Method);
                if (request.Method.ToLower().Equals("post"))
                {
                    request.EnableRewind();
                    Stream stream = request.Body;
                    byte[] buffer = new byte[request.ContentLength.Value];
                    stream.Read(buffer, 0, buffer.Length);
                    errorData.Add("Body", Encoding.UTF8.GetString(buffer));
                    request.Body.Position = 0;
                }
                else if (request.Method.ToLower().Equals("get"))
                {
                    errorData.Add("Body", request.QueryString.Value);
                }
                errorData.Add("ErrorInfo", ex.Message);
                _logger.LogError(JsonConvert.SerializeObject(errorData));
                await HandleExceptionAsync(httpContext, ex);
            }
        }

        private Task HandleExceptionAsync(HttpContext httpContext, Exception ex)
        {
            return httpContext.Response.WriteAsync(JsonConvert.SerializeObject(new ResultMessage<string>() { success = true, data = null, message = ex.Message }));
        }
    }

    // Extension method used to add the middleware to the HTTP request pipeline.
    public static class CustomExceptionMiddlewareExtensions
    {
        public static IApplicationBuilder UseCustomExceptionMiddleware(this IApplicationBuilder builder)
        {
            return builder.UseMiddleware<CustomExceptionMiddleware>();
        }
    }
}
 

 

Startup类的  Configure 方法代码如下：

  public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {

            app.UseCustomExceptionMiddleware();
            app.UseMvc();

        }

 

Program 类代码如下
        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
            WebHost.CreateDefaultBuilder(args)
                .UseStartup<Startup>()
                //发布需要按以下配置
                .UseNLog()）
               

 

 

nlog.config 代码如下：

<?xml version="1.0" encoding="utf-8" ?>
<nlog xmlns="http://www.nlog-project.org/schemas/NLog.xsd"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      autoReload="true"
      internalLogLevel="info"
      internalLogFile="internal-nlog.txt">

  <!-- define various log targets -->
  <targets>
    <!-- write logs to file -->
    <target xsi:type="File" name="allfile" fileName="logs/${shortdate}.log"
                 layout="${longdate}|${logger}|${uppercase:${level}}|${message} ${exception}" />

    <target xsi:type="Null" name="blackhole" />
  </targets>
  <rules>
    <!--All logs, including from Microsoft-->
    <logger name="*" minlevel="Debug" writeTo="allfile" />

    <!--Skip Microsoft logs and so log only own logs-->
    <logger name="Microsoft.*" minlevel="Trace" writeTo="blackhole" final="true" />
    <logger name="*" minlevel="Trace" writeTo="ownFile-web" />
  </rules>
</nlog>