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>() }));
}
}