.NET?Core?使用委托實(shí)現(xiàn)動(dòng)態(tài)流程組裝的思路詳解
引言
在看.NET Core 源碼的管道模型中間件(Middleware)部分,覺(jué)得這個(gè)流程組裝,思路挺好的,于是就分享給大家。本次代碼實(shí)現(xiàn)就直接我之前寫(xiě)的動(dòng)態(tài)代理實(shí)現(xiàn)AOP的基礎(chǔ)上改的,就不另起爐灶了,主要思路就是運(yùn)用委托。對(duì)委托不理解的可留言,我寫(xiě)一篇委托的常規(guī)使用方式,以及底層原理(編譯器)的文章

沒(méi)看過(guò)上一章的,我這里大家給貼一下地址:.NET Core 實(shí)現(xiàn)動(dòng)態(tài)代理做AOP(面向切面編程)
接下來(lái)進(jìn)入正題
1.定義接口IInterceptor
定義好我們AOP需要實(shí)現(xiàn)的接口,不同職責(zé)可以定義不同接口,大家根據(jù)實(shí)際情況劃分
internal interface IInterceptor
{
}
internal interface IInterceptorAction : 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.定義特性
這里只定義一個(gè)基類(lèi)特性類(lèi),繼承標(biāo)記接口,用于設(shè)置共通配置,且利于后面反射查找
[AttributeUsage(AttributeTargets.Class)]
internal class BaseInterceptAttribute : Attribute, IInterceptor
{
}3.編寫(xiě)生成代理類(lèi)的邏輯
只需要繼承.NET CORE 原生DispatchProxy類(lèi),重寫(xiě)相關(guān)業(yè)務(wù)代碼
3.1 編寫(xiě)創(chuàng)建代理方法
編寫(xiě)一個(gè)我們自己的Create方法(),這兩個(gè)參數(shù)為了后面調(diào)用目標(biāo)類(lèi)儲(chǔ)備的,方法實(shí)現(xiàn)就只需要調(diào)用DispatchProxy類(lèi)的Create()
internal class DynamicProxy<T> : DispatchProxy
{
public T Decorated { get; set; }//目標(biāo)類(lèi)
public IEnumerable<IInterceptorAction> Interceptors { get; set; } // AOP動(dòng)作
/// <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, IEnumerable<IInterceptor> interceptors)
{
object proxy = Create<T, DynamicProxy<T>>(); // 調(diào)用DispatchProxy 的Create 創(chuàng)建一個(gè)代理實(shí)例
DynamicProxy<T> proxyDecorator = (DynamicProxy<T>)proxy;
proxyDecorator.Decorated = decorated;
proxyDecorator.Interceptors = interceptors.Where(c=>c.GetType().GetInterface(typeof(IInterceptorAction).Name) == typeof(IInterceptorAction)).Select(c=>c as IInterceptorAction);
return (T)proxy;
}3.2 重寫(xiě)Invoke方法
這個(gè)就是需要實(shí)現(xiàn)我們自己的業(yè)務(wù)了,大家看注釋?xiě)?yīng)該就能看懂個(gè)大概了,目前這里只處理了IInterceptorAction接口邏輯,比如異常、異步等等,自己可按需實(shí)現(xiàn)。而流程組裝的精髓就三步
1.不直接去執(zhí)行targetMethod.Invoke(),而是把它放到委托里面。
2.定義AssembleAction()方法來(lái)組裝流程,方法里面也不執(zhí)行方法,也是返回一個(gè)執(zhí)行方法的委托。
3.循環(huán)事先在Create()方法存儲(chǔ)的特性實(shí)例,調(diào)用AssembleAction()方法組裝流程,這樣就達(dá)到俄羅斯套娃的效果了。
protected override object? Invoke(MethodInfo? targetMethod, object?[]? args)
{
Exception exception = null;//由委托捕獲變量,用來(lái)存儲(chǔ)異常
Func<object?[]?, object?> action = (args) =>
{
try
{
return targetMethod?.Invoke(Decorated, args);
}
catch (Exception ex)//捕獲異常,不影響AOP繼續(xù)執(zhí)行
{
exception = ex;
}
return null;
};
//進(jìn)行倒序,使其按照由外置內(nèi)的流程執(zhí)行
foreach (var c in Interceptors.Reverse())
{
action = AssembleAction(action, c);
}
//執(zhí)行組裝好的流程
var result = action?.Invoke(args);
//如果方法有異常拋出異常
if (exception != null)
{
throw exception;
}
return result;
}
private Func<object?[]?, object?>? AssembleAction(Func<object?[]?, object?>? action, IInterceptorAction c)
{
return (args) =>
{
//執(zhí)行之前的動(dòng)作
AfterAction(c.AfterAction, args);
var result = action?.Invoke(args);
//執(zhí)行之后的動(dòng)作
BeforeAction(c.BeforeAction, args, result);
return result;
};
}
private void AfterAction(Action<object?[]?> action, object?[]? args)
{
try
{
action(args);
}
catch (Exception ex)
{
Console.WriteLine($"執(zhí)行之前異常:{ex.Message},{ex.StackTrace}");
}
}
private void BeforeAction(Action<object?[]?, object?> action, object?[]? args, object? result)
{
try
{
action(args, result);
}
catch (Exception ex)
{
Console.WriteLine($"執(zhí)行之后異常:{ex.Message},{ex.StackTrace}");
}
}
}
4.定義一個(gè)工廠(chǎng)
工廠(chǎng)用于專(zhuān)門(mén)來(lái)為我們創(chuàng)建代理類(lèi),邏輯很簡(jiǎn)單,后續(xù)大家也可以按需編寫(xiě),目前邏輯就是利用反射獲取目標(biāo)類(lèi)的特性,把參數(shù)組裝起來(lái)。
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.GetCustomAttributes<BaseInterceptAttribute>();
//創(chuàng)建代理類(lèi)
var proxy = new DynamicProxy<T>().Create(decorated, interceptAttribut);
return proxy;
}
}5.定義ServiceHelp
這個(gè)是為了使得我們?nèi)种挥靡粋€(gè)作用域的IOC容器
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>();
}
}6.測(cè)試
6.1 編程AOP實(shí)現(xiàn)
寫(xiě)兩個(gè)特性實(shí)現(xiàn),繼承基類(lèi)特性,實(shí)現(xiàn)Action接口邏輯,測(cè)試兩個(gè)特性隨意調(diào)換位置進(jìn)行組裝流程
internal class AOPTest1Attribut : BaseInterceptAttribute, IInterceptorAction
{
public void AfterAction(object?[]? args)
{
Console.WriteLine($"AOP1方法執(zhí)行之前,args:{args[0] + "," + args[1]}");
// throw new Exception("異常測(cè)試(異常,但依然不能影響程序執(zhí)行)");
}
public void BeforeAction(object?[]? args, object? result)
{
Console.WriteLine($"AOP1方法執(zhí)行之后,result:{result}");
}
}
internal class AOPTest2Attribut : BaseInterceptAttribute, IInterceptorAction
{
public void AfterAction(object?[]? args)
{
Console.WriteLine($"AOP2方法執(zhí)行之前,args:{args[0] + "," + args[1]}");
}
public void BeforeAction(object?[]? args, object? result)
{
Console.WriteLine($"AOP2方法執(zhí)行之后,result:{result}");
}
}6.2 編寫(xiě)測(cè)試服務(wù)
寫(xiě)一個(gè)簡(jiǎn)單的測(cè)試服務(wù),就比如兩個(gè)整數(shù)相加,然后標(biāo)記上我們寫(xiě)的AOP特性
internal interface ITestService
{
public int Add(int a, int b);
}
[AOPTest2Attribut]
[AOPTest1Attribut]
internal class TestService : ITestService
{
public int Add(int a, int b)
{
Console.WriteLine($"正在執(zhí)行--》Add({a},)");
//throw new Exception("方法執(zhí)行--》測(cè)試異常");
return a + b;
}
}6.3 調(diào)用
1.把服務(wù)注冊(cè)到IOC
2.調(diào)用創(chuàng)建代理類(lèi)的工廠(chǎng)
3.調(diào)用測(cè)試服務(wù)函數(shù):.Add(1, 2)
IServiceCollection serviceCollection = new ServiceCollection(); serviceCollection.AddTransient<ITestService, TestService>(); ServiceHelp.BuildServiceProvider(serviceCollection); //用工廠(chǎng)獲取代理實(shí)例 var s = ProxyFactory.Create<ITestService>(); var sum = s.Add(1, 2);
6.4 效果圖
AOP1->AOP2->Add(a,b)

