.Net Core中間件和過濾器實現錯誤日誌記錄

時間  2019-11-16
標籤 core 中間件 過濾器 實現 錯誤 日誌 記錄 简体版
原文   原文鏈接

1.中間件的概念

ASP.NET Core的處理流程是一個管道，中間件是組裝到應用程序管道中用來處理請求和響應的組件。 每一箇中間件能夠：json

  • 選擇是否將請求傳遞給管道中的下一個組件。
  • 能夠在調用管道中的下一個組件以前和以後執行業務邏輯。

　　中間件是一個請求委託（ public delegate Task RequestDelegate(HttpContext context) ）的實例，因此中間件的本質就是一個方法，方法的參數是HttpContext，返回Task。傳入的HttpContext參數包含了請求和響應信息，咱們能夠在中間件中對這些信息就行修改。中間件的管道處理流程以下：api

　　咱們知道中間件是配置請求處理管道的組件，那麼誰來負責構建管道呢？負責構建管道的角色是ApplicationBuilder。ApplicationBuilder經過Use、Run、Map及MapWhen方法來註冊中間件，構建請求管道。咱們簡單看下這幾個方法。瀏覽器

1 Run

　　新建一個WebAPI項目，修改StartUp中的Configure方法以下，用Run方法註冊的中間件能夠叫作終端中間件，即該中間件執行完成後再也不執行後續的中間件。app

        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            //第一個中間件
            app.Run(async (context) =>
            {
                context.Response.ContentType = "text/plain;charset=utf-8";//防止中文亂碼
                await context.Response.WriteAsync("第一個中間件輸出你好~");
            });
            //第二個中間件
            app.Run(async (context) =>
            {
                await context.Response.WriteAsync("第二個中間件輸出你好~");
            });
        }

　　運行程序，咱們看到只執行了第一個中間件，後邊的中間件不會執行。
asp.net

2 Use

　　Use方法的參數是一個委託實例，委託的第一個參數是HttpContext，這是待處理的請求上下文；第二個參數next是下一個中間件，咱們能夠經過next.Invoke()調用下一個中間件，而且能夠在調用下一個中間件以前/以後對HttpContext作一個邏輯處理。async

        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            //第一個中間件
            app.Use(async (context, next) =>
            {
                context.Response.ContentType = "text/plain;charset=utf-8";//防止中文亂碼
                await context.Response.WriteAsync($"第一個中間件輸出你好~{Environment.NewLine}");

                await context.Response.WriteAsync($"下一個中間件執行前執行===>{Environment.NewLine}");
                await next.Invoke();
                await context.Response.WriteAsync($"下一個中間件執行後執行<==={Environment.NewLine}");
            });
            //第二個中間件
            app.Use(async (context,next) =>
            {
                await context.Response.WriteAsync($"第二個中間件輸出你好~{Environment.NewLine}");
            });
        }

 　　運行程序以下所示。注意若是咱們沒有調用next.Invoke()方法，會形成管道短路，後續的全部中間件都再也不執行。ide

3 Map

