.NET Core利用動(dòng)態(tài)代理實(shí)現(xiàn)AOP(面向切面編程)

更新時(shí)間：2022年01月11日 16:04:10 作者：極客Bob

用動(dòng)態(tài)代理可以做AOP（面向切面編程），進(jìn)行無(wú)入侵式實(shí)現(xiàn)自己的擴(kuò)展業(yè)務(wù)，調(diào)用者和被調(diào)用者之間的解耦，提高代碼的靈活性和可擴(kuò)展性。本文將為大家詳細(xì)介紹實(shí)現(xiàn)的方法，感興趣的可以學(xué)習(xí)一下

1.介紹

1.1 動(dòng)態(tài)代理作用

用動(dòng)態(tài)代理可以做AOP（面向切面編程），進(jìn)行無(wú)入侵式實(shí)現(xiàn)自己的擴(kuò)展業(yè)務(wù)，調(diào)用者和被調(diào)用者之間的解耦，提高代碼的靈活性和可擴(kuò)展性，比如：日志記錄、性能統(tǒng)計(jì)、安全控制、事務(wù)處理、異常處理等等。本方式實(shí)現(xiàn)思路用的.NET Core原生的DispatchProxy類(lèi)，再加《特性標(biāo)記》+《Handle接口》達(dá)到無(wú)入侵式擴(kuò)展，有興趣的朋友，自行改進(jìn)一下，封裝成組件。

有什么做的不好的或者建議，希望大家及時(shí)提出，幫助改進(jìn)。

代碼上傳在gitee：https://gitee.com/luoxiangbao/dynamic-proxy.git

1.2 原生DispatchProxy類(lèi)介紹

DispatchProxy我去看了一下源碼，和我設(shè)想的差不多，就是Emit類(lèi)庫(kù)直接編寫(xiě)IL語(yǔ)言，動(dòng)態(tài)生成類(lèi)和方法，然后在方法里調(diào)用Invoke方法，這個(gè)時(shí)候就我們只需要重寫(xiě)Invoke方法，具體實(shí)現(xiàn)由我們自己管控。其性能很高，幾乎和我們寫(xiě)好的C#編譯成IL沒(méi)多大區(qū)別，大家用的Autofac的AOP，我也看了一下，底層用的是Castle.Core類(lèi)庫(kù)，而Castle.Core底層還是用的Emit方式實(shí)現(xiàn)，只是思路不同。

便于理解我給大家貼一下源碼：

1.定義抽象DispatchProxy類(lèi)的Invoke元數(shù)據(jù)

2.Emit類(lèi)庫(kù)直接編寫(xiě)IL語(yǔ)言，為代理類(lèi)添加調(diào)用Invoke方法代碼

1.3簡(jiǎn)單介紹一下：IL代碼

IL是.NET框架中間語(yǔ)言（Intermediate Language），編譯器可以直接將源程序編譯為.exe或.dll文件，而CLR(公共語(yǔ)言運(yùn)行時(shí))執(zhí)行的是IL語(yǔ)言，不是C#高級(jí)編程語(yǔ)言，IL代碼是一種近似于指令式的代碼語(yǔ)言，與匯編語(yǔ)言比較相近，給大家做個(gè)案例對(duì)比一下。

C#代碼：

class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("Hello World!");
        }
    }

IL代碼：

IL_0000:  nop
IL_0001:  ldstr      "Hello World!"
IL_0006:  call       void [System.Console]System.Console::WriteLine(string)
IL_000b:  nop
IL_000c:  ret

有興趣的朋友自己也可以去實(shí)現(xiàn)。接下來(lái)進(jìn)入正題，我們?cè)趺蠢肈ispatchProxy自己造輪子！?。?/p>

2.實(shí)現(xiàn)

2.1 繼承DispatchProxy

核心類(lèi)就是，DispatchProxy。這是.NET core 原生的。會(huì)幫我們創(chuàng)建一個(gè)代理類(lèi)

