AOP從靜態代理到動態代理（Emit實現）詳解

2019-10-29 19:59:09

字體：大中小

來源：轉載

供稿：網友

【前言】

AOP（Aspect Orient Programming），我們一般稱為面向方面（切面）編程，作為面向對象的一種補充，用于處理系統中分布于各個模塊的橫切關注點，比如事務管理、日志、緩存等等。AOP實現的關鍵在于AOP框架自動創建的AOP代理，AOP代理主要分為靜態代理和動態代理，靜態代理的代表為AspectJ；而動態代理則以Spring AOP為代表。

何為切面？

一個和業務沒有任何耦合相關的代碼段，諸如：調用日志，發送郵件，甚至路由分發。一切能為代碼所有且能和代碼充分解耦的代碼都可以作為一個業務代碼的切面。

我們為什么要AOP？

那我們從一個場景舉例說起：

如果想要采集用戶操作行為，我們需要掌握用戶調用的每一個接口的信息。這時候的我們要怎么做?

如果不采用AOP技術，也是最簡單的，所有方法體第一句話先調用一個日志接口將方法信息傳遞記錄。

有何問題？

實現業務沒有任何問題，但是隨之而來的是代碼臃腫不堪，難以調整維護的諸多問題（可自行腦補）。

如果我們采用了AOP技術，我們就可以在系統啟動的地方將所有將要采集日志的類注入，每一次調用方法前，AOP框架會自動調用我們的日志代碼。

是不是省去了很多重復無用的勞動？代碼也將變得非常好維護（有朝一日不需要了，只需將切面代碼注釋掉即可）

接下來我們看看AOP框架的工作原理以及實過程。

【實現思路】

AOP框架呢，一般通過靜態代理和動態代理兩種實現方式。

　　 AOP,靜態代理,動態代理,Emit

何為靜態代理？

靜態代理，又叫編譯時代理，就是在編譯的時候，已經存在代理類，運行時直接調用的方式。說的通俗一點，就是自己手動寫代碼實現代理類的方式。

我們通過一個例子來展現一下靜態代理的實現過程：

我們這里有一個業務類，里面有方法Test()，我們要在Test調用前和調用后分別輸出日志。

AOP,靜態代理,動態代理,Emit

我們既然要將Log當作一個切面，我們肯定不能去動原有的業務代碼，那樣也違反了面向對象設計之開閉原則。

那么我們要怎么做呢？我們定義一個新類 BusinessProxy 去包裝一下這個類。為了便于在多個方法的時候區分和辨認，方法也叫 Test（）

AOP,靜態代理,動態代理,Emit

這樣，我們如果要在所有的Business類中的方法都添加Log，我們就在BusinessProxy代理類中添加對應的方法去包裝。既不破壞原有邏輯，又可以實現前后日志的功能。

當然，我們可以有更優雅的實現方式：

AOP,靜態代理,動態代理,Emit

我們可以定義代理類，繼承自業務類。將業務類中的方法定義為虛方法。那么我們可以重寫父類的方法并且在加入日志以后再調用父類的原方法。

當然，我們還有更加優雅的實現方式：

AOP,靜態代理,動態代理,Emit

我們可以使用發射的技術，寫一個通用的Invoke方法，所有的方法都可以通過該方法調用。

我們這樣便實現了一個靜態代理。

那我們既然有了靜態代理，為什么又要有動態代理呢？

我們仔細回顧靜態代理的實現過程。我們要在所有的方法中添加切面，我們就要在代理類中重寫所有的業務方法。更有甚者，我們有N個業務類，就要定義N個代理類。這是很龐大的工作量。

AOP,靜態代理,動態代理,Emit

這就是動態代理出現的背景，相比都可以猜得到，動態代理就是將這一系列繁瑣的步驟自動化，讓程序自動為我們生成代理類。

何為動態代理？

動態代理，又成為運行時代理。在程序運行的過程中，調用了生成代理類的代碼，將自動生成業務類的代理類。不需要我們手共編寫，極高的提高了工作效率和調整了程序員的心態。