AOP2->AOP1->Add(a,b)

代碼上傳至gitee,AOP流程組裝分支:https://gitee.com/luoxiangbao/dynamic-proxy.git
到此這篇關(guān)于.NET Core 利用委托實(shí)現(xiàn)動(dòng)態(tài)流程組裝的文章就介紹到這了,更多相關(guān).NET Core動(dòng)態(tài)流程組裝內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
解決.Net Core項(xiàng)目發(fā)布在IIS上訪(fǎng)問(wèn)404的問(wèn)題
這篇文章介紹了解決.Net Core項(xiàng)目發(fā)布在IIS上訪(fǎng)問(wèn)404的問(wèn)題,對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-12-12
ASP.NET session.timeout設(shè)置案例詳解
這篇文章主要介紹了ASP.NET session.timeout設(shè)置案例詳解,本篇文章通過(guò)簡(jiǎn)要的案例,講解了該項(xiàng)技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下2021-08-08
ASP.NET Core優(yōu)雅的在開(kāi)發(fā)環(huán)境保存機(jī)密(User Secrets)
這篇文章主要為大家詳細(xì)介紹了ASP.NET Core如何優(yōu)雅的在開(kāi)發(fā)環(huán)境保存機(jī)密User Secrets,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-05-05
Asp.net Core 初探(發(fā)布和部署Linux)
這篇文章主要介紹了Asp.net Core 初探(發(fā)布和部署Linux),小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2016-12-12
[譯]ASP.NET Core 2.0 網(wǎng)址重定向的方法
本篇文章主要介紹了[譯]ASP.NET Core 2.0 網(wǎng)址重定向的方法,小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-10-10
ASP.NET MVC5網(wǎng)站開(kāi)發(fā)用戶(hù)修改資料和密碼(六)
這篇文章主要介紹了ASP.NET MVC5網(wǎng)站開(kāi)發(fā)用戶(hù)修改資料和密碼,本文即將結(jié)束member區(qū)域的用戶(hù)部分,感興趣的小伙伴們可以參考一下2015-09-09
ASP.NET怎么操作DataTable實(shí)例應(yīng)用
有機(jī)會(huì)在博客園的博問(wèn)頻道上看到一個(gè)問(wèn)題,《ASP.NET怎么操作DataTable》;需要的朋友可以參考下2012-11-11

