Asp.net Core 3.1基于AspectCore实现AOP实现事务、缓存拦

Asp.Core 3.1：利用AspectCore实现AOP的事务与缓存

对于想要为方法快速添加事务或缓存特性的人来说，面向切面编程（AOP）无疑是一种强大的技术。在Asp.Core 3.1中，我们可以借助AspectCore框架轻松实现AOP，下面让我详细为你介绍这一过程。

在开始之前，你可能已经知道AOP的概念，它类似于中间件，允许我们在方法的前后任意添加代码。这在缓存、日志等处理中非常适用。相较于之前的版本，Asp.Core 3.1提供了更简洁的方式来集成AOP，即使用AspectCore框架。

你需要安装一个NuGet包，名为AspectCore.Extensions.DependencyInjection。这个包为我们提供了在Asp.Core应用中集成AspectCore的工具。

接下来，在Program.cs类中，我们需要用AspectCore的IOC容器替换内置的。这是因为在AOP中，我们需要依赖IOC容器来实现的注入。具体代码如下：

```csharp

public class Program

{

public static void Main(string[] args)

{

CreateHostBuilder(args).Build().Run();

}

public static IHostBuilder CreateHostBuilder(string[] args) =>

Host.CreateDefaultBuilder(args)

.ConfigureWebHostDefaults(webBuilder =>

{

webBuilder.UseStartup();

})

// 使用AspectCore替换默认的IOC容器

.UseServiceProviderFactory(new DynamicProxyServiceProviderFactory());

}

```

然后，在Startup.cs的ConfigureServices方法中，我们需要配置动态代理。如果你只使用特性进行拦截，那么这一步是可选的。但如果你想进行全局配置或指定哪些服务被拦截，那么就需要在这里进行配置。代码如下：

```csharp

services.ConfigureDynamicProxy(o =>

{

// 添加AOP的配置

});

```

配置完成后，你就可以轻松地为接口、接口的方法、类及其虚方法添加了。如果你想拦截控制器的action，那么在ConfigureService里需要调用AddControllersAsServices方法。例如：

```csharp

services.AddControllers()

// 把控制器当成服务

.AddControllersAsServices()

```

关于事务的实现，你可以继承AbstractInterceptorAttribute来实现特性拦截。如果你想创建一个全局，那么就继承AbstractInterceptor并在ConfigureDynamicProxy中进行配置。在这里，我就不详细展开介绍了。需要注意的是，如果你的项目没有添加AspectCore.Core包，可能会缺少一些扩展方法，如IsAsync、UnwrapAsyncReturnValue等。请确保你的项目已经正确添加了所有必要的包。

事务处理的优雅执行者

在一个以数据为中心的应用中，事务的恰当处理显得尤为重要。为此，我们推出了一个强大的事务——TransactionInterceptorAttribute类。它继承自AbstractInterceptorAttribute类，并进行了定制。

当调用Invoke方法时，这个首先会获取当前的数据库上下文AppDbContext。如果当前没有启用事务，它将启动一个新的事务。然后，它会尝试执行后续的操作（next(context)）。如果一切顺利，它将提交事务；如果发生异常，它会回滚事务并抛出异常。而如果已经存在一个事务，那么它将直接执行后续操作。

如此设计，旨在确保我们的应用程序在处理数据库操作时，能够在一个事务的笼罩下完成，保证了数据的完整性和一致性。让我们的代码更加优雅地处理事务，让数据库操作更加流畅。

接下来，让我们转向另一个重要的——缓存CacheInterceptorAttribute。它同样继承自AbstractInterceptorAttribute类，并加入了缓存秒数（ExpireSeconds）的设置。这个用于处理缓存相关的操作。

在Invoke方法中，它会首先判断当前操作是否是异步的。针对异步方法，我们需要特别处理其返回值。这是因为异步方法可能会在等待任务完成期间返回，这时我们需要确保缓存的数据是的。它还使用了我定义的ICacheHelper接口和Redis进行缓存操作。关于这部分的详细使用，我会在后续的博客中进行详细介绍。

这两个的设计都是为了提升我们的应用程序在处理数据库和缓存操作时的效率和稳定性。让我们的代码更加优雅、流畅地运行，提升了用户体验和应用程序的性能。