internal class DynamicProxy<T> : DispatchProxy
    {
        public T? decorated { get; set; }//目標(biāo)類(lèi)
        public Action<object?[]?>? _afterAction { get; set; }  // 動(dòng)作之后執(zhí)行
        public Action<object?[]?, object>? _beforeAction { get; set; } // 動(dòng)作之前執(zhí)行
        protected override object? Invoke(MethodInfo? targetMethod, object?[]? args)
        {
            Exception exception = null;
            AfterAction(args);
            object result = null;
            try
            {
                //調(diào)用實(shí)際目標(biāo)對(duì)象的方法
                result = targetMethod?.Invoke(decorated, args);
            }
            catch (Exception ex)
            {
                exception = ex;
            }
            BeforeAction(args, result);
            //調(diào)用完執(zhí)行方法后的委托，如果有異常，拋出異常
            if (exception != null)
            {
                throw exception;
            }
            return result;
        }

        /// <summary>
        /// 創(chuàng)建代理實(shí)例
        /// </summary>
        /// <param name="decorated">代理的接口類(lèi)型</param>
        /// <param name="afterAction">方法執(zhí)行前執(zhí)行的事件</param>
        /// <param name="beforeAction">方法執(zhí)行后執(zhí)行的事件</param>
        /// <returns></returns>
        public T Create(T decorated, Action<object?[]?> afterAction, Action<object?[]?, object> beforeAction)
        {
            object proxy = Create<T, DynamicProxy<T>>(); // 調(diào)用DispatchProxy 的Create  創(chuàng)建一個(gè)新的T
            DynamicProxy<T> proxyDecorator = (DynamicProxy<T>)proxy;
            proxyDecorator.decorated = decorated;
            //把自定義的方法委托給代理類(lèi)
            proxyDecorator._afterAction = afterAction;
            proxyDecorator._beforeAction = beforeAction;
            return (T)proxy;
        }


        private void AfterAction(object?[]? args)
        {
            try
            {
                _afterAction.Invoke(args);
            }
            catch (Exception ex)
            {
                Console.WriteLine($"執(zhí)行之前異常：{ex.Message}，{ex.StackTrace}");
            }
        }

        private void BeforeAction(object?[]? args, object? result)
        {
            try
            {
                _beforeAction.Invoke(args, result);
            }
            catch (Exception ex)
            {
                Console.WriteLine($"執(zhí)行之后異常：{ex.Message}，{ex.StackTrace}");
            }
        }


    }

2.2 定義handle接口

這個(gè)接口定義：執(zhí)行之前、執(zhí)行之后兩個(gè)方法。用來(lái)實(shí)現(xiàn)具體業(yè)務(wù)邏輯的處理

internal interface IInterceptor
    {
        /// <summary>
        /// 執(zhí)行之前
        /// </summary>
        /// <param name="args">參數(shù)</param>
        void AfterAction(object?[]? args);


        /// <summary>
        /// 執(zhí)行之后
        /// </summary>
        /// <param name="args">參數(shù)</param>
        /// <param name="result">結(jié)果</param>
        void BeforeAction(object?[]? args, object result);
    }

2.3 定義AOP特性

1.用來(lái)標(biāo)記類(lèi)具體使用哪個(gè)handle的實(shí)現(xiàn)來(lái)處理業(yè)務(wù)。

2. 特性定義Type屬性決定創(chuàng)建代理類(lèi)的時(shí)候，具體使用哪個(gè)handle實(shí)現(xiàn)

[AttributeUsage(AttributeTargets.Class)]
    internal class InterceptAttribut : Attribute
    {
        public Type Type { get; set; }
        public InterceptAttribut(Type type) 
        {
            this.Type = type;
        }
    }

2.4 定義創(chuàng)建代理類(lèi)的工廠

這里就是來(lái)組裝代理類(lèi)與handle實(shí)現(xiàn)的地方。