原理不必多說，就是動態生成靜態代理的代碼。我們要做的，就是選用一種生成代碼的方式去生成。

今天我分享一個簡單的AOP框架，代碼使用Emit生成。當然，Emit 代碼的寫法不是今天要講的主要內容，需要提前去學習。

先說效果：

定義一個Action特性類 ActionAttribute繼承自 ActionBaseAttribute，里面在Before和After方法中輸出兩條日志；

AOP,靜態代理,動態代理,Emit

定義一個Action特性類InterceptorAttribute 繼承自InterceptorBaseAttribute，里面捕獲了方法調用異常，以及執行前后分別輸出日志；

AOP,靜態代理,動態代理,Emit

然后定義一個業務類BusinessClass 實現了IBusinessClass 接口，定義了各種類型的方法

AOP,靜態代理,動態代理,Emit

多余的方法不貼圖了。

我們把上面定義的方法調用切面標簽放在業務類上，表示該類下所有的方法都執行異常過濾；

我們把Action特性放在Test方法上，表明要在 Test（）方法的 Before 和 After 調用時記錄日志；

我們定義測試類：

AOP,靜態代理,動態代理,Emit

調用一下試試：

AOP,靜態代理,動態代理,Emit

可見，全類方法標簽 Interceptor 在 Test 和 GetInt 方法調用前后都打出了對應的日志；

Action方法標簽只在 Test 方法上做了標記，那么Test方法 Before 和 After 執行時打出了日志；

【實現過程】

實現的思路在上面已經有詳細的講解，可以參考靜態代理的實現思路。

我們定義一個動態代理生成類 DynamicProxy，用于原業務代碼的掃描和代理類代碼的生成；

定義兩個過濾器標簽，ActionBaseAttribute，提供Before和After切面方法；InterceptorBaseAttribute，提供 Invoke “全調用”包裝的切面方法；

Before可以獲取到當前調用的方法和參數列表，After可以獲取到當前方法調用以后的結果。

Invoke 可以拿到當前調用的對象和方法名，參數列表。在這里進行反射動態調用。

[AttributeUsage(AttributeTargets.Method | AttributeTargets.Class, AllowMultiple = false, Inherited = true)] public class ActionBaseAttribute : Attribute { public virtual void Before(string @method, object[] parameters) { } public virtual object After(string @method, object result) { return result; } }

[AttributeUsage(AttributeTargets.Class, AllowMultiple = false, Inherited = true)] public class InterceptorBaseAttribute : Attribute { public virtual object Invoke(object @object, string @method, object[] parameters) {  return @object.GetType().GetMethod(@method).Invoke(@object, parameters); } }

代理生成類采用Emit的方式生成運行時IL代碼。

先把代碼放在這里：

