.net使用DispatchProxy

群山春晓

实现动态aop并注入 用表达式树调用目标方法
创建一个DynamicDispatchProxy类继承DispatchProxy,字典key最好是由路劲名称+方法参数组成 

1. public class DynamicDispatchProxy<T> : DispatchProxy
2. {
3.     /// <summary>
4.     /// 目标类
5.     /// </summary>
6.     private T _this { get; set; }
7.     /// <summary>
8.     /// 进入前方法
9.     /// </summary>
10.     private Action<string> _last { get; set; }
11.     /// <summary>
12.     /// 退出后方法
13.     /// </summary>
14.     private Action<string, object?> _next { get; set; }
15.     private void last(string _v)
16.     {
17.         try
18.         {
19.             _last.Invoke(_v);
20.         }
21.         catch (System.Exception)
22.         {
24.         }
25.     }
26.     private void next(string _v, object _v1)
27.     {
28.         try
29.         {
30.             _next.Invoke(_v, _v1);
31.         }
32.         catch (System.Exception)
33.         {
35.         }
36.     }
37.     private static ConcurrentDictionary<string, Delegate?> dic = new ConcurrentDictionary<string, Delegate?>();
38.     protected override object? Invoke(MethodInfo? targetMethod, object?[]? args)
39.     {
40.         last(targetMethod.Name);
41.         object obj = null;
42.         try
43.         {
44.             var paramstype = targetMethod.GetParameters().Select(d => d.ParameterType).ToList();
45.             var key =typeof(T).FullName+ targetMethod.Name + string.Join(' ', paramstype.Select(d => d.Name));
46.             if (!dic.ContainsKey(key))
47.             {
48.                 List<ParameterExpression> listparame = new List<ParameterExpression>();
49.                 for (int i = 0; i < paramstype.Count; i++)
50.                 {
51.                     listparame.Add(Expression.Parameter(paramstype[i]));
52.                 }
53.                 MethodCallExpression method = Expression.Call(Expression.Constant(_this), targetMethod, listparame);
54.                 Delegate? lambda = Expression.Lambda(method, listparame).Compile();
55.                 dic.TryAdd(key, lambda);
56.             }
57.             obj= dic[key].DynamicInvoke(args);
58.              next(targetMethod.Name,obj);
59.             return obj;
60.         }
61.         catch (System.Exception ex)
62.         {
64.             throw ex;
65.         }
66.     }
67.     public T Create(){
68.         ///BuildServiceProvider 获取方法
69.         var imp = IServiceCollectionHelp.GetService<T>();
70.         ///拦截实现类的type
71.         var attributtype = imp.GetType().GetCustomAttribute<DynamicTypeAttribut>();
72.         ///在这之前要先注入 拦截实现类才能获取 Impintercept这是接口定义拦截前和拦截后
73.         var Impintercept = IServiceCollectionHelp.GetService<IIntercept>(attributtype.type);
74.         object o = Create<T, DynamicDispatchProxy<T>>();
75.         DynamicDispatchProxy<T> pro=(DynamicDispatchProxy<T>)o;
76.         ///赋值给上面委托
77.         pro._this = imp;
78.         pro._last = Impintercept.Last;
79.         pro._next = Impintercept.Next;
80.         return (T)o;
81.     }
82. }

复制代码

创建一个特性类 来获取拦截实现类的type !DynamicTypeAttribut

1. [AttributeUsage(AttributeTargets.Class)]
2.     public class DynamicTypeAttribut:Attribute
3.     {
4.         public Type type;
5.         public DynamicTypeAttribut(Type type){
6.             this.type=type;
7.         }
8.     }

复制代码

定义拦截接口 IIntercept

1.   public interface IIntercept
2.     {
3.         void Last(string name);
4.         void Next(string name,object? obj);
5.     }

复制代码

拦截的目标

1. public interface ITest
2. {
3.     void Write();
4.     int Add(int v1,int v2);
5. }<br>///这里是Intercept是实现类
6. [DynamicTypeAttribut(typeof(Intercept))]
7. public class Test : ITest
8. {
9.     public int Add(int v1, int v2)
10.     {
11.         Console.WriteLine(nameof(Add));
12.        return v1+v2;
13.     }
15.     public void Write()
16.     {
17.       
18.         Console.WriteLine(this.GetHashCode());
19.     }
20. }

复制代码

拦截方法的实现

1. public class Intercept : IIntercept
2. {
3.     public void Last(string name)
4.     {
5.         Console.WriteLine(this.GetHashCode());
7.         Console.WriteLine("进入"+name);
8.     }
10.     public void Next(string name, object? obj)
11.     {
12.         Console.WriteLine("推出"+name);
13.         if( obj !=null)
14.             Console.WriteLine("返回值"+obj);
15.     }
16. }

复制代码

注入

1. ///注入拦截实现类 不然获取不到
2. builder.Services.AddScoped< Intercept>();
3. ///这里也要注入一次  不然也获取不到
4. builder.Services.AddScoped<ITest, Test>();
5. var _ = new DynamicDispatchProxy<ITest>();
6. IServiceCollectionHelp.serviceProvider = builder.Services.BuildServiceProvider();
7. builder.Services.AddScoped(typeof(ITest), d => {
8.         return _.Create();///创建
9. })

复制代码

 

来源:https://www.cnblogs.com/bay-max-/archive/2023/03/03/17175481.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！