.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