public class DynamicProxy { public static TInterface CreateProxyOfRealize<TInterface, TImp>() where TImp : class, new() where TInterface : class {  return Invoke<TInterface, TImp>(); } public static TProxyClass CreateProxyOfInherit<TProxyClass>() where TProxyClass : class, new() {  return Invoke<TProxyClass, TProxyClass>(true); } private static TInterface Invoke<TInterface, TImp>(bool inheritMode = false) where TImp : class, new() where TInterface : class {  var impType = typeof(TImp);  string nameOfAssembly = impType.Name + "ProxyAssembly";  string nameOfModule = impType.Name + "ProxyModule";  string nameOfType = impType.Name + "Proxy";  var assemblyName = new AssemblyName(nameOfAssembly);  var assembly = AppDomain.CurrentDomain.DefineDynamicAssembly(assemblyName, AssemblyBuilderAccess.Run);  var moduleBuilder = assembly.DefineDynamicModule(nameOfModule);  //var assembly = AppDomain.CurrentDomain.DefineDynamicAssembly(assemblyName, AssemblyBuilderAccess.RunAndSave);  //var moduleBuilder = assembly.DefineDynamicModule(nameOfModule, nameOfAssembly + ".dll");  TypeBuilder typeBuilder;  if (inheritMode)  typeBuilder = moduleBuilder.DefineType(nameOfType, TypeAttributes.Public, impType);  else  typeBuilder = moduleBuilder.DefineType(nameOfType, TypeAttributes.Public, null, new[] { typeof(TInterface) });  InjectInterceptor<TImp>(typeBuilder, impType.GetCustomAttribute(typeof(InterceptorBaseAttribute))?.GetType(), inheritMode);  var t = typeBuilder.CreateType();  //assembly.Save(nameOfAssembly + ".dll");  return Activator.CreateInstance(t) as TInterface; } private static void InjectInterceptor<TImp>(TypeBuilder typeBuilder, Type interceptorAttributeType, bool inheritMode = false) {  var impType = typeof(TImp);  // ---- define fields ----  FieldBuilder fieldInterceptor = null;  if (interceptorAttributeType != null)  {  fieldInterceptor = typeBuilder.DefineField("_interceptor", interceptorAttributeType, FieldAttributes.Private);  }  // ---- define costructors ----  if (interceptorAttributeType != null)  {  var constructorBuilder = typeBuilder.DefineConstructor(MethodAttributes.Public, CallingConventions.Standard, null);  var ilOfCtor = constructorBuilder.GetILGenerator();  ilOfCtor.Emit(OpCodes.Ldarg_0);  ilOfCtor.Emit(OpCodes.Newobj, interceptorAttributeType.GetConstructor(new Type[0]));  ilOfCtor.Emit(OpCodes.Stfld, fieldInterceptor);  ilOfCtor.Emit(OpCodes.Ret);  }  // ---- define methods ----  var methodsOfType = impType.GetMethods(BindingFlags.Public | BindingFlags.Instance);  string[] ignoreMethodName = new[] { "GetType", "ToString", "GetHashCode", "Equals" };  foreach (var method in methodsOfType)  {  //ignore method  if (ignoreMethodName.Contains(method.Name))   return;  var methodParameterTypes = method.GetParameters().Select(p => p.ParameterType).ToArray();  MethodAttributes methodAttributes;  if (inheritMode)   methodAttributes = MethodAttributes.Public | MethodAttributes.Virtual;  else   methodAttributes = MethodAttributes.Public | MethodAttributes.HideBySig | MethodAttributes.NewSlot | MethodAttributes.Virtual | MethodAttributes.Final;  var methodBuilder = typeBuilder.DefineMethod(method.Name, methodAttributes, CallingConventions.Standard, method.ReturnType, methodParameterTypes);  var ilMethod = methodBuilder.GetILGenerator();  // set local field  var impObj = ilMethod.DeclareLocal(impType);  //instance of imp object  var methodName = ilMethod.DeclareLocal(typeof(string)); //instance of method name  var parameters = ilMethod.DeclareLocal(typeof(object[])); //instance of parameters  var result = ilMethod.DeclareLocal(typeof(object));  //instance of result  LocalBuilder actionAttributeObj = null;  //attribute init  Type actionAttributeType = null;  if (method.GetCustomAttribute(typeof(ActionBaseAttribute)) != null || impType.GetCustomAttribute(typeof(ActionBaseAttribute)) != null)  {   //method can override class attrubute   if (method.GetCustomAttribute(typeof(ActionBaseAttribute)) != null)   {   actionAttributeType = method.GetCustomAttribute(typeof(ActionBaseAttribute)).GetType();   }   else if (impType.GetCustomAttribute(typeof(ActionBaseAttribute)) != null)   {   actionAttributeType = impType.GetCustomAttribute(typeof(ActionBaseAttribute)).GetType();   }   actionAttributeObj = ilMethod.DeclareLocal(actionAttributeType);   ilMethod.Emit(OpCodes.Newobj, actionAttributeType.GetConstructor(new Type[0]));   ilMethod.Emit(OpCodes.Stloc, actionAttributeObj);  }  //instance imp  ilMethod.Emit(OpCodes.Newobj, impType.GetConstructor(new Type[0]));  ilMethod.Emit(OpCodes.Stloc, impObj);  //if no attribute  if (fieldInterceptor != null || actionAttributeObj != null)  {   ilMethod.Emit(OpCodes.Ldstr, method.Name);   ilMethod.Emit(OpCodes.Stloc, methodName);   ilMethod.Emit(OpCodes.Ldc_I4, methodParameterTypes.Length);   ilMethod.Emit(OpCodes.Newarr, typeof(object));   ilMethod.Emit(OpCodes.Stloc, parameters);   // build the method parameters   for (var j = 0; j < methodParameterTypes.Length; j++)   {   ilMethod.Emit(OpCodes.Ldloc, parameters);   ilMethod.Emit(OpCodes.Ldc_I4, j);   ilMethod.Emit(OpCodes.Ldarg, j + 1);   //box   ilMethod.Emit(OpCodes.Box, methodParameterTypes[j]);   ilMethod.Emit(OpCodes.Stelem_Ref);   }  }  //dynamic proxy action before  if (actionAttributeType != null)  {   //load arguments   ilMethod.Emit(OpCodes.Ldloc, actionAttributeObj);   ilMethod.Emit(OpCodes.Ldloc, methodName);   ilMethod.Emit(OpCodes.Ldloc, parameters);   ilMethod.Emit(OpCodes.Call, actionAttributeType.GetMethod("Before"));  }  if (interceptorAttributeType != null)  {   //load arguments   ilMethod.Emit(OpCodes.Ldarg_0);//this   ilMethod.Emit(OpCodes.Ldfld, fieldInterceptor);   ilMethod.Emit(OpCodes.Ldloc, impObj);   ilMethod.Emit(OpCodes.Ldloc, methodName);   ilMethod.Emit(OpCodes.Ldloc, parameters);   // call Invoke() method of Interceptor   ilMethod.Emit(OpCodes.Callvirt, interceptorAttributeType.GetMethod("Invoke"));  }  else  {   //direct call method   if (method.ReturnType == typeof(void) && actionAttributeType == null)   {   ilMethod.Emit(OpCodes.Ldnull);   }   ilMethod.Emit(OpCodes.Ldloc, impObj);   for (var j = 0; j < methodParameterTypes.Length; j++)   {   ilMethod.Emit(OpCodes.Ldarg, j + 1);   }   ilMethod.Emit(OpCodes.Callvirt, impType.GetMethod(method.Name));   //box   if (actionAttributeType != null)   {   if (method.ReturnType != typeof(void))    ilMethod.Emit(OpCodes.Box, method.ReturnType);   else    ilMethod.Emit(OpCodes.Ldnull);   }  }  //dynamic proxy action after  if (actionAttributeType != null)  {   ilMethod.Emit(OpCodes.Stloc, result);   //load arguments   ilMethod.Emit(OpCodes.Ldloc, actionAttributeObj);   ilMethod.Emit(OpCodes.Ldloc, methodName);   ilMethod.Emit(OpCodes.Ldloc, result);   ilMethod.Emit(OpCodes.Call, actionAttributeType.GetMethod("After"));  }  // pop the stack if return void  if (method.ReturnType == typeof(void))  {   ilMethod.Emit(OpCodes.Pop);  }  else  {   //unbox,if direct invoke,no box   if (fieldInterceptor != null || actionAttributeObj != null)   {   if (method.ReturnType.IsValueType)    ilMethod.Emit(OpCodes.Unbox_Any, method.ReturnType);   else    ilMethod.Emit(OpCodes.Castclass, method.ReturnType);   }  }  // complete  ilMethod.Emit(OpCodes.Ret);  } } }

里面實現了兩種代理方式，一種是面向接口實現的方式，另一種是繼承重寫的方式。

但是繼承重寫的方式需要把業務類的所有方法寫成virtual虛方法，動態類會重寫該方法。

我們從上一節的Demo中獲取到運行時生成的代理類dll，用ILSpy反編譯查看源代碼：

AOP,靜態代理,動態代理,Emit