.NET Core依賴注入集成Dynamic Proxy


在《Castle DynamicProxy基本用法》中介紹了如何將DP與Autofac集成使用,而 .NET Core有自己的依賴注入容器,在不依賴第三方容器的基礎上,如何實現動態代理就成了一個問題。

.NET Core依賴注入實現動態代理

我們知道,要創建一個代理對象,需要簡單的三步:

  • 創建Target
  • 創建Interceptor
  • 使用Target和Interceptor創建代理對象

.NET Core的依賴注入允許我們自定義ServiceDescriptor對象,而在ServiceDescriptor對象中,我們可以定義對象實例化的過程,這個過程叫做factory,通過自定義factory,我們可以類型的動態代理的創建。

代碼如下:

services.AddTransient<LoggingInterceptor>();
services.AddTransient<SampleService>();

services.AddTransient<ISampleService>(provider =>
{
    var target = provider.GetService<SampleService>();
    var loggingInterceptor = provider.GetService<LoggingInterceptor>();
    var proxy = DynamicProxyExtensions.Generator.CreateInterfaceProxyWithTarget<ISampleService>(target, loggingInterceptor);

    return proxy;
});

或者通過實例化ServiceDescriptor的方式進行注入:

services.AddTransient<LoggingInterceptor>();
services.AddTransient<SampleService>();

Func<IServiceProvider, object> factory = (provider) => {
    var target = provider.GetService<SampleService>();
    var loggingInterceptor = provider.GetService<LoggingInterceptor>();
    var auditInterceptor = provider.GetService<AuditInterceptor>().ToInterceptor();
    var proxy = DynamicProxyExtensions.Generator.CreateInterfaceProxyWithTarget<ISampleService>(target, loggingInterceptor, auditInterceptor);

    return proxy;
};
var serviceDescriptor = new ServiceDescriptor(typeof(ISampleService), factory, ServiceLifetime.Transient);

services.Add(serviceDescriptor);

通過這種方式,我們可以將動態代理與依賴注入結合起來。但是這樣的代碼缺少封裝,開發效率偏低,在使用過程中還需要對依賴注入、動態代理都有一定了解,為了解決這些問題,我們需要再次封裝。

依賴注入與動態代理的簡單封裝

public static class DependencyInjectionExtensions
{
    public static IServiceCollection AddService<TService, TImplementation>(this IServiceCollection services,
        ServiceLifetime lifetime, params Type[] interceptorTypes)
    {
        return services.AddService(typeof(TService), typeof(TImplementation), lifetime, interceptorTypes);
    }

    public static IServiceCollection AddService(this IServiceCollection services, Type serviceType, Type implType,
        ServiceLifetime lifetime, params Type[] interceptorTypes)
    {
        services.Add(new ServiceDescriptor(implType, implType, lifetime));
        
        Func<IServiceProvider, object> factory = (provider) =>
        {
            var target = provider.GetService(implType);

            List<IInterceptor> interceptors = interceptorTypes.ToList().ConvertAll<IInterceptor>(interceptorType =>
            {
                return provider.GetService(interceptorType) as IInterceptor;
            });

            var proxy = DynamicProxyExtensions.Generator.CreateInterfaceProxyWithTarget(serviceType, target, interceptors.ToArray());

            return proxy;
        };
        var serviceDescriptor = new ServiceDescriptor(serviceType, factory, lifetime);
        services.Add(serviceDescriptor);

        return services;
    }
}

在使用時需要注意,一定要先將Interceptor類注入到容器中。


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM