脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → C#教程 → C# 使用 Castle 实现 AOP

C# 使用 Castle 实现 AOP及如何用 Autofac 集成 Castle

 更新时间：2021年02月25日 10:29:15   作者：丹枫无迹  
这篇文章主要介绍了C# 使用 Castle 实现 AOP及如何用 Autofac 集成 Castle，帮助大家更好的理解和学习使用c#，感兴趣的朋友可以了解下

Castle 是 2003 年诞生于 Apache Avalon 项目，目的是为了创建一个IOC 框架。发展到现在已经有四个组件：

  • ORM组件：ActiveRecord
  • IOC组件：Windsor
  • 动态代理组件：DynamicProxy
  • Web MVC组件：MonoRail

本文主要介绍 动态代理组件 Castle.DynamicProxy

基本用法

Castle.DynamicProxy 是通过 Emit 反射动态生成代理类来实现的，效率相对静态植入要慢一点，但比普通的反射又高一些。动态代理只对公共接口方法、类中的虚方法生效，因为只有接口中的方法、类中的虚方法才可以在子类中重写。

基于接口的拦截器

public interface IProductRepository
{
 void Add(string name);
}

public class ProductRepository : IProductRepository
{
 public void Add(string name) => Console.WriteLine($"新增产品：{name}");
}

public class LoggerInterceptor : IInterceptor
{
 public void Intercept(IInvocation invocation)
 {
  var methodName = invocation.Method.Name;

  Console.WriteLine($"{methodName} 执行前");

  //调用业务方法
  invocation.Proceed();

  Console.WriteLine($"{methodName} 执行完毕");
 }
}

class Program
{
 static void Main(string[] args)
 {
  ProxyGenerator generator = new ProxyGenerator();

  IInterceptor loggerIntercept = new LoggerInterceptor();

  IProductRepository productRepo = new ProductRepository();

  IProductRepository proxy = generator.CreateInterfaceProxyWithTarget(productRepo, loggerIntercept);

  proxy.Add("大米");

  Console.Read();
 }
}

基于类的拦截器

public class ProductRepository
{
 public virtual void Add(string name) => Console.WriteLine($"新增产品：{name}");
}

static void Main(string[] args)
{
 ProxyGenerator generator = new ProxyGenerator();

 IInterceptor loggerIntercept = new LoggerInterceptor();

 ProductRepository proxy = generator.CreateClassProxyWithTarget(new ProductRepository(), loggerIntercept);
 // 使用 CreateClassProxy 泛型方法可以省去实例化代码
 //ProductRepository proxy = generator.CreateClassProxy<ProductRepository>(loggerIntercept);

 proxy.Add("大米");
}

在上例中，如果 ProductRepository.Add 不是虚方法，也不会报错，但是拦截器不会被调用。

异步函数拦截

Castle.DynamicProxy 对异步函数的拦截跟同步没啥差别，只是，如果要在方法执行完成后插入内容，需要 await

public class ProductRepository
{
 public virtual Task Add(string name)
 {
  return Task.Run(() =>
      {
       Thread.Sleep(1000);
       Console.WriteLine($"异步新增产品：{name}");
      });
 }
}

public class LoggerInterceptor : IInterceptor
{
 public async void Intercept(IInvocation invocation)
 {
  var methodName = invocation.Method.Name;

  Console.WriteLine($"{methodName} 执行前");

  invocation.Proceed();

  // 不 await 的话将会先输出“执行完毕”，再输出“异步新增产品”
  var task = (Task)invocation.ReturnValue;
  await task;

  Console.WriteLine($"{methodName} 执行完毕");
 }
}

上面这个写法是简单粗暴的，如果碰到返回值是 Task<TResult>，或者不是异步函数，就会出错。所以这里是要对返回值进行一个判断的。

可以使用 Castle.Core.AsyncInterceptor 包，它包装了 Castle，使异步调用更简单。

Castle.Core.AsyncInterceptor 的 GitHub 地址：https://github.com/JSkimming/Castle.Core.AsyncInterceptor

public class ProductRepository : IProductRepository
{
 public Task Add(string name)
 {
  return Task.Run(() =>
      {
       Thread.Sleep(1000);
       Console.WriteLine($"异步新增产品：{name}");
      });
 }

 public Task<string> Get()
 {
  return Task.Run(() =>
      {
       Thread.Sleep(1000);
       Console.WriteLine($"获取产品");

       return "大米";
      });
 }
}

