基于 abp vNext 和 .NET Core 开发博客项目 - 异常处理和日志记录

时间  2020-06-06
标签 基于 abp vnext core 开发 博客 项目 异常 处理 日志 记录 繁體版
原文   原文链接

在开始以前，咱们实现一个以前的遗留问题，这个问题是有人在GitHub Issues(https://github.com/Meowv/Blog/issues/8)上提出来的，就是当咱们对Swagger进行分组，实现IDocumentFilter接口添加了文档描述信息后，切换分组时会显示不属于当前分组的Tag。html

通过研究和分析发现，是能够解决的，我不知道你们有没有更好的办法，个人实现方法请看：git

0

//SwaggerDocumentFilter.cs
...
        public void Apply(OpenApiDocument swaggerDoc, DocumentFilterContext context)
        {
            var tags = new List<OpenApiTag>{...}
            
            #region 实现添加自定义描述时过滤不属于同一个分组的API

            var groupName = context.ApiDescriptions.FirstOrDefault().GroupName;

            var apis = context.ApiDescriptions.GetType().GetField("_source", BindingFlags.NonPublic | BindingFlags.Instance).GetValue(context.ApiDescriptions) as IEnumerable<ApiDescription>;

            var controllers = apis.Where(x => x.GroupName != groupName).Select(x => ((ControllerActionDescriptor)x.ActionDescriptor).ControllerName).Distinct();

            swaggerDoc.Tags = tags.Where(x => !controllers.Contains(x.Name)).OrderBy(x => x.Name).ToList();

            #endregion
        }
...

根据调试代码发现，咱们能够从context.ApiDescriptions获取到当前显示的是哪个分组下的API。github

而后使用GetType().GetField(string name, BindingFlags bindingAttr)获取到_source，当前项目的全部API，里面同时也包含了ABP默认生成的一些接口。json

再将API中不属于当前分组的API筛选掉，用Select查询出全部的Controller名称进行去重。api

由于OpenApiTag中的Name名称与Controller的Name是一致的，因此最后将包含controllers名称的tag查询出来取反，便可知足需求。mvc

上一篇文章(http://www.javashuo.com/article/p-ecngxpov-ev.html)集成了GitHub，使用JWT的方式完成了身份认证和受权，保护了咱们写的API接口。app

本篇主要实现对项目中出现的异常仅需处理，当出现不可避免的错误时，或者未受权用户调用接口时，能够进行有效的监控和日志记录。异步

目前调用未受权接口，会直接返回一个状态码为401的错误页面，这样显得太不友好，咱们仍是用以前写的统一返回模型来告诉调用者，你是未受权的，调不了个人接口，上篇也有提到过，咱们将用两种方式来解决。async

方式一 ：使用AddJwtBearer()扩展方法下面的options.Events事件机制。ide

//MeowvBlogHttpApiHostingModule.cs
...
	//应用程序提供的对象，用于处理承载引起的事件，身份验证处理程序
	options.Events = new JwtBearerEvents
	{
	    OnChallenge = async context =>
	    {
	        // 跳过默认的处理逻辑，返回下面的模型数据
	        context.HandleResponse();
	
	        context.Response.ContentType = "application/json;charset=utf-8";
	        context.Response.StatusCode = StatusCodes.Status200OK;
	
	        var result = new ServiceResult();
	        result.IsFailed("UnAuthorized");
	
	        await context.Response.WriteAsync(result.ToJson());
	    }
	};
...

在项目启动时，实例化了OnChallenge，若是用户调用未受权，将请求的状态码赋值为200，并返回模型数据。

1

如图所示，能够看到已经成功返回了一段比较友好的JSON数据。

{
  "Code": 1,
  "Message": "UnAuthorized",
  "Success": false,
  "Timestamp": 1590226085318
}

方式二 ：使用中间件的方式。

咱们注释掉上面的代码，在.HttpApi.Hosting添加文件夹Middleware，新建一个中间件ExceptionHandlerMiddleware.cs

using Meowv.Blog.ToolKits.Base;
using Meowv.Blog.ToolKits.Extensions;
using Microsoft.AspNetCore.Http;
using System;
using System.Net;
using System.Threading.Tasks;

namespace Meowv.Blog.HttpApi.Hosting.Middleware
{
    /// <summary>
    /// 异常处理中间件
    /// </summary>
    public class ExceptionHandlerMiddleware
    {
        private readonly RequestDelegate next;

        public ExceptionHandlerMiddleware(RequestDelegate next)
        {
            this.next = next;
        }

        /// <summary>
        /// Invoke
        /// </summary>
        /// <param name="context"></param>
        /// <returns></returns>
        public async Task Invoke(HttpContext context)
        {
            try
            {
                await next(context);
            }
            catch (Exception ex)
            {
                await ExceptionHandlerAsync(context, ex.Message);
            }
            finally
            {
                var statusCode = context.Response.StatusCode;
                if (statusCode != StatusCodes.Status200OK)
                {
                    Enum.TryParse(typeof(HttpStatusCode), statusCode.ToString(), out object message);
                    await ExceptionHandlerAsync(context, message.ToString());
                }
            }
        }

        /// <summary>
        /// 异常处理，返回JSON
        /// </summary>
        /// <param name="context"></param>
        /// <param name="message"></param>
        /// <returns></returns>
        private async Task ExceptionHandlerAsync(HttpContext context, string message)
        {
            context.Response.ContentType = "application/json;charset=utf-8";

            var result = new ServiceResult();
            result.IsFailed(message);

            await context.Response.WriteAsync(result.ToJson());
        }
    }
}

RequestDelegate是一种请求委托类型，用来处理HTTP请求的函数，返回的是delegate，实现异步的Invoke方法。

这里我写了一个比较通用的方法，当出现异常时直接执行ExceptionHandlerAsync()方法，当没有异常发生时，在finally中判断当前请求状态，多是200？404？401？等等，无论它是什么，反正不是200，获取到状态码枚举的Key值用来看成错误信息返回，最后也执行ExceptionHandlerAsync()方法，返回咱们自定义的模型。

写好了中间件，而后在OnApplicationInitialization(...)中使用它。

public override void OnApplicationInitialization(ApplicationInitializationContext context)
        {
            ...
            // 异常处理中间件
            app.UseMiddleware<ExceptionHandlerMiddleware>();
            ...
        }

一样能够达到效果，相比之下他还支持状态非401的错误返回，好比咱们访问一个不存在的页面：https://localhost:44388/aaa ，也能够友好的进行处理。

2

固然这两种方式能够共存，互不影响。

还有一种处理异常的方式，就是咱们的过滤器Filter，abp已经默认为咱们实现了全局的异常模块，详情能够看其文档：https://docs.abp.io/zh-Hans/abp/latest/Exception-Handling ，在这里，我准备移除abp提供的异常处理模块，本身实现一个。

先看一下目前的异常显示状况，咱们在HelloWorldController中写一个异常接口。

//HelloWorldController.cs
...
        [HttpGet]
        [Route("Exception")]
        public string Exception()
        {
            throw new NotImplementedException("这是一个未实现的异常接口");
        }
...

3

按理说，他应该会执行到咱们写的ExceptionHandlerMiddleware中间件中去，可是被咱们的Filter进行拦截了，如今咱们移除默认的拦截器AbpExceptionFilter

仍是在模块类MeowvBlogHttpApiHostingModule，ConfigureServices()方法中。

Configure<MvcOptions>(options =>
{
    var filterMetadata = options.Filters.FirstOrDefault(x => x is ServiceFilterAttribute attribute && attribute.ServiceType.Equals(typeof(AbpExceptionFilter)));

    // 移除 AbpExceptionFilter
    options.Filters.Remove(filterMetadata);
});

从options.Filters中找到AbpExceptionFilter，而后Remove掉，此时再看一下有异常的接口。

4

当咱们注释掉咱们的中间件时，他就会显示以下图这样。

5

这个页面有没有很熟悉的感受？相信作过.net core开发的都遇到过吧。

ok，如今为止已经完美显示了。但到这里还远远不够，说好的本身实现Filter呢？咱们如今实现Filter又有什么用呢？咱们能够在Filter中能够作一些日志记录。

在.HttpApi.Hosting层添加文件夹Filters，新建一个MeowvBlogExceptionFilter.cs的Filter，他须要实现咱们的IExceptionFilter接口的OnExceptionAsync()方法便可。

//MeowvBlogExceptionFilter.cs
using Meowv.Blog.ToolKits.Helper;
using Microsoft.AspNetCore.Mvc.Filters;

namespace Meowv.Blog.HttpApi.Hosting.Filters
{
    public class MeowvBlogExceptionFilter : IExceptionFilter
    {
        /// <summary>
        /// 异常处理
        /// </summary>
        /// <param name="context"></param>
        /// <returns></returns>
        public void OnException(ExceptionContext context)
        {
            // 日志记录
            LoggerHelper.WriteToFile($"{context.HttpContext.Request.Path}|{context.Exception.Message}", context.Exception);
        }
    }
}

OnException(...)方法很简单，这里只作了记录日志的操做，剩下的交给咱们中间件去处理吧。

注意，必定要在移除默认AbpExceptionFilter后，将咱们本身实现的MeowvBlogExceptionFilter在模块类ConfigureServices()方法中注入到系统。

...
	Configure<MvcOptions>(options =>
	{
	    ...
	    // 添加本身实现的 MeowvBlogExceptionFilter
	    options.Filters.Add(typeof(MeowvBlogExceptionFilter));
	});
...

说到日志，就有不少种处理方式，请选择你熟悉的方式，我这里将使用log4net进行处理，仅供参考。

在.ToolKits层添加log4net包，使用命令安装：Install-Package log4net，而后添加文件夹Helper，新建一个LoggerHelper.cs。

//LoggerHelper.cs
using log4net;
using log4net.Config;
using log4net.Repository;
using System;
using System.IO;

namespace Meowv.Blog.ToolKits.Helper
{
    public static class LoggerHelper
    {
        private static readonly ILoggerRepository Repository = LogManager.CreateRepository("NETCoreRepository");
        private static readonly ILog Log = LogManager.GetLogger(Repository.Name, "NETCorelog4net");

        static LoggerHelper()
        {
            XmlConfigurator.Configure(Repository, new FileInfo("log4net.config"));
        }

        /// <summary>
        /// 写日志
        /// </summary>
        /// <param name="message"></param>
        /// <param name="ex"></param>
        public static void WriteToFile(string message)
        {
            Log.Info(message);
        }

        /// <summary>
        /// 写日志
        /// </summary>
        /// <param name="message"></param>
        /// <param name="ex"></param>
        public static void WriteToFile(string message, Exception ex)
        {
            if (string.IsNullOrEmpty(message))
                message = ex.Message;

            Log.Error(message, ex);
        }
    }
}

在.HttpApi.Hosting中添加log4net配置文件，log4net.config配置文件以下：

//log4net.config
<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <configSections>
    <section name="log4net" type="log4net.Config.Log4NetConfigurationSectionHandler, log4net"/>
  </configSections>
  <log4net debug="false">

    <appender name="info" type="log4net.Appender.RollingFileAppender,log4net">
      <param name="File" value="log4net/info/" />
      <param name="AppendToFile" value="true" />
      <param name="MaxSizeRollBackups" value="-1"/>
      <param name="MaximumFileSize" value="5MB"/>
      <param name="RollingStyle" value="Composite" />
      <param name="DatePattern" value="yyyyMMdd\\HH&quot;.log&quot;" />
      <param name="StaticLogFileName" value="false" />
      <layout type="log4net.Layout.PatternLayout,log4net">
        <param name="ConversionPattern" value="%n
{
	&quot;system&quot;: &quot;Meowv.Blog&quot;,
	&quot;datetime&quot;: &quot;%d&quot;,
	&quot;description&quot;: &quot;%m&quot;,
  &quot;level&quot;: &quot;%p&quot;,
	&quot;info&quot;: &quot;%exception&quot;
}" />
      </layout>
      <filter type="log4net.Filter.LevelRangeFilter">
        <levelMin value="INFO" />
        <levelMax value="INFO" />
      </filter>
    </appender>

    <appender name="error" type="log4net.Appender.RollingFileAppender,log4net">
      <param name="File" value="log4net/error/" />
      <param name="AppendToFile" value="true" />
      <param name="MaxSizeRollBackups" value="-1"/>
      <param name="MaximumFileSize" value="5MB"/>
      <param name="RollingStyle" value="Composite" />
      <param name="DatePattern" value="yyyyMMdd\\HH&quot;.log&quot;" />
      <param name="StaticLogFileName" value="false" />
      <layout type="log4net.Layout.PatternLayout,log4net">
        <param name="ConversionPattern" value="%n
{
	&quot;system&quot;: &quot;Meowv.Blog&quot;,
	&quot;datetime&quot;: &quot;%d&quot;,
	&quot;description&quot;: &quot;%m&quot;,
  &quot;level&quot;: &quot;%p&quot;,
	&quot;info&quot;: &quot;%exception&quot;
}" />
      </layout>
      <filter type="log4net.Filter.LevelRangeFilter">
        <levelMin value="ERROR" />
        <levelMax value="ERROR" />
      </filter>
    </appender>

    <root>
      <level value="ALL"></level>
      <appender-ref ref="info"/>
      <appender-ref ref="error"/>
    </root>

  </log4net>

</configuration>

此时再去调用 .../HelloWorld/Exception，将会获得日志文件，内容是以JSON格式进行存储的。

6

关于Filter的更多用法能够参考微软官方文档：https://docs.microsoft.com/zh-cn/aspnet/core/mvc/controllers/filters

到这里，系统的异常处理和日志记录便完成了，你学会了吗？😁😁😁

开源地址：https://github.com/Meowv/Blog/tree/blog_tutorial

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程