Mbp通过筛选器和中间件实现异常,日志,事务及接口返回数据格式化aop处理.

Mbp应用服务层的AOP实现

实现方法:asp.net core mvc 筛选器 + 中间件

日志,事务,和接口返回结果统一格式化采用操作筛选器,而异常处理采用中间件来处理.

最开始,我是打算用autofac的高级特性的拦截器来做AOP的,但是遇到一个问题,poco controller没办法注入到autofac的容器里面.导致拦截器不能正常工作,所以就采用了筛选器来做.这里的场景有以下几个:

AOP是在应用层,而应用层是用poco controller做的,而在asp.net core web api的基架中,controller处在管线的末端.所以可以在这层进行全局拦截.
中间件处理异常更加灵活,可以有更多的定制化需求,而异常筛选器是响应抓捕的异常来处理,它相当于是异常发生后的一个处理程序,而中间件可以来实现类似异常筛选器.
中间件不短路,只是在程序运行的管线上添加了try catch,同时也解决了异步方法出现的异常无法被捕获的问题.

实现代码

Mbp.AspNetCore.Filter 添加MbpLogFilter,MbpTransActionFilter,ResponseMiddleware三个操作筛选器
Mbp.AspNetCore.Middleware 添加MbpGlobaExceptionMiddleware中间件
在模块MbpAspNetCoreModule中注册筛选器和中间件

public override IServiceCollection AddServices(IServiceCollection services)

        {

            services.AddMvc().AddNewtonsoftJson(options =>

            {

                // 忽略循环引用

                options.SerializerSettings.ReferenceLoopHandling = ReferenceLoopHandling.Ignore;

                // 不使用驼峰

                options.SerializerSettings.ContractResolver = new DefaultContractResolver();

                // 设置时间格式

                options.SerializerSettings.DateFormatString = "yyyy-MM-dd HH:mm:ss";

            }).AddMvcOptions(options =>

            {

                // 禁用Version的绑定

                options.ModelMetadataDetailsProviders.Add(new ExcludeBindingMetadataProvider(typeof(System.Version)));

                // 统一事务处理中间件

                options.Filters.Add(typeof(MbpTransActionFilter));

                // 统一日志处理中间件

                options.Filters.Add(typeof(MbpLogFilter));

                // 请求响应统一格式处理中间件

                options.Filters.Add(typeof(ResponseMiddleware));

            }); ;

            AddAutoWebApi(services, new AutoWebApiOptions());

            // 创建Cors策略

            services.AddCors(options =>

            {

                options.AddPolicy("MbpCors",

                builder =>

                {

                    builder.WithOrigins(services.BuildServiceProvider().GetService<IConfiguration>().GetSection("AllowedHosts").Value)

                    .AllowAnyMethod()

                    .AllowAnyHeader(); ;

                });

            });

            return base.AddServices(services);

        }

public override void UseModule(IApplicationBuilder app)

        {

            // 启用跨域请求中间件

            app.UseCors("MbpCors");

            // 启用应用服务层全局错误处理中间件

            app.UseMiddleware(typeof(MbpGlobaExceptionMiddleware));

            base.UseModule(app);

        }

异常中间件对并发冲突进行单独处理

 public async Task InvokeAsync(HttpContext context, ILogger<MbpGlobaExceptionMiddleware> logger)

        {

            try

            {

                // Call the next delegate/middleware in the pipeline

                await _next(context);

            }

            catch (DbUpdateConcurrencyException ex)

            {

                // 发生冲突时候,牺牲后者.不做具体数据合并操作.提示当前用户数据已经发生修改,需要重试.

                logger.LogError("并发冲突:" + ex.Message);

                context.Response.ContentType = "application/json";

                await context.Response.WriteAsync(JsonConvert.SerializeObject(new { Code = 500, Message = "提交并发冲突", Version = "1", Data = new List<object>() }));

            }

            catch (Exception ex)

            {

                // 其他异常

                logger.LogError($"请求[{context.Request.Path}]发生异常:" + ex.Message);

                context.Response.ContentType = "application/json";

                await context.Response.WriteAsync(JsonConvert.SerializeObject(new { Code = 500, Message = "服务器异常", Version = "1", Data = new List<object>() }));

            }

        }

代码详细地址:https://github.com/mbpframework/Mbp

巴特西

Mbp通过筛选器和中间件实现异常,日志,事务及接口返回数据格式化aop处理.

Mbp应用服务层的AOP实现

实现方法:asp.net core mvc 筛选器 + 中间件

日志,事务,和接口返回结果统一格式化采用操作筛选器,而异常处理采用中间件来处理.

实现代码

异常中间件对并发冲突进行单独处理

最新文章

热门文章