什么网站 是cms系统下载,法律咨询免费平台,wordpress防站教程,北京网站设计引流微信hyhyk1一、简要说明统一工作单元是一个比较重要的基础设施组件#xff0c;它负责管理整个业务流程当中涉及到的数据库事务#xff0c;一旦某个环节出现异常自动进行回滚处理。在 ABP vNext 框架当中#xff0c;工作单元被独立出来作为一个单独的模块(Volo.Abp.Uow)。你可以根据自己… 一、简要说明统一工作单元是一个比较重要的基础设施组件它负责管理整个业务流程当中涉及到的数据库事务一旦某个环节出现异常自动进行回滚处理。在 ABP vNext 框架当中工作单元被独立出来作为一个单独的模块(Volo.Abp.Uow)。你可以根据自己的需要来决定是否使用统一工作单元。二、源码分析整个 Volo.Abp.Uow 项目的结构如下从下图还是可以看到我们的老朋友 IUnitOfWorkManager 和 IUnitOfWork 不过也多了一些新东西。看一个模块的功能首先从它的 Module 入手我们先看一下 AbpUnitofWorkModule 里面的实现。2.1 工作单元的初始模块打开 AbpUnitOfWorkModule 里面的代码发现还是有点失望里面就一个服务注册完成事件。public override void PreConfigureServices(ServiceConfigurationContext context){ context.Services.OnRegistred(UnitOfWorkInterceptorRegistrar.RegisterIfNeeded);}这里的结构和之前看的 审计日志 模块类似就是注册拦截器的作用没有其他特别的操作。2.1.1 拦截器注册继续跟进代码其实现是通过 UnitOfWorkHelper 来确定哪些类型应该集成 UnitOfWork 组件。public static void RegisterIfNeeded(IOnServiceRegistredContext context){ if (UnitOfWorkHelper.IsUnitOfWorkType(context.ImplementationType.GetTypeInfo())) { context.Interceptors.TryAddUnitOfWorkInterceptor(); }}继续分析 UnitOfWorkHelper 内部的代码第一种情况则是实现类型 (implementationType) 或类型的任一方法标注了 UnitOfWork 特性的话都会为其注册工作单元拦截器。第二种情况则是 ABP vNext 为我们提供了一个新的 IUnitOfWorkEnabled 标识接口。只要继承了该接口的实现都会被视为需要工作单元组件会在系统启动的时候自动为它绑定拦截器。public static bool IsUnitOfWorkType(TypeInfo implementationType){ if (HasUnitOfWorkAttribute(implementationType) || AnyMethodHasUnitOfWorkAttribute(implementationType)) { return true; } if (typeof(IUnitOfWorkEnabled).GetTypeInfo().IsAssignableFrom(implementationType)) { return true; } return false;}2.2 新的接口与抽象在 ABP vNext 当中将一些 职责 从原有的工作单元进行了 分离。抽象出了 IDatabaseApi 、ISupportsRollback、ITransactionApi 这三个接口这三个接口分别提供了不同的功能和职责。2.2.1 数据库统一访问接口这里以 IDatabaseApi 为例它是提供了一个 数据库提供者(Database Provider) 的抽象概念在 ABP vNext 里面是将 EFCore 作为数据库概念来进行抽象的。(因为后续 MongoDb 与 MemoryDb 与其同级)你可以看作是 EF Core 的 Provider 在 EF Core 里面我们可以实现不同的 Provider 来让 EF Core 支持访问不同的数据库。而 ABP vNext 这么做的意图就是提供一个统一的数据库访问 API如何理解呢这里以 EFCoreDatabaseApiTDbContext 为例你查看它的实现会发现它继承并实现了 ISupportsSavingChanges 也就是说 EFCoreDatabaseApiTDbContext 支持 SaveChanges 操作来持久化数据更新与修改。public class EfCoreDatabaseApiTDbContext : IDatabaseApi, ISupportsSavingChanges where TDbContext : IEfCoreDbContext{ public TDbContext DbContext { get; } public EfCoreDatabaseApi(TDbContext dbContext) { DbContext dbContext; } public Task SaveChangesAsync(CancellationToken cancellationToken default) { return DbContext.SaveChangesAsync(cancellationToken); } public void SaveChanges() { DbContext.SaveChanges(); }}也就是说 SaveChanges 这个操作是 EFCore 这个 DatabaseApi 提供了一种特殊操作是该类型数据库的一种特殊接口。如果针对于某些特殊的数据库例如 InfluxDb 等有一些特殊的 Api 操作时就可以通过一个 DatabaseApi 类型进行处理。2.2.2 数据库事务接口通过最开始的项目结构会发现一个 ITransactionApi 接口这个接口只定义了一个 事务提交操作(Commit)并提供了异步方法的定义。public interface ITransactionApi : IDisposable{ void Commit(); Task CommitAsync();}跳转到其典型实现 EfCoreTransactionApi 当中可以看到该类型还实现了 ISupportsRollback 接口。通过这个接口的名字我们大概就知道它的作用就是提供了回滚方法的定义。如果某个数据库支持回滚操作那么就可以为其实现该接口。其实这里按照语义你也可以将它放在 EfCoreDatabaseApiTDbContext 进行实现因为回滚也是数据库提供的 API 之一只是在 ABP vNext 里面又将其归为事务接口进行处理了。这里就不再详细赘述该类型的具体实现后续会在单独的 EF Core 章节进行说明。2.3 工作单元的原理与实现在 ABP vNext 框架当中的工作单元实现与原来 ABP 框架有一些不一样。2.3.1 内部工作单元 (子工作单元)首先说内部工作单元的定义现在是有一个新的 ChildUnitOfWork 类型作为 子工作单元。子工作单元本身并不会产生实际的业务逻辑操作基本所有逻辑都是调用 UnitOfWork 的方法。internal class ChildUnitOfWork : IUnitOfWork{ public Guid Id _parent.Id; public IUnitOfWorkOptions Options _parent.Options; public IUnitOfWork Outer _parent.Outer; public bool IsReserved _parent.IsReserved; public bool IsDisposed _parent.IsDisposed; public bool IsCompleted _parent.IsCompleted; public string ReservationName _parent.ReservationName; public event EventHandlerUnitOfWorkFailedEventArgs Failed; public event EventHandlerUnitOfWorkEventArgs Disposed; public IServiceProvider ServiceProvider _parent.ServiceProvider; private readonly IUnitOfWork _parent; public ChildUnitOfWork([NotNull] IUnitOfWork parent) { Check.NotNull(parent, nameof(parent)); _parent parent; _parent.Failed (sender, args) { Failed.InvokeSafely(sender, args); }; _parent.Disposed (sender, args) { Disposed.InvokeSafely(sender, args); }; } public void SetOuter(IUnitOfWork outer) { _parent.SetOuter(outer); } public void Initialize(UnitOfWorkOptions options) { _parent.Initialize(options); } public void Reserve(string reservationName) { _parent.Reserve(reservationName); } public void SaveChanges() { _parent.SaveChanges(); } public Task SaveChangesAsync(CancellationToken cancellationToken default) { return _parent.SaveChangesAsync(cancellationToken); } public void Complete() { } public Task CompleteAsync(CancellationToken cancellationToken default) { return Task.CompletedTask; } public void Rollback() { _parent.Rollback(); } public Task RollbackAsync(CancellationToken cancellationToken default) { return _parent.RollbackAsync(cancellationToken); } public void OnCompleted(FuncTask handler) { _parent.OnCompleted(handler); } public IDatabaseApi FindDatabaseApi(string key) { return _parent.FindDatabaseApi(key); } public void AddDatabaseApi(string key, IDatabaseApi api) { _parent.AddDatabaseApi(key, api); } public IDatabaseApi GetOrAddDatabaseApi(string key, FuncIDatabaseApi factory) { return _parent.GetOrAddDatabaseApi(key, factory); } public ITransactionApi FindTransactionApi(string key) { return _parent.FindTransactionApi(key); } public void AddTransactionApi(string key, ITransactionApi api) { _parent.AddTransactionApi(key, api); } public ITransactionApi GetOrAddTransactionApi(string key, FuncITransactionApi factory) { return _parent.GetOrAddTransactionApi(key, factory); } public void Dispose() { } public override string ToString() { return $[UnitOfWork {Id}]; }}虽然基本上所有方法的实现都是调用的实际工作单元实例。但是有两个方法 ChildUnitOfWork 是空实现的那就是 Complete() 和 Dispose() 方法。这两个方法一旦在内部工作单元调用了就会导致 事务被提前提交所以这里是两个空实现。下面就是上述逻辑的伪代码using(var transactioinUow uowMgr.Begin()){ using(var childUow1 uowMgr.Begin()) { using(var childUow2 uowMgr.Begin()) { childUow2.Complete(); } childUow1.Complete(); } transactioinUow.Complete();}以上结构一旦某个内部工作单元抛出了异常到会导致最外层带事务的工作单元无法调用 Complete()方法也就能够保证我们的 数据一致性。2.3.2 外部工作单元首先我们查看 UnitOfWork 类型和 IUnitOfWork 的定义和属性可以获得以下信息。每个工作单元是瞬时对象因为它继承了 ITransientDependency 接口。每个工作单元都会有一个 Guid 作为其唯一标识信息。每个工作单元拥有一个 IUnitOfWorkOptions 来说明它的配置信息。这里的配置信息主要指一个工作单元在执行时的 超时时间是否包含一个事务以及它的 事务隔离级别如果是事务性的工作单元的话。每个工作单元存储了 IDatabaseApi 与 ITransactionApi 的集合并提供了访问/存储接口。提供了两个操作事件 Failed 与 Disposed。这两个事件分别在工作单元执行失败以及被释放时(调用 Dispose() 方法)触发开发人员可以挂载这两个事件提供自己的处理逻辑。工作单元还提供了一个工作单元完成事件组。用于开发人员在工作单元完成时(调用Complete() 方法)挂载自己的处理事件因为是 ListFuncTask 所以你可以指定多个它们都会在调用 Complete() 方法之后执行例如如下代码using (var uow _unitOfWorkManager.Begin()){ uow.OnCompleted(async () completed true); uow.OnCompleted(async()Console.WriteLine(Hello ABP vNext)); uow.Complete();}以上信息是我们查看了 UnitOfWork 的属性与接口能够直接得出的结论接下来我会根据一个工作单元的生命周期来说明一遍工作单元的实现。一个工作单元的的构造是通过工作单元管理器实现的(IUnitOfWorkManager)通过它的 Begin() 方法我们会获得一个工作单元至于这个工作单元是外部工作单元还是内部工作单元取决于开发人员传入的参数。public IUnitOfWork Begin(UnitOfWorkOptions options, bool requiresNew false){ Check.NotNull(options, nameof(options)); var currentUow Current; if (currentUow ! null !requiresNew) { return new ChildUnitOfWork(currentUow); } var unitOfWork CreateNewUnitOfWork(); unitOfWork.Initialize(options); return unitOfWork;}这里需要注意的就是创建新的外部工作单元方法它这里就使用了 IoC 容器提供的 Scope 生命周期并且在创建之后会将最外部的工作单元设置为最新创建的工作单元实例。private IUnitOfWork CreateNewUnitOfWork(){ var scope _serviceProvider.CreateScope(); try { var outerUow _ambientUnitOfWork.UnitOfWork; var unitOfWork scope.ServiceProvider.GetRequiredServiceIUnitOfWork(); unitOfWork.SetOuter(outerUow); _ambientUnitOfWork.SetUnitOfWork(unitOfWork); unitOfWork.Disposed (sender, args) { _ambientUnitOfWork.SetUnitOfWork(outerUow); scope.Dispose(); }; return unitOfWork; } catch { scope.Dispose(); throw; }}上述描述可能会有些抽象结合下面这两幅图可能会帮助你的理解。我们可以在任何地方注入 IAmbientUnitOfWork 来获取当前活动的工作单元关于 IAmbientUnitOfWork 与 IUnitOfWorkAccessor 的默认实现都是使用的 AmbientUnitOfWork。在该类型的内部通过 AsyncLocalIUnitOfWork 来确保在不同的 异步上下文切换 过程中其值是正确且统一的。构造了一个外部工作单元之后我们在仓储等地方进行数据库操作。操作完成之后我们需要调用 Complete() 方法来说明我们的操作已经完成了。如果你没有调用 Complete() 方法那么工作单元在被释放的时候就会产生异常并触发 Failed 事件。public virtual void Dispose(){ if (IsDisposed) { return; } IsDisposed true; DisposeTransactions(); if (!IsCompleted || _exception ! null) { OnFailed(); } OnDisposed();}所以我们在手动使用工作单元管理器构造工作单元的时候一定要注意调用 Complete() 方法。既然 Complete() 方法这么重要它内部究竟做了什么事情呢下面我们就来看一下。public virtual void Complete(){ if (_isRolledback) { return; } PreventMultipleComplete(); try { _isCompleting true; SaveChanges(); CommitTransactions(); IsCompleted true; OnCompleted(); } catch (Exception ex) { _exception ex; throw; }}public virtual void SaveChanges(){ foreach (var databaseApi in _databaseApis.Values) { (databaseApi as ISupportsSavingChanges)?.SaveChanges(); }}protected virtual void CommitTransactions(){ foreach (var transaction in _transactionApis.Values) { transaction.Commit(); }}protected virtual void RollbackAll(){ foreach (var databaseApi in _databaseApis.Values) { try { (databaseApi as ISupportsRollback)?.Rollback(); } catch { } } foreach (var transactionApi in _transactionApis.Values) { try { (transactionApi as ISupportsRollback)?.Rollback(); } catch { } }}这里可以看到ABP vNext 完全剥离了具体事务或者回滚的实现方法都是移动到具体的模块进行实现的也就是说在调用了 Complete() 方法之后我们的事务就会被提交了。本小节从创建、提交、释放这三个生命周期讲解了工作单元的原理和实现关于具体的事务和回滚实现我会放在下一篇文章进行说明这里就不再赘述了。为什么工作单元常常配合 using 语句块 使用就是因为在提交工作单元之后就可以自动调用 Dispose() 方法对工作单元的状态进行校验而不需要我们手动处理。using(var uowA _uowMgr.Begion()){ uowA.Complete();}2.3.3 保留工作单元在 ABP vNext 里面工作单元有了一个新的动作/属性叫做 是否保留(Is Reserved)。它的实现也比较简单指定了一个 ReservationName然后设置 IsReserved 为 true 就完成了整个动作。那么它的作用是什么呢这块内容我会在工作单元管理器小节进行解释。2.4 工作单元管理器工作单元管理器在工作单元的原理/实现里面已经有过了解工作单元管理器主要负责工作单元的创建。这里我再挑选一个工作单元模块的单元测试来说明什么叫做 保留工作单元。[Fact]public async Task UnitOfWorkManager_Reservation_Test(){ _unitOfWorkManager.Current.ShouldBeNull(); using (var uow1 _unitOfWorkManager.Reserve(Reservation1)) { _unitOfWorkManager.Current.ShouldBeNull(); using (var uow2 _unitOfWorkManager.Begin()) { _unitOfWorkManager.Current.ShouldNotBeNull(); _unitOfWorkManager.Current.Id.ShouldNotBe(uow1.Id); await uow2.CompleteAsync(); } _unitOfWorkManager.Current.ShouldBeNull(); _unitOfWorkManager.BeginReserved(Reservation1); _unitOfWorkManager.Current.ShouldNotBeNull(); _unitOfWorkManager.Current.Id.ShouldBe(uow1.Id); await uow1.CompleteAsync(); } _unitOfWorkManager.Current.ShouldBeNull();}通过对代码的注释和断点调试的结果我们知道了通过 Reserved 创建的工作单元它的 IsReserved 属性是 true所以我们调用 IUnitOfWorkManager.Current 访问的时候会忽略掉保留工作单元所以得到的值就是 null。但是通过调用 BeginReserved(string name) 方法我们就可以将指定的工作单元置为 当前工作单元这是因为调用了该方法之后会重新调用工作单元的 Initialize() 方法在该方法内部又会将 IsReserved 设置为 false 。public virtual void Initialize(UnitOfWorkOptions options){ IsReserved false;}保留工作单元的用途主要是在某些特殊场合在某些特定条件下不想暴露给 IUnitOfWorkManager.Current 时使用。2.5 工作单元拦截器如果我们每个地方都通过工作单元管理器来手动创建工作单元那还是比较麻烦的。ABP vNext 通过拦截器来为特定的类型符合规则自动创建工作单元。关于拦截器的注册已经在文章最开始说明了这里就不再赘述我们直接来看拦截器的内部实现。其实在拦截器的内部一样是使用工作单元拦截器我来为我们创建工作单元的。只不过通过拦截器的方式就能够无感知/无侵入地为我们构造健壮的数据持久化机制。public override void Intercept(IAbpMethodInvocation invocation){ if (!UnitOfWorkHelper.IsUnitOfWorkMethod(invocation.Method, out var unitOfWorkAttribute)) { invocation.Proceed(); return; } using (var uow _unitOfWorkManager.Begin(CreateOptions(invocation, unitOfWorkAttribute))) { invocation.Proceed(); uow.Complete(); }}关于在 ASP.NET Core MVC 的工作单元过滤器在实现上与拦截器大同小异后续讲解 ASP.NET Core Mvc 时再着重说明。三、总结ABP vNext 框架通过统一工作单元为我们提供了健壮的数据库访问与持久化机制使得开发人员在进行软件开发时只需要关注业务逻辑即可。不需要过多关注与数据库等基础设施的交互这一切交由框架完成即可。这里多说一句ABP vNext 本身就是面向 DDD 所设计的一套快速开发框架包括值对象ValueObject这些领域驱动开发的特殊概念也被加入到框架实现当中。微服务作为 DDD 的一个典型实现DDD 为微服务的划分提供理论支持。这里为大家推荐《领域驱动设计软件核心复杂性应对之道》这本书该书籍由领域驱动设计的提出者编写。看了之后发现在大型系统当中博主之前做 ERP 的吃过这个亏很多时候都是凭感觉来写没有一个具体的理论来支持软件开发。最近拜读了上述书籍之后发现领域驱动设计DDD就是一套完整的方法论当然 不是银弹。大家在学习并理解了领域驱动设计之后使用 ABP vNext 框架进行大型系统开发就会更加得心应手。四、后记关于本系列文章的更新因为最近自己在做 物联网(Rust 语言学习、数字电路设计)相关的开发工作所以 5 月到 6 月这段时间都没怎么去研究 ABP vNext。最近在学习领域驱动设计的过程中发现 ABP vNext 就是为 DDD 而生的所以趁热打铁想将后续的 ABP vNext 文章一并更新预计在 7 月内会把剩余的文章补完核心模块。原文地址https://www.cnblogs.com/myzony/p/11112288.html.NET社区新闻深度好文欢迎访问公众号文章汇总 http://www.csharpkit.com