public class LoggerInterceptor : IAsyncInterceptor
{
 public void InterceptAsynchronous(IInvocation invocation)
 {
  invocation.ReturnValue = InternalInterceptAsynchronous(invocation);
 }

 async Task InternalInterceptAsynchronous(IInvocation invocation)
 {
  var methodName = invocation.Method.Name;

  Console.WriteLine($"{methodName} 异步执行前");

  invocation.Proceed();
  await (Task)invocation.ReturnValue;

  Console.WriteLine($"{methodName} 异步执行完毕");
 }

 public void InterceptAsynchronous<TResult>(IInvocation invocation)
 {
  invocation.ReturnValue = InternalInterceptAsynchronous<TResult>(invocation);

  Console.WriteLine(((Task<TResult>)invocation.ReturnValue).Id);
 }

 private async Task<TResult> InternalInterceptAsynchronous<TResult>(IInvocation invocation)
 {
  var methodName = invocation.Method.Name;

  Console.WriteLine($"{methodName} 异步执行前");

  invocation.Proceed();
  var task = (Task<TResult>)invocation.ReturnValue;
  TResult result = await task;

  Console.WriteLine(task.Id);

  Console.WriteLine($"{methodName} 异步执行完毕");

  return result;
 }

 public void InterceptSynchronous(IInvocation invocation)
 {
  var methodName = invocation.Method.Name;

  Console.WriteLine($"{methodName} 同步执行前");

  invocation.Proceed();

  Console.WriteLine($"{methodName} 同步执行完毕");
 }
}

class Program
{
 static void Main(string[] args)
 {
  ProxyGenerator generator = new ProxyGenerator();

  IAsyncInterceptor loggerIntercept = new LoggerInterceptor();

  IProductRepository productRepo = new ProductRepository();

  IProductRepository proxy = generator.CreateInterfaceProxyWithTarget(productRepo, loggerIntercept);

  proxy.Get();
 }
}

这是 Castle.Core.AsyncInterceptor 提供的示例写法，这里有个问题，也是我的疑惑。invocation.ReturnValue = InternalInterceptAsynchronous(invocation); 将导致代理返回的 Task 是一个新的 Task，这一点我们可以输出 Task.Id 来确认。个人感觉有点画蛇添足。

public async void InterceptAsynchronous<TResult>(IInvocation invocation)
{
 var methodName = invocation.Method.Name;

 Console.WriteLine($"{methodName} 异步执行前");

 invocation.Proceed();
 var task = (Task<TResult>)invocation.ReturnValue;
 await task;

 Console.WriteLine($"{methodName} 异步执行完毕");
}

这样就挺好的。

如果有小伙伴知道为什么要返回一个新的 Task，请留言告诉我，谢谢！

Autofac 集成

Autofac.Extras.DynamicProxy 是一个 Autofac 扩展，可与 Castle 一起提供 AOP 拦截。

基于接口的拦截器

static void Main(string[] args)
{
 ContainerBuilder builder = new ContainerBuilder();
 //注册拦截器
 builder.RegisterType<LoggerInterceptor>().AsSelf();

 //注册要拦截的服务
 builder.RegisterType<ProductRepository>().AsImplementedInterfaces()
  .EnableInterfaceInterceptors()     //启用接口拦截
  .InterceptedBy(typeof(LoggerInterceptor));  //指定拦截器

 IContainer container = builder.Build();

 IProductRepository productRepo = container.Resolve<IProductRepository>();

 productRepo.Add("大米");
}

基于类的拦截器

static void Main(string[] args)
{
 ContainerBuilder builder = new ContainerBuilder();
 //注册拦截器
 builder.RegisterType<LoggerInterceptor>().AsSelf();

 //注册要拦截的服务
 builder.RegisterType<ProductRepository>()
  .EnableClassInterceptors()      //启用类拦截
  .InterceptedBy(typeof(LoggerInterceptor));  //指定拦截器

 IContainer container = builder.Build();

 ProductRepository productRepo = container.Resolve<ProductRepository>();

 productRepo.Add("大米");
}

异步函数拦截

Castle.Core.AsyncInterceptor 中，IAsyncInterceptor 接口并不集成 IInterceptor 接口，而 Autofac.Extras.DynamicProxy 是绑定 Castle 的，所以按上面同步拦截的写法是会报错的。

IAsyncInterceptor 提供了 ToInterceptor() 扩展方法来进行类型转换。

public class LoggerInterceptor : IInterceptor
{
 readonly LoggerAsyncInterceptor interceptor;

