AOP框架Dora.Interception 3.0 [1]: 编程体验
.NET Core正式發布之后，我為.NET Core度身定制的AOP框架Dora.Interception也升級到3.0。這個版本除了升級底層類庫（.NET Standard 2.1）之外，我還對它進行大范圍的重構甚至重新設計。這次重構大部分是在做減法，其目的在于使設計和使用更加簡單和靈活，接下來我們就來體驗一下在一個ASP.NET Core應用程序下如何使用Dora.Interception。
源代碼下載
實例1（Console）
實例2（ASP.NET Core MVC + 注冊可攔截服務）
實例3（ASP.NET Core MVC + 注冊InterceptableServiceProviderFactory）
實例4（ASP.NET Core MVC + 攔截策略）
實例5（ASP.NET Core MVC + 策略腳本化）
一、演示場景
我們依然沿用“緩存”這個應用場景：我們創建一個緩存攔截器，并將其應用到某個方法上。緩存攔截器會將目標方法的返回值緩存起來。在緩存過期之前，提供相同參數列表的方法調用會直接返回緩存的數據，而無需執行目標方法。如下所示是作為緩存鍵類型的CacheKey的定義，可以看出緩存是針對”方法+參數列表”實施緩存的。
private class Cachekey{
public MethodBase Method { get; }
public object[] InputArguments { get; }
public Cachekey(MethodBase method, object[] arguments)
{
Method = method;
InputArguments = arguments;
}
public override bool Equals(object obj)
{
if (!(obj is Cachekey another))
{
return false;
}
if (!Method.Equals(another.Method))
{
return false;
}
for (int index = 0; index < InputArguments.Length; index++)
{
var argument1 = InputArguments[index];
var argument2 = another.InputArguments[index];
if (argument1 == null && argument2 == null)
{
continue;
}
if (argument1 == null || argument2 == null)
{
return false;
}
if (!argument2.Equals(argument2))
{
return false;
}
}
return true;
}
public override int GetHashCode()
{
int hashCode = Method.GetHashCode();
foreach (var argument in InputArguments)
{
hashCode = hashCode ^ argument.GetHashCode();
}
return hashCode;
}
}
二、定義攔截器
作為Dora.Interception區別于其他AOP框架的最大特性，我們注冊的攔截器類型無需實現某個預定義的接口，因為我們采用基于“約定”的攔截器定義方式。基于約定方式定義的緩存攔截器類型CacheInterceptor定義如下。
public class CacheInterceptor{
private readonly IMemoryCache _cache;
private readonly MemoryCacheEntryOptions _options;
public CacheInterceptor(IMemoryCache cache, IOptions<MemoryCacheEntryOptions> optionsAccessor)
{
_cache = cache;
_options = optionsAccessor.Value;
}
public async Task InvokeAsync(InvocationContext context)
{
var key = new Cachekey(context.Method, context.Arguments);
if (_cache.TryGetValue(key, out object value))
{
context.ReturnValue = value;
}
else
{
await context.ProceedAsync();
_cache.Set(key, context.ReturnValue, _options);
}
}
}
按照約定，攔截器類型只需要定義成一個普通的“公共、實例”類型即可。攔截操作需要定義在約定的InvokeAsync方法中，該方法的返回類型為Task，并且包含一個InvocationContext類型的參數。InvocationContext類型封裝了當前方法的調用上下文，我們可以利用它獲取當前的方法和輸入參數等信息。InvocationContext的ReturnValue?屬性表示方法調用的返回結果，CacheInterceptor正式通過設置該屬性從而實現將方法返回值進行緩存的目的。
如上面的代碼片段所示，在InvokeAsync方法中，我們先判斷針對當前的參數參數列表是否具有緩存的結果，如果有的話我們直接將它作為InvocationContext上下文的ReturnValue屬性。如果從緩存中找不到對應的結果，在通過調用InvocationContext上下文的ProceedAsync方法執行目標方法（也可能是后續攔截器），并將新的結果緩存起來。
三、依賴注入
Dora.Interception是為.NET Core度身定制的輕量級AOP框架。由于依賴注入已經成為了.NET Core基本的編程方式，所以Dora.Interception和.NET Core的依賴注入框架進行了無縫整合。正因為如此，當我們在定義攔截器的時候可以將依賴服務直接注入到構造函數中。對于上面定義的CacheInterceptor來說，由于我們直接使用的是.NET Core提供的基于內存的緩存框架，所以我們直接將所需的IMemoryCache 服務和提供配置選項的IOptions<MemoryCacheEntryOptions>?服務注入到構造函數中。
除了構造函數注入，我們還支持針對InvokeAsync方法的“方法注入”。也就是說我們可以將上述的兩個依賴服務以如下的方式注入到InvokeAsync方法中。
public class CacheInterceptor{
public async Task InvokeAsync(InvocationContext context, IMemoryCache cache, IOptions<MemoryCacheEntryOptions> optionsAccessor)
{
var key = new Cachekey(context.Method, context.Arguments);
if (cache.TryGetValue(key, out object value))
{
context.ReturnValue = value;
}
else
{
await context.ProceedAsync();
cache.Set(key, context.ReturnValue, optionsAccessor.Value);
}
}
}
針對攔截器類型的兩種依賴注入方式并不是等效的，它們之間的差異體現在服務實例的生命周期上。由于攔截器對象自身屬于一個Singleton服務，所以我們不能在它的構造函數中注入一個Scoped服務，否則依賴服務將不能按照期望的方式被釋放。Scoped服務只能注入到InvokeAsync方法中，因為該方法注入的服務實例是根據當前Scope的IServiceProvider提供的（對于ASP.NET Core應用來說，就是當前HttpContext上下文的RequestServices）。
四、注冊攔截器
AOP的本質對方法調用進行攔截，并在調用目標方法之前執行應用的攔截器，所以我們定義的攔截器最終需要注冊到一個或者多個方法上。Dora.Interception刻意將“攔截器”和“攔截器注冊”分離開來，因為攔截器具有不同的注冊方式。
在類型或者方法上標注特性是我們常用的攔截器注冊方式，為此我們為CacheInterceptor定義了如下這個CacheReturnValueAttribute。CacheReturnValueAttribute繼承自抽象類型InterceptorAttribute，在重寫的Use方法中，我們只需要調用作為參數的IInterceptorChainBuilder對象的Use<TInterceptor>方法將指定的攔截器添加到攔截器鏈條（同一個方法上可能同時應用多個攔截器）。
[AttributeUsage(AttributeTargets.Method)]public class CacheReturnValueAttribute : InterceptorAttribute
{
public override void Use(IInterceptorChainBuilder builder)
{
builder.Use<CacheInterceptor>(Order);
}
}
Use<TInterceptor>方法的泛型參數表示對應攔截器的類型，它的第一個參數表示指定的攔截器在整個鏈條上的位置。這個值就是InterceptorAttribute的Order屬性值。如果攔截器類型構造函數中定義了一些無法通過依賴注入框架提供的參數，我們在調用Use<TInterceptor>方法時可以利用后面的params參數來指定。
如果你覺得將攔截器類型和對應的特性分開定義比較煩，也可以將兩者合二為一，我們只需要將InvokeAsync方法按照如下的方式轉移到InterceptorAttribute類型中就可以了。由于它自身就是一個攔截器，我們在Use方法中會調用IInterceptorChainBuilder對象非泛型Use方法，并將自身作為第一個參數。
[AttributeUsage(AttributeTargets.Method)]public class CacheReturnValueAttribute : InterceptorAttribute
{
public async Task InvokeAsync(InvocationContext context, IMemoryCache cache, IOptions<MemoryCacheEntryOptions> optionsAccessor)
{
var key = new Cachekey(context.Method, context.Arguments);
if (cache.TryGetValue(key, out object value))
{
context.ReturnValue = value;
}
else
{
await context.ProceedAsync();
cache.Set(key, context.ReturnValue, optionsAccessor.Value);
}
}
public override void Use(IInterceptorChainBuilder builder)
{
builder.Use(this, Order);
}
}
為了能夠很直觀地看到針對方法返回值的緩存，我們定義了如下這個表示系統時鐘的ISystemClock的服務接口。該接口具有唯一的GetCurrentTime方法返回當前的時間，方法參數用于控制行為方法的時間類型（UTC或者Local）。實現類型SystemClock標注了我們定義的InterceptorAttribute特性。
public interface ISystemClock{
DateTime GetCurrentTime(DateTimeKind dateTimeKind);
}
public class SystemClock : ISystemClock
{
[CacheReturnValue(Order = 1)]
public DateTime GetCurrentTime(DateTimeKind dateTimeKind)
{
return dateTimeKind switch
{
DateTimeKind.Local => DateTime.UtcNow.ToLocalTime(),
DateTimeKind.Unspecified => DateTime.Now,
_ => DateTime.UtcNow,
};
}
}
五、注冊可被攔截的服務
接下來我們在一個ASP.NET Core MVC應用中演示針對ISystemClock服務提供時間的緩存。如下所示的是應用承載程序和注冊Startup類型的定義。為了讓依賴注入框架提供的ISystemClock服務是可以被攔截的，我們調用了IServiceCollection接口的AddSingletonInterceptable<TService, TImplementation>擴展方法。由于CacheInterceptor利用.NET Core內存緩存框架來存儲方法返回值，所以我們還調用了AddMemoryCache擴展方法注冊了相關服務。
public class Program{
public static void Main(string[] args)
{
Host.CreateDefaultBuilder()
.ConfigureWebHostDefaults(buider => buider.UseStartup<Startup>())
.Build()
.Run();
}
}
public class Startup
{
public void ConfigureServices(IServiceCollection services)
{
services
.AddMemoryCache()
.AddInterception()
.AddSingletonInterceptable<ISystemClock, SystemClock>()
.AddRouting()
.AddControllers();
}
public void Configure(IApplicationBuilder app)
{
app
.UseRouting()
.UseEndpoints(endpoints => endpoints.MapControllers());
}
}
我們定義了如下這個HomeController，并在其構造函數中注入了ISystemClock服務。在Action方法Index中，我們利用ISystemClock服務在1秒時間間隔內兩次提供當前時間，并將這兩個時間呈現在瀏覽器上。調用ISystemClock的GetCurrentTime方法指定的時間類型（UTC或者Local）是利用查詢字符串提供的。
public class HomeController : Controller{
private readonly ISystemClock _clock;
public HomeController(ISystemClock clock)
{
_clock = clock ?? throw new ArgumentNullException(nameof(clock));
}
[HttpGet("/{kind?}")]
public async Task Index(string kind="local")
{
DateTimeKind dateTimeKind = string.Compare(kind, "utc", true) == 0
? DateTimeKind.Utc
: DateTimeKind.Local;
Response.ContentType = "text/html";
await Response.WriteAsync("<html><body><ul>");
for (int i = 0; i < 2; i++)
{
await Response.WriteAsync($"<li>{_clock.GetCurrentTime(dateTimeKind)}</li>");
await Task.Delay(1000);
}
await Response.WriteAsync("</ul><body></html>");
}
}
運行程序后，我們利用瀏覽器對定義在HomeController中的Action方法Index發起請求。如下圖所示，由于緩存的存在，只要指定的時間類型一樣，返回的時間就是一樣的。
六、保留現有的服務注冊方式
在上面的示例演示中，為了讓依賴注入框架提供的ISystemClock服務能夠被攔截，我們不得不調用自定義的AddSingletonInterceptable<TService, TImplementation>擴展方法擴展方法來注冊服務。如果你不喜歡這種方式，我們還提供了另一種解決方案，那就是按照如下的方式調用IHostBuilder的UseInterceptableServiceProvider擴展方法注冊我們自定義的InterceptableServiceProviderFactory。
public class Program{
public static void Main(string[] args)
{
Host.CreateDefaultBuilder()
.UseInterceptableServiceProvider()
.ConfigureWebHostDefaults(buider => buider.UseStartup<Startup>())
.Build()
.Run();
}
}
一旦我們按照上面的代碼完成了針對InterceptableServiceProviderFactory的注冊之后，我們將可以將針對ISystemClock服務的注冊還原成我們熟悉的方式。
public class Startup{
public void ConfigureServices(IServiceCollection services)
{
services
.AddMemoryCache()
.AddInterception()
.AddSingleton<ISystemClock, SystemClock>()
.AddRouting()
.AddControllers();
}
public void Configure(IApplicationBuilder app)
{
app
.UseRouting()
.UseEndpoints(endpoints => endpoints.MapControllers());
}
}
七、基于策略的攔截器注冊方式
Dora.Interception提供了擴展點使我們可以實現任意的攔截器注冊方式。除了默認提供的針對“特性標注”的方式之外，我們還提供了一種針對策略的注冊方式。這里的策略旨在提供這樣的表達：將某種類型的攔截器應用到某個類型的某個方法或者屬性上。如果我們沒有將CacheReturnValueAttribute特性標注到SystemClock的GetCurrentTime方法上，我們可以將承載程序修改成如下的形式。
public class Program{
public static void Main(string[] args)
{
Host.CreateDefaultBuilder()
.UseInterceptableServiceProvider(configure: Configure)
.ConfigureWebHostDefaults(buider => buider.UseStartup<Startup>())
.Build()
.Run();
static void Configure(InterceptionBuilder interceptionBuilder)
{
interceptionBuilder.AddPolicy(policyBuilder => policyBuilder
.For<CacheReturnValueAttribute>(order: 1, cache => cache
.To<SystemClock>(target => target
.IncludeMethod(clock => clock.GetCurrentTime(default)))));
}
}
}
如上面的代碼片段所示，我們在調用IHostBuilder的UseInterceptableServiceProvider擴展方法的時候指定了一個Action<InterceptionBuilder>對象，它通過調用InterceptionBuilder 對象的AddPolicy擴展方法通過明確的語義將CacheReturnValueAttribute應用到SystemClock的GetCurrentTime方法上。由于不論是指定類型還是方法都是采用“強類型”的方式，所以有效避免了出錯的可能性。
八、策略腳本化
如果希望在不修改現有程序代碼的前提下自由的修改攔截策略，我們可以將策略腳本化。在這里我們使用的腳本語言就是C#，所以我們可以將上面提供的策略代碼放在一個C#腳本中。比如我們在根目錄下創建一個interception.dora文件，并在其中定義如下的策略。
policyBuilder.For<CacheReturnValueAttribute>(1, cache => cache
.To<SystemClock>(clock => clock
.IncludeMethod(it => it.GetCurrentTime(default))));
為了使用這個策略腳本，我們需要對承載程序作相應修改。如下面的代碼片段所示，我們同樣調用了InterceptionBuilder 的AddPolicy方法，但是這次我們指定的是策略腳本文件名。為了能夠識別腳本文件中的類型，我們提供了一個Action<PolicyFileBuilder>對象，并調用PolicyFileBuilder的AddReferences方法添加了程序集引用，調用AddImports方法導入了命名空間。
public class Program{
public static void Main(string[] args)
{
Host.CreateDefaultBuilder()
.UseInterceptableServiceProvider(configure: Configure)
.ConfigureWebHostDefaults(buider => buider.UseStartup<Startup>())
.Build()
.Run();
static void Configure(InterceptionBuilder interceptionBuilder)
{
interceptionBuilder.AddPolicy("Interception.dora", script => script
.AddReferences(Assembly.GetExecutingAssembly())
.AddImports("App"));
}
}
}
總結
以上是生活随笔為你收集整理的AOP框架Dora.Interception 3.0 [1]: 编程体验的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Magicodes.IE已支持导出Wor
- 下一篇： BeetleX之FastHttpApi服