　　在業務簡單的狀況下，使用一個請求處理管道來處理全部的請求就能夠了，當業務複雜的時候， 咱們可能考慮把不一樣業務的請求交給不一樣的管道中處理。 Map 基於給定請求路徑的匹配項來建立請求管道分支。 若是請求路徑以給定路徑開頭，則執行分支。看一個栗子，需求是/userinfo開頭的請求使用用戶分支管道來處理，/product開頭的請求使用產品分支管道處理，代碼以下：測試

    public class Startup
    {
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
        }
        public IConfiguration Configuration { get; }

        // 依賴注入
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
        }
        /// <summary>
        /// 配置用戶分支管道，處理以url以/userinfo開頭的請求 
        /// </summary>
        /// <param name="app"></param>
        private static void UserinfoConfigure(IApplicationBuilder app)
        {
            app.Use(async (context, next) =>
            {
                await context.Response.WriteAsync($"處理用戶業務，{Environment.NewLine}");
                await next.Invoke();
            });
            app.Run(async (context) => { await context.Response.WriteAsync("用戶業務處理完成~"); });
        }
        /// <summary>
        /// 配置產品分支管道，處理以url以/product開頭的請求
        /// </summary>
        /// <param name="app"></param>
        private static void ProductConfigure(IApplicationBuilder app)
        {
            app.Use(async (context, next) =>
            {
                await context.Response.WriteAsync($"處理產品業務");
                await next.Invoke();
            });
        }
        // 配置請求處理管道
        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            //防止中文亂碼
            app.Use(async (context,next) =>
            {
                context.Response.ContentType = "text/plain;charset=utf-8";
                await next.Invoke();
            });

            app.Map("/userinfo", UserinfoConfigure);

            app.Map("/product", ProductConfigure);

            app.Run(async context =>
            {
                await context.Response.WriteAsync("主管道處理其餘業務");
            });
        }
    }

　　運行程序執行結果以下：ui

4 MapWhen

　　MapWhen和Map的思想比較類似，MapWhen基於自定義條件來建立請求管道分支，並將請求映射到管道的新分支。看一個栗子就明白了，下邊栗子的需求是查詢參數包含name的請求交給一個分支管道處理，url包含/userinfo的請求交給用戶分支來處理，代碼以下：this

    public class Startup
    {
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
        }
        public IConfiguration Configuration { get; }

        // 依賴注入
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
        }
        /// <summary>
        /// 配置分支管道，處理以url中有包含/userinfo的請求
        /// </summary>
        /// <param name="app"></param>
        private static void UserinfoConfigure(IApplicationBuilder app)
        {
            app.Use(async (context, next) =>
            {
                await context.Response.WriteAsync($"處理用戶業務，{Environment.NewLine}");
                await next.Invoke();
            });
            app.Run(async (context) => { await context.Response.WriteAsync("用戶業務處理完成~"); });
        }
        /// <summary>
        /// 配置分支管道，處理以查詢參數有name的請求
        /// </summary>
        /// <param name="app"></param>
        private static void HNameConfigure(IApplicationBuilder app)
        {
            app.Use(async (context, next) =>
            {
                await context.Response.WriteAsync($"查詢參數包含name，值爲:{context.Request.Query["name"]}");
                await next.Invoke();
            });
        }
        // 配置請求處理管道
        public void Configure(IApplicationBuilder app, IHostingEnvironment env)
        {
            //防止中文亂碼
            app.Use(async (context,next) =>
            {
                context.Response.ContentType = "text/plain;charset=utf-8";
                await next.Invoke();
            });
          
            app.MapWhen(context => context.Request.Query.ContainsKey("name"), HNameConfigure);
            app.MapWhen(context => context.Request.Path.Value.ToString().Contains("/userinfo"), UserinfoConfigure);

            app.Run(async context =>
            {
                await context.Response.WriteAsync("主管道處理其餘業務");
            });
        }
    }

 　　程序執行結果以下：

　　到這裏咱們對中間件已經有了一個基本的瞭解，接下了經過一個異常日誌 中間件來了解開發中怎麼去使用中間件。

2 使用中間件記錄錯誤日誌

