ABP使用及框架解析系列 - [Unit of Work part.2-框架实现] - An.Cup.Of.Coffee(3)_H5之家

在之前的Begin实现中，我们看到，其返回路线有两个，一个返回了InnerUnitOfWorkCompleteHandle对象，另一个返回了IUnitOfWork实现对象。IUnitOfWork稍后详细解析，让我们先来解析InnerUnitOfWorkCompleteHandle ：

internal class InnerUnitOfWorkCompleteHandle : IUnitOfWorkCompleteHandle { DidNotCallCompleteMethodExceptionMessage = ; _isCompleteCalled; _isDisposed; public void Complete() { _isCompleteCalled = true; } public async Task CompleteAsync() { _isCompleteCalled = true; } public void Dispose() { if (_isDisposed) { return; } _isDisposed = true; if (!_isCompleteCalled) { if (HasException()) { return; } throw new AbpException(DidNotCallCompleteMethodExceptionMessage); } } HasException() { try { return Marshal.GetExceptionCode() != 0; } catch (Exception) { return false; } } }

我们可以看到，Complete和CompleteAsync里面，都只是简单的将_isCompleteCalled设置为true，在Dispose方法中，也仅仅只是判断是否已经dispose过、是否完成、是否有异常，没有更多的动作。这样大家会不会有一个疑问“这个工作单元的完成和释放工作里没有具体的完成操作，怎么就算完成工作单元了？”，这时，让我们结合使用到InnerUnitOfWorkCompleteHandle的地方来看：

if (options.Scope == TransactionScopeOption.Required && _currentUnitOfWorkProvider.Current != null) { return new InnerUnitOfWorkCompleteHandle(); }

这个判断，代表了当前已经存在工作单元，所以这个就是用于工作单元嵌套。内部的工作单元在提交和释放时，不需要做实际的提交和释放，只需要保证没有异常抛出，然后最外层工作单元再进行实际的提交和释放。这也就说明，在Begin方法中的另一条路线，返回IUnitOfWork实现对象才是最外层的事务对象。

IUnitOfWork

public interface IUnitOfWork : IActiveUnitOfWork, IUnitOfWorkCompleteHandle { Id { get; } //外层工作单元 IUnitOfWork Outer { get; set; } Begin(UnitOfWorkOptions options); }

IUnitOfWork除了继承了IUnitOfWorkCompleteHandle接口，拥有了Complete方法外，还继承了IActiveUnitOfWork接口：

public interface IActiveUnitOfWork { EventHandler Completed; event EventHandler<UnitOfWorkFailedEventArgs> Failed; event EventHandler Disposed; //工作单元设置 UnitOfWorkOptions Options { get; } //数据过滤配置 IReadOnlyList<DataFilterConfiguration> Filters { get; } bool IsDisposed { get; } void SaveChanges(); Task SaveChangesAsync(); IDisposable DisableFilter(params string[] filterNames); IDisposable EnableFilter(params string[] filterNames); bool IsFilterEnabled(string filterName); IDisposable SetFilterParameter(string filterName, string parameterName, object value); }

这个接口中包含了很多Filter相关的属性与方法，都是些数据过滤相关的，这里不对其进行介绍，所以这个接口里，主要包含了三个事件（Completed、Failed、Disposed），工作单元设置（Options），IsDisposed以及同步异步的SaveChanges。

除了IUnitOfWork接口，ABP还提供了一个实现IUnitOfWork接口的抽象基类UnitOfWorkBase，UnitOfWorkBase的主要目的，是为开发人员处理一些前置、后置工作和异常处理，所以UnitOfWorkBase实现了部分方法，并提供了一些抽象方法，在实现的部分中做好前后置工作，然后调用抽象方法，将主要实现交给子类，并对其进行异常处理，下面以Begin实现与Complete实现为例：

public void Begin(UnitOfWorkOptions options) { if (options == null) { ); } //防止Begin被多次调用 (); Options = options; //过滤配置 SetFilters(options.FilterOverrides); //抽象方法，子类实现 BeginUow(); } public void Complete() { //防止Complete被多次调用 (); try { //抽象方法，子类实现 CompleteUow(); _succeed = true; OnCompleted(); } catch (Exception ex) { _exception = ex; throw; } }