Asp.netCore 3.1控制器属性注入and异步事务Aop by AutoFac
做自己-jason 人气:0Aspect Oriented Programming（AOP）是较为热门的一个话题。AOP，国内我们都习惯称之为：面向切面编程
下面直接code 干货展示：(一般人我还不告诉,嘻嘻)
1:导入相关的包：AutoFac 默认最新稳定版即可
Autofac.Extensions.DependencyInjection Version="7.1.0"
Autofac.Extras.DynamicProxy Version="6.0.0"
2：AutoFac注入的扩展方法
1 using System;
2 using System.Linq;
3 namespace ZRF.CRM.Commoms
4 {
5 using Autofac;
6 using Autofac.Extras.DynamicProxy;
7 using Microsoft.AspNetCore.Mvc;
8 using System.Reflection;
9 using ZRF.CRM.Commoms.Interceptors;
10 using ZRF.CRM.MyAttrobutrs;
11
12 public static class ContainerBuilderExtenTion
13 {
14 public static void DependInjecterIoc(this ContainerBuilder builder)
15 {
16 builder.RegisterType<TransactionScopeAsyncInterCeptor>();
17 builder.RegisterAssemblyTypes(Assembly.Load("ZRF.CRM.Service"))
18 .AsImplementedInterfaces().PropertiesAutowired().InterceptedBy(typeof(TransactionScopeAsyncInterCeptor)).EnableInterfaceInterceptors().OnRegistered(t =>
19 {
20 Console.WriteLine("ZRF.CRM.Service===Register_ok");
21 });
22 }
23 }
24 }
3：新增ConfigureContainer(ContainerBuilder builder)方法，并在Startup方法中注册
1 using System;
2 using System.Collections.Generic;
3 using System.Linq;
4 using System.Reflection;
5 using System.Threading.Tasks;
7 using Autofac;
8 using Microsoft.AspNetCore.Builder;
9 using Microsoft.AspNetCore.Hosting;
10 using Microsoft.AspNetCore.Mvc;
11 using Microsoft.AspNetCore.Mvc.Controllers;
12 using Microsoft.Extensions.Configuration;
13 using Microsoft.Extensions.DependencyInjection;
14 using Microsoft.Extensions.DependencyInjection.Extensions;
15 using Microsoft.Extensions.Hosting;
16 using WebApplication1.IOCS;
17 using ZRF.CRM.Commoms;
18 namespace WebApplication1
19 {
20 public class Startup
21 {
22 public Startup(IConfiguration configuration)
23 {
24 Configuration = configuration;
25 }
26 public void ConfigureContainer(ContainerBuilder builder)
27 {
28 builder.DependInjecterIoc();
29
30 //控制器属性注入
31 builder.RegisterModule<ControllerModule>();
32 }
33 public IConfiguration Configuration { get; }
34
35 // This method gets called by the runtime. Use this method to add services to the container.
36 public void ConfigureServices(IServiceCollection services)
37 {
38 services.AddControllersWithViews();
39
40 //core 3.0级以上
41 services.Replace(ServiceDescriptor.Transient<IControllerActivator, ServiceBasedControllerActivator>());
42 }
43
44 // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
45 public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
46 {
47 if (env.IsDevelopment())
48 {
49 app.UseDeveloperExceptionPage();
50 }
51 else
52 {
53 app.UseExceptionHandler("/Home/Error");
54 }
55 app.UseStaticFiles();
56
57 app.UseRouting();
58
59 app.UseAuthorization();
60
61 app.UseEndpoints(endpoints =>
62 {
63 endpoints.MapControllerRoute(
64 name: "default",
65 pattern: "{controller=Home}/{action=Index}/{id?}");
66 });
67 }
68 }
69 }
4：Controller
1 using Microsoft.AspNetCore.Mvc;
2 using Microsoft.Extensions.Logging;
3 using System;
4 using System.Collections.Generic;
5 using System.Diagnostics;
6 using System.Linq;
7 using System.Threading.Tasks;
8 using WebApplication1.Models;
9 using ZRF.CRM.MyAttrobutrs;
10 using ZRF.CRM.InterFaces;
11 namespace WebApplication1.Controllers
12 {
13 [ControllerCanInjectPropertity]
14 public class HomeController : Controller
15 {
16 private readonly ILogger<HomeController> _logger;
17
18 IDoLog _dolog;
19 ITest002Service _service;
20 public IDoLog _dolog2 { get; set; }
21
22 public HomeController(ILogger<HomeController> logger, IDoLog dolog, ITest002Service service)
23 {
24 _logger = logger;
25 _dolog = dolog;
26 this._service = service;
27 }
28
29 public IActionResult Index()
30 {
31 var boolflag = _dolog2.LogWork("aaaa");
32 bool flag = _dolog.LogWork("qqai");
33 var getMsg = _service.Dowork("有aop的方法");
34 Console.WriteLine("Aop获取到方法：" + getMsg);
35 //_service.DoWork02("没有aop的普通方法");
36 return View();
37 }
38
39 public IActionResult Privacy()
40 {
41 return View();
42 }
43
44 [ResponseCache(Duration = 0, Location = ResponseCacheLocation.None, NoStore = true)]
45 public IActionResult Error()
46 {
47 return View(new ErrorViewModel { RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier });
48 }
49 }
50 }
5:InterFace
1 using System;
2 using System.Collections.Generic;
3 using System.Text;
4
5 namespace ZRF.CRM.InterFaces
6 {
7
8 public interface ITest002Service
9 {
10 string Dowork(string msg);
11 string DoWork02(string msg);
12 }
13 }
6：Service
1 using System;
2 using System.Collections.Generic;
3 using System.Text;
4 namespace ZRF.CRM.Service
5 {
6 using ZRF.CRM.InterFaces;
7 using ZRF.CRM.MyAttrobutrs;
8
9 public class Test002Service : ITest002Service
10 {
11 [TransactionScopeAsync]
12 public string Dowork(string msg)
13 {
14
15 return $"Test002Service:Dowork {DateTime.Now}-{msg}";
16 }
17
18 public string DoWork02(string msg)
19 {
20 return $"Test002Service:DoWork02:{DateTime.Now}-{msg}";
21 }
22 }
23 }
7：自定义特性，将来判断哪些方法可以aop
1 using System;
2 using System.Collections.Generic;
3 using System.Text;
4
5 namespace ZRF.CRM.MyAttrobutrs
6 {
7 [AttributeUsage(AttributeTargets.Method)]
8 public class TransactionScopeAsyncAttribute : Attribute
9 {
10 }
11
12 }
8:自定义类来实现Aop的IInterceptor方法
1 using System;
2 using System.Collections.Generic;
3 using System.Text;
4
5 namespace ZRF.CRM.Commoms.Interceptors
6 {
7 using Autofac;
8 using Castle.DynamicProxy;
9 using System.Reflection;
10 using System.Transactions;
11 using ZRF.CRM.MyAttrobutrs;
12
13 public class TransactionScopeAsyncInterCeptor : IInterceptor
14 {
15 public void Intercept(IInvocation invocation)
16 {
17
18 if (HaveAsyncTrascAttribute(invocation))
19 {
20 TransactionScope scope = null;
21 try
22 {
23 scope = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled);
24 Console.WriteLine("TransactionScopeAsyncFlowOption之前=======");
25 invocation.Proceed();
26 scope.Complete();
27 Console.WriteLine("invocation.Proceed()用户自己的逻辑处理ok=======");
28 Console.WriteLine("TransactionScopeAsyncFlowOption之后=======");
29 }
30 catch (Exception)
31 {
32 Console.WriteLine("TransactionScopeAsyncInterCeptor：发生异常");
33 if (scope != null)
34 {
35 scope.Dispose();
36 }
37 }
38 }
39 else {
40 Console.WriteLine("没有异步事务发生！");
41 invocation.Proceed();
42 return;
43 }
44 }
45
46 private bool HaveAsyncTrascAttribute(IInvocation invocation)
47 {
48 var methodInfo = invocation.MethodInvocationTarget ?? invocation.Method;
49 if (methodInfo.GetCustomAttribute<TransactionScopeAsyncAttribute>() != null)
50 {
51 return true;
52 }
53 else { return false; }
54 }
55 }
56 }
9：来一张测试的截图
10：最后欢迎留言指教
加载全部内容