internal class ProxyFactory
    {

        /// <summary>
        /// 創(chuàng)建代理實(shí)例
        /// </summary>
        /// <param name="decorated">代理的接口類(lèi)型</param>
        /// <returns></returns>
        public static T Create<T>()
        {
            var decorated = ServiceHelp.GetService<T>();
            var type = decorated.GetType();
            var interceptAttribut = type.GetCustomAttribute<InterceptAttribut>();
            var interceptor = ServiceHelp.GetService<IInterceptor>(interceptAttribut.Type);
            //創(chuàng)建代理類(lèi)
            var proxy = new DynamicProxy<T>().Create(decorated, interceptor.AfterAction, interceptor.BeforeAction);
            return proxy;
        }

    }

1.拿到具體類(lèi)，獲取Type，獲取我們上面定義的特性，通過(guò)特性的屬性，用來(lái)創(chuàng)建handle實(shí)例

2.ServiceHelp是我定義的一個(gè)來(lái)獲取實(shí)例化的容器幫助類(lèi)。這個(gè)用.NET CORE 原始的IOC。大家可替換成autofac

3.創(chuàng)建化代理實(shí)例，把實(shí)例和handle實(shí)現(xiàn)的具體方法：AfterAction、BeforeAction傳入。用于代理類(lèi)執(zhí)行的時(shí)候，進(jìn)行真正的調(diào)用

2.5 定義ServiceHelp

這里大家可自行發(fā)揮

public static class ServiceHelp
    {

        public static IServiceProvider? serviceProvider { get; set; }

        public static void BuildServiceProvider(IServiceCollection serviceCollection)
        {
            //構(gòu)建容器
            serviceProvider = serviceCollection.BuildServiceProvider();
        }

        public static T GetService<T>(Type serviceType)
        {
            return (T)serviceProvider.GetService(serviceType);
        }

        public static T GetService<T>()
        {
            return serviceProvider.GetService<T>();
        }
    }

3.測(cè)試

3.1 定義handle實(shí)現(xiàn)

    internal class AOPTest : IInterceptor
    {
        public void AfterAction(object?[]? args)
        {
            Console.WriteLine($"AOP方法執(zhí)行之前，args：{args}");
            throw new Exception("異常測(cè)試（異常，但依然不能影響程序執(zhí)行）");
        }

        public void BeforeAction(object?[]? args, object result)
        {
            Console.WriteLine($"AOP方法執(zhí)行之后，args：{args}，result：{result}");
        }
    }

3.2 定義Service接口

    internal interface ITestService
    {
        public int Add(int a, int b);
    }

3.3實(shí)現(xiàn)Service接口

定義實(shí)現(xiàn)，并且在類(lèi)上加上，AOP交給哪個(gè)handle

    [InterceptAttribut(typeof(AOPTest))]
    internal class TestService : ITestService
    {
        public int Add(int a, int b)
        {
            Console.WriteLine($"正在執(zhí)行--》Add({a},)");
            throw new Exception("方法執(zhí)行--》測(cè)試異常");
            return a + b;
        }
    }

3.4 大功告成

1.創(chuàng)建容器，把我們自己的業(yè)務(wù)實(shí)現(xiàn)都注冊(cè)好

2.通過(guò)工廠進(jìn)行，動(dòng)態(tài)創(chuàng)建代理實(shí)例

// See https://aka.ms/new-console-template for more information
using Infrastructure.DynamicProxy;
using Microsoft.Extensions.DependencyInjection;

Console.WriteLine("Hello, World!");
//容器注冊(cè)
IServiceCollection serviceCollection = new ServiceCollection();
serviceCollection.AddTransient(typeof(AOPTest));
serviceCollection.AddTransient<ITestService, TestService>();
//構(gòu)建容器
ServiceHelp.BuildServiceProvider(serviceCollection);
//用工廠獲取代理實(shí)例
var s = ProxyFactory.Create<ITestService>();
var sum = s.Add(1, 2);
Console.WriteLine("執(zhí)行完畢=====>" + sum);