　　這裏使用的日誌組件爲nlog，首先建立一個WebAPI項目，添加一個自定義日誌處理中間件CostomErrorMiddleware，當程序出錯時會記錄日誌，同時開發環境下會把異常的詳細信息打印在頁面上，非開發環境隱藏詳細信息，代碼以下：

    /// <summary>
    /// 自定義的錯誤處理類
    /// </summary>
    public class CostomErrorMiddleware
    {
        private readonly RequestDelegate next;
        private readonly ILogger logger;
        private IHostingEnvironment environment;
        /// <summary>
        /// DI,注入logger和環境變量
        /// </summary>
        /// <param name="next"></param>
        /// <param name="logger"></param>
        /// <param name="environment"></param>
        public CostomErrorMiddleware(RequestDelegate next, ILogger<CostomErrorMiddleware> logger, IHostingEnvironment environment)
        {
            this.next = next;
            this.logger = logger;
            this.environment = environment;
        }
        /// <summary>
        /// 實現Invoke方法
        /// </summary>
        /// <param name="context"></param>
        /// <returns></returns>
        public async Task Invoke(HttpContext context)
        {
            try
            {
                await next.Invoke(context);
            }
            catch (Exception ex)
            {
                await HandleError(context, ex);
            }
        }
        /// <summary>
        /// 錯誤信息處理方法
        /// </summary>
        /// <param name="context"></param>
        /// <param name="ex"></param>
        /// <returns></returns>
        private async Task HandleError(HttpContext context, Exception ex)
        {
            context.Response.StatusCode = 500;
            context.Response.ContentType = "text/json;charset=utf-8;";
            string errorMsg = $"錯誤消息:{ex.Message}{Environment.NewLine}錯誤追蹤:{ex.StackTrace}";
            //不管是否爲開發環境都記錄錯誤日誌
            logger.LogError(errorMsg);
            //瀏覽器在開發環境顯示詳細錯誤信息,其餘環境隱藏錯誤信息
            if (environment.IsDevelopment())
            {
                await context.Response.WriteAsync(errorMsg);
            }
            else
            {
                await context.Response.WriteAsync("抱歉，服務端出錯了");
            }
        }
    }

　　修改StartUp類中的Configure方法以下，注入nlog 須要先安裝 NLog.Web.AspNetCore ，使用app.UseMiddleware<CostomErrorMiddleware>()註冊咱們自定義的中間件，代碼以下：

       /// 配置請求管道
        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory factory)
        {
            //添加nlog
            factory.AddNLog();
            env.ConfigureNLog("nlog.config");
            //泛型方法添加中間件
            app.UseMiddleware<CostomErrorMiddleware>();
            app.UseMvc(); 
        }

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="D:\LogDemoOfWebapi\internal-nlog.txt">
  <!-- enable asp.net core layout renderers -->
  <extensions>
    <add assembly="NLog.Web.AspNetCore"/>
  </extensions>
  <targets>
    <target xsi:type="File" name="errorLog" fileName="D:/logs/AT___${shortdate}.log" 
            layout="----------------日誌記錄開始----------------${newline}【日誌時間】：${longdate} ${newline}【日誌級別】：${level:uppercase=true}${newline}【異常相關信息】${newline}${message}${newline}${newline}${newline}" />
  </targets>
  <rules>
    <logger name="*" minlevel="Error" writeTo="errorLog" />
  </rules>
</nlog>
View Code

　　到這裏異常處理中間件就註冊完成了，修改ValueController本身製造一個異常來測試一下，代碼以下：

    [Route("api/[controller]")]
    [ApiController]
    public class ValuesController : ControllerBase
    {
        private ILogger<ValuesController> _logger;
        public ValuesController(ILogger<ValuesController> logger)
        {
            _logger = logger;
        }
        // GET api/values
        [HttpGet]
        public ActionResult<IEnumerable<string>> Get()
        {
          
            return new string[] { "value1", "value2" };
        }

        // GET api/values/5
        [HttpGet("{id}")]
        public ActionResult<string> Get(int id)
        {
            throw new Exception("有一個錯誤發生了.."); return "value";
        }
    }

　　運行程序，在開發環境下訪問/Values/1，顯示結果以下，同時這些錯誤信息也會經過nlog寫入到錯誤日誌中：

 　　非開發環境下，訪問/values/1，顯示以下：

　　若是咱們想使用相似app.UseMvc()這樣的形式來使用咱們自定義的中間件的話，就須要給ApplicationBuilder添加一個擴展方法，首先添加一個靜態類CostomMiddleware，代碼以下：

    /// <summary>
    /// 擴展方法
    /// </summary>
    public static class CostomMiddleware
    {
        public static IApplicationBuilder UseCostomError(this IApplicationBuilder app)
        {
            return app.UseMiddleware<CostomErrorMiddleware>();
        }
    }