 public LoggerInterceptor(LoggerAsyncInterceptor interceptor)
 {
  this.interceptor = interceptor;
 }

 public void Intercept(IInvocation invocation)
 {
  this.interceptor.ToInterceptor().Intercept(invocation);
 }
}

public class LoggerAsyncInterceptor : IAsyncInterceptor
{
 public void InterceptAsynchronous(IInvocation invocation)
 {
  //...
 }

 public void InterceptAsynchronous<TResult>(IInvocation invocation)
 {
  //...
 }

 public void InterceptSynchronous(IInvocation invocation)
 {
  //...
 }
}

static void Main(string[] args)
{
 ContainerBuilder builder = new ContainerBuilder();
 //注册拦截器
 builder.RegisterType<LoggerInterceptor>().AsSelf();
 builder.RegisterType<LoggerAsyncInterceptor>().AsSelf();

 //注册要拦截的服务
 builder.RegisterType<ProductRepository>().AsImplementedInterfaces()
  .EnableInterfaceInterceptors()     //启用接口拦截
  .InterceptedBy(typeof(LoggerInterceptor));  //指定拦截器

 var container = builder.Build();

 IProductRepository productRepo = container.Resolve<IProductRepository>();

 productRepo.Get();
}

以上就是C# 使用 Castle 实现 AOP及如何用 Autofac 集成 Castle的详细内容，更多关于C# 使用 Castle 实现 AOP的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • C#中WPF颜色对话框控件的实现

    C#中WPF颜色对话框控件的实现

    在 C# WPF开发中颜色对话框控件（ColorDialog）用于对界面中的背景、文字…（拥有颜色属性的所有控件）设置颜色，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2022-03-03
  • C#读取配置文件的方法汇总

    C#读取配置文件的方法汇总

    本文给大家介绍的是使用C#读取配置文件的方法，个人给大家总结了6种，余下的以后再更新，有需要的小伙伴可以参考下。
    2015-06-06
  • Unity实现卡片循环滚动效果的示例详解

    Unity实现卡片循环滚动效果的示例详解

    这篇文章主要为大家详细介绍了如何利用Unity实现卡片循环滚动的效果，文中的实现步骤讲解详细，具有一定的借鉴价值，需要的可以参考一下
    2022-12-12
  • Unity AssetBundle打包工具示例详解

    Unity AssetBundle打包工具示例详解

    这篇文章主要介绍了Unity AssetBundle打包工具,本文通过实例代码给大家介绍的非常详细，具有一定的参考借鉴价值，需要的朋友可以参考下
    2021-10-10
  • C#实现一个Word保护性模板文件

    C#实现一个Word保护性模板文件

    这篇文章主要为大家详细介绍了C#如何实现一个Word保护性模板文件,文中的示例代码讲解详细,具有一定的借鉴价值,需要的小伙伴可以参考一下
    2024-01-01
  • C#入参使用引用类型要加ref的原因解析

    C#入参使用引用类型要加ref的原因解析

    这篇文章主要介绍了C#入参使用引用类型要加ref的原因解析,我们在实际开发中还是能够碰到一些引用类型添加ref的场景，其实道理也是一样的，就是将引用类型的栈的地址传递到了方法中，那么和不添加有啥区别，感兴趣的朋友跟随小编一起看看吧
    2022-11-11
  • C# 控件属性和InitializeComponent()关系案例详解

    C# 控件属性和InitializeComponent()关系案例详解

    这篇文章主要介绍了C# 控件属性和InitializeComponent()关系案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-08-08
  • 关于C#中使用Oracle存储过程返回结果集的问题

    关于C#中使用Oracle存储过程返回结果集的问题

    Oracle中可以使用游标（Cursor）对数据集进行操作，但在存储过程输出参数中直接使用Cursor错误，下面小编给大家带来了C#中使用Oracle存储过程返回结果集的问题，感兴趣的朋友一起看看吧
    2021-10-10
  • c# 动态加载dll文件,并实现调用其中的方法(推荐)

    c# 动态加载dll文件,并实现调用其中的方法(推荐)

    下面小编就为大家带来一篇c# 动态加载dll文件,并实现调用其中的方法(推荐)。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
    2017-02-02
  • C#中动态数组用法实例

    C#中动态数组用法实例

    这篇文章主要介绍了C#中动态数组用法,实例分析了C#中ArrayList实现动态数组的技巧,非常具有实用价值,需要的朋友可以参考下
    2015-04-04

最新评论