在 asp.net core 中使用 UnitOfWorkManager 实现多种事务传播 #289
Description
本篇文章内容引导，如何在 asp.net core 项目中使用特性(注解) 的方式管理事务。
UnitOfWorkManager 只可以管理 Repository 仓储对象的事务，直接 fsql.Insert<T>() 是不行的！！但是可以用 repository.Orm.Insert<T>！！repository.Orm 是特殊实现的 IFreeSql，与 当前事务保持一致。
支持六种传播方式(propagation)，意味着跨方法的事务非常方便，并且支持同步异步：
- Requierd：如果当前没有事务，就新建一个事务，如果已存在一个事务中，加入到这个事务中，默认的选择。
- Supports：支持当前事务，如果没有当前事务，就以非事务方法执行。
- Mandatory：使用当前事务，如果没有当前事务，就抛出异常。
- NotSupported：以非事务方式执行操作，如果当前存在事务，就把当前事务挂起。
- Never：以非事务方式执行操作，如果当前事务存在则抛出异常。
- Nested：以嵌套事务方式执行。
第一步：引入动态代理库
dotnet add package Rougamo.Fody
[AttributeUsage(AttributeTargets.Method)] public class TransactionalAttribute : Rougamo.MoAttribute { public Propagation Propagation { get; set; } = Propagation.Required; public IsolationLevel IsolationLevel { get => m_IsolationLevel.Value; set => m_IsolationLevel = value; } IsolationLevel? m_IsolationLevel; static AsyncLocal<IServiceProvider> m_ServiceProvider = new AsyncLocal<IServiceProvider>(); public static void SetServiceProvider(IServiceProvider serviceProvider) => m_ServiceProvider.Value = serviceProvider; IUnitOfWork _uow; public override void OnEntry(MethodContext context) { var uowManager = m_ServiceProvider.Value.GetService(typeof(UnitOfWorkManager)) as UnitOfWorkManager; _uow = uowManager.Begin(this.Propagation, this.m_IsolationLevel); } public override void OnExit(MethodContext context) { if (typeof(Task).IsAssignableFrom(context.RealReturnType)) ((Task)context.ReturnValue).ContinueWith(t => _OnExit()); else _OnExit(); void _OnExit() { try { if (context.Exception == null) _uow.Commit(); else _uow.Rollback(); } finally { _uow.Dispose(); } } } }| UnitOfWorkManager 成员 | 说明 |
|---|---|
| IUnitOfWork Current | 返回当前的工作单元 |
| void Binding(repository) | 将仓储的事务交给它管理 |
| IUnitOfWork Begin(propagation, isolationLevel) | 创建工作单元 |
第二步：配置 Startup.cs 注入、中间件
//Startup.cs public void ConfigureServices(IServiceCollection services) { services.AddSingleton<IFreeSql>(fsql); services.AddScoped<UnitOfWorkManager>(); services.AddFreeRepository(null, typeof(Startup).Assembly); //批量注入 Service } public void Configure(IApplicationBuilder app, IWebHostEnvironment env) { app.Use(async (context, next) => { TransactionalAttribute.SetServiceProvider(context.RequestServices); await next(); }); }第三步：在 Controller 或者 Service 或者 Repository 中使用事务特性
public class SongService { readonly IBaseRepository<Song> _repoSong; readonly IBaseRepository<Detail> _repoDetail; readonly SongRepository _repoSong2; public SongService(IBaseRepository<Song> repoSong, IBaseRepository<Detail> repoDetail, SongRepository repoSong2) { _repoSong = repoSong; _repoDetail = repoDetail; _repoSong2 = repoSong2; } [Transactional] public virtual void Test1() { //这里 _repoSong、_repoDetail、_repoSong2 所有操作都是一个工作单元 this.Test2(); } [Transactional(Propagation = Propagation.Nested)] public virtual void Test2() //嵌套事务，新的（不使用 Test1 的事务） { //这里 _repoSong、_repoDetail、_repoSong2 所有操作都是一个工作单元 } }是不是进方法就开事务呢？
不一定是真实事务，有可能是虚的，就是一个假的 unitofwork（不带事务）
也有可能是延用上一次的事务
也有可能是新开事务，具体要看传播模式
重写仓储实现
以上使用的是泛型仓储，那我们如果是重写一个仓储 如何保持和UnitOfWorkManager同一个事务呢。
继承现有的DefaultRepository<,>仓储，实现自定义的仓储SongRepository.cs,
public class SongRepository : DefaultRepository<Song, int>, ISongRepository { public SongRepository(UnitOfWorkManager uowm) : base(uowm?.Orm, uowm) { } public List<Song> GetSongs() { return Select.Page(1, 10).ToList(); } }其中接口。ISongRepository.cs
public interface ISongRepository : IBaseRepository<Song, int> { List<Song> GetSongs(); }在 startup.cs 注入此服务
services.AddScoped<ISongRepository, SongRepository>();