　　而後修改Configure方法便可：

        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory factory)
        {
            //添加nlog
            factory.AddNLog();
            env.ConfigureNLog("nlog.config");
            //使用擴展方法
 app.UseCostomError();
            app.UseMvc(); 
        }

　　運行程序後和前邊的執行效果是同樣的。

3 使用過濾器記錄錯誤日誌

　　過濾器你們應該都很熟悉，在ASP.NET Core中過濾器的使用沒有太大的變化，這裏也實現一個使用過濾器記錄錯誤日誌的栗子，直接看代碼吧，首先建立一個過濾器，代碼以下：

    /// <summary>
    /// 自定義的錯誤處理過濾器
    /// </summary>
    public class CustomErrorFilter :Attribute, IExceptionFilter
    {
        private readonly ILogger _logger;
        private IHostingEnvironment _environment;

        public CustomErrorFilter(ILogger<CustomErrorFilter> logger,IHostingEnvironment environment)
        {
            
            _logger = logger;
            _environment = environment;
        }
        public void OnException(ExceptionContext context)
        {
            Exception ex = context.Exception;
            string errorMsg = $"錯誤消息:{ex.Message}{Environment.NewLine}錯誤追蹤:{ex.StackTrace}";
            ContentResult result = new ContentResult
            {
                ContentType = "text/json;charset=utf-8;",
                StatusCode = 500
            };
            //不管是否爲開發環境都記錄錯誤日誌
            _logger.LogError(errorMsg);
            //瀏覽器在開發環境顯示詳細錯誤信息,其餘環境隱藏錯誤信息
            if (_environment.IsDevelopment())
            {
                result.Content = $"錯誤消息:{ex.Message}{Environment.NewLine}錯誤追蹤:{ex.StackTrace}";
            }
            else
            {
                result.Content = "抱歉，服務端出錯了";
            }
            context.Result = result;
            context.ExceptionHandled = true;
        }
    }

　　修改StartUp類，注入nlog，配置全局過濾器，代碼以下，其中nlog.config和中間件栗子中同樣：

    public class Startup
    {
        public Startup(IConfiguration configuration)
        {
            Configuration = configuration;
        }

        public IConfiguration Configuration { get; }

        // 依賴注入
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddMvc(
                configure =>
                {
                    configure.Filters.Add<CustomErrorFilter>();//全局過濾器，不用添加特性頭
                }//全局過濾器，不用添加特性頭
                ).SetCompatibilityVersion(CompatibilityVersion.Version_2_2);
            //services.AddScoped<CustomErrorFilter>();//局部過濾器，須要在Controller/Action添加特性頭 [ServiceFilter(typeof(CustomErrorFilter))]
        }

        // 配置管道
        public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory factory)
        {
            factory.AddNLog();
            env.ConfigureNLog("nlog.config");
            app.UseMvc();
        }
    }

　　而後修改ValuesController，設置錯誤和上邊中間件的栗子同樣，運行代碼訪問/values/1時，在開發環境中顯示以下，同時錯誤信息也會寫入錯誤日誌中：

 　　在生產環境中訪問/values/1的話，錯誤詳細也會寫入錯誤日誌中，瀏覽器顯示以下：

　　本文介紹了中間件的基本使用，同時使用中間件和過濾器兩種方式實現了異常日誌的記錄，若是文中有錯誤的地方但願你們能夠指出，我會及時改正。

參考文章

　　【1】https://docs.microsoft.com/zh-cn/aspnet/core/fundamentals/logging/?view=aspnetcore-3.0

【2】https://docs.microsoft.com/zh-cn/aspnet/core/fundamentals/middleware/?view=aspnetcore-3.0

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程