.NetCore学习笔记：三、基于AspectCore的AOP事务管理

AOP（面向切面编程），通过预编译方式和运行期间动态代理实现程序功能的统一维护的一种技术。AOP是OOP的延续，是函数式编程的一种衍生范型。利用AOP可以对业务逻辑的各个部分进行隔离，从而使得业务逻辑各部分之间的耦合度降低，提高程序的可重用性，同时提高了开发的效率。

AspectCore 提供了一个全新的轻量级和模块化的Aop解决方案，现在已经支持Asp.Net Core。

实现AOP类TransactionalAttribute：

/// <summary>
/// 为工作单元提供事务一致性
/// </summary>
public class TransactionalAttribute : AbstractInterceptorAttribute
{
    IUnitOfWork _unitOfWork { get; set; }

    public async override Task Invoke(AspectContext context, AspectDelegate next)
    {
        try
        {
            _unitOfWork = context.ServiceProvider.GetService(typeof(IUnitOfWork)) as IUnitOfWork;
            _unitOfWork.BeginTransaction();
            await next(context);
            _unitOfWork.Commit();
        }
        catch (Exception)
        {
            _unitOfWork.Rollback();
            throw;
        }
    }
}

这里需要引用AspectCore.Abstractions.dll库，代码中的UnitOfWork类在前面的文章中有讲解：.NetCore学习笔记：一、UnitOfWork工作单元。

在读写数据库的时候，将_unitOfWork.DbTransaction加入。下面这个是Dapper的Execute实例：

 _unitOfWork.DbConnection.Execute(sql, param: param, transaction: _unitOfWork.DbTransaction, commandType: commandType);

为Web应用程序添加配置：

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<Startup>();
        })          
        .UseDynamicProxy();//aspcectcore
}

在netcore3.1中配置比较简单，只需要在Program类中添加UseDynamicProxy()就可以了。

这样在需要用到事务的地方我们使用[Transactional]标注一下就可以了。

public class TestService : ITestService
{
    ITestDomain _testDomain { get; set; }
    public TestService(ITestDomain testDomain)
    {
        this._testDomain = testDomain;
    }

    public Test Get(string id)
    {
        var test = _testDomain.Get(id);
        return test;
    }

    [Transactional]
    public void Insert(List<Test> list)
    {
        _testDomain.InsertList(list);
    }
}

上段代码中的ITestDomain实现：

public class TestDomain : ITestDomain
{
    IRepository<Test> _testRepository { get; set; }
    public TestDomain(IRepository<Test> testRepository)
    {
        this._testRepository = testRepository;
    }

    public Test Get(string id)
    {
        return _testRepository.Get(id);
    }

    public void Insert(List<Test> list)
    {
        if (list == null)
            return;
        foreach(var item in list)
            _testRepository.Insert(item);
    }
}

代码片段中的Repository在前面的文章中有讲解：.NetCore学习笔记：二、基于Dapper的泛型Repository。

这样就实现AOP事务了。

源码地址：https://github.com/letnet/NetCoreDemo