【转】ABP源码分析十:Unit Of Work

ABP以AOP的方式实现UnitOfWork功能。通过UnitOfWorkRegistrar将UnitOfWorkInterceptor在某个类被注册到IOCContainner的时候,一并添加到该类在容器中对应的ComponentModel的Interceptors集合中。总结一句话就是,UOW的功能是通过自定义Castle拦截器来实现的。本文主要介绍ABP核心框架中的UnitOfWork的实现,后续会分别介绍ABP其他模块是如何具体实现IUnitOfWork的

 

如图,AbpKernelModule调用UnitOfWorkRegister的Initialize方法将UnitOfWorkInterceptor拦截器添加到标注了UnitOfWork特性方法的类,以及实现IRepository或IApplicationService的类上。

 

下图是UnitOfWorkRegister的代码

 

和通常实现的AOP一样,ABP定义了UnitOfWork特性,方便业务层为方法注入UOW功能。

UnitOfWorkAttribute:用于标注某个方法位UnitOfWork的Attribute类. 通过这个特性,可以指定是否启用UOW,事务隔离级别,TransactionScopeOption等

UnitOfWorkOptions: 封装了UnitOfWork参数的类,其实例是通过UnitOfWorkAttribute的CreateOptions来生成的。

 


 

接下来,分析下UnitOfWork是如何封装事务的。

基于接口隔离原则的考量,ABP作者将UnitOfWork的方法分到了三个不同的接口中,如下图。

IUnitOfWorkCompleteHandle:定义了UOW同步和异步的complete方法。实现UOW完成时候的逻辑。

 

IActiveUnitOfWork:一个UOW除了以上两个接口中定义的方法和属性外,其他的属性和方法都在这个接口定义的。比如Completed,Disposed,Failed事件代理,Filter的enable和disable,以及同步、异步的SaveChanges方法。

 

IUnitOfWork:继承了上面两个接口。定义了外层的IUnitOfWork的引用和UOW的begin方法。 ABP是通过构建一个UnitOfWork的链,将不同的方法纳入到一个事务中(后文解释)。

UnitOfWorkBase:这个抽象类实现了上面三个接口中定义的方法,而真正实现事务控制的方法是由这个抽象类的子类实现的(比如,真正创建TransactionScope的操作是在EfUnitOfWork,NhUnitOfWork这样的之类中实现的)。UOW中除了事务控制逻辑以外的逻辑都是由UnitOfWorkBase抽象类实现的。

 

 

ABP中共有以下4个具体的UOW类型,他们都继承自UnitOfWorkBase。Entity Framework, Nhibernate UnitOfWork是实现事务控制的UOW。MongoDB 和 MemoryDB UnitOfWork是没有事务控制的。 原因很简单,MongoDB本身就没有完整的事务控制功能, 而ABP 框架实现的MemoryDB也是没有事务控制功能的。

 

IUnitOfWorkManager/UnitOfWorkManager:和其他***manager类一样是一个Facade,他对外提供UOW的功能(用于创建UnitOfWork,并开启UnitOfWork流程),对内调用各种UOW功能的各种组件。

 

UnitOfWork拦截器调用UnitOfWorkManager开启UOW流程的代码。

 

Unit Of Work大致运行流程如下

  1. UOW拦截器被注入到需要UOW的类中。
  2. ABP执行标注了UnitOfWork特性的方法时。UOW拦截器以begin()->realAction()->complete()->dispose()顺序执行,其中realAction是被调用的真实业务操作。 UOW拦截器是通过using这种方式调用IUnitOfWork的某个具体实现,这就确保begin 和 dispose也总是会被执行的。 这里需要注意complete却不一定会被执行,比如在complete方法被调用前方法的执行产生了异常。
  3. 当执行一连串的操作时(A方法->B方法->C方法,假设这三个方法都标注了UnitOfWork特性),ABP在执行A方法前会创建整个过程中唯一的IUnitOfWork对象,该对象会启动.NET事务。在执行到B,C方法只会创建InnerUnitOfWorkCompleteHandle。 InnerUnitOfWorkCompleteHandle与IUnitOfWork对象的差异在于它不会创建真实的事务。但ABP会调用其complete,以告知ABP其对应的方法以成功完成,可以提交事务.
  4. 事务可以回滚的关键关键在于IUnitOfWork对象在被dispose时候会检查complete方法有没有被执行,没有的话就认为这个UOW标注的方法没有顺利完成,从而导致事务的回滚操作。
  5. 整个事务的提交是通过第一个UOW(也是唯一个)的complete方法执行时提交的。

 

 

InnerUnitOfWorkCompleteHandle关于检查complete方法有没有被执行的代码

 

UnitOfWorkManager的beign方法。这边可以看出只有一个IUnitOfWork对象会被创建, 而且由于这个对象是通过容器直接resolve的,那么ABP怎么知道该通过resolve得到什么样的实例呢?是EfUnitOfWork?还是MongoDbUnitOfWork?还是MemoryDbUnitOfWork?还是NhUnitOfWork?答案是ABP不知道,ABP作者假设你只会用其中一个模块,所以如果你把这四个module都加入到你的项目中,结果是不可预知的。

 

EfUnitOfWork在begin方法中创建.NET事务

 

EfUnitOfWork提交事务

 

 

 

 

CallContextCurrentUnitOfWorkProvider

CallContextCurrentUnitOfWorkProvider的主要功能其实只有一个:通过current返回当前UOW环境下的UOW实例。

一般思路是:将IUnitOfWork对象定义为实例变量或者是类变量。 但是两者事实上都不可行。

如果定义为类变量,那就会面临线程安全的问题,解决方式无非加锁,但会导致并发能力下降,ABP是web框架,因为锁导致并发能力下降是不能接受的。

如果定义为实例变量,在同一线程其他地方resolve CallContextCurrentUnitOfWorkProvider这个实例的时候都会得到一个新的实例,新的实例下current自然是NULL.

ABP的做法是:线程逻辑上下文+线程安全的Dictinoray容器。

线程逻辑上下文用于存储UOW实例的key, 而线程逻辑上下文对于本线程是全局可访问的,而同时具有天然的隔离性。这就确保了当前线程的各个地方都可以得到current的UOW的key

线程安全的Dictinoray容器是一个类实例,用于存放UOW的实例,通过UOW的key就可以取到UOW的实例。

 

 

返回ABP源码分析系列文章目录

 

Q:我有个问题想请教。关于ABP的事务机制。
1.为什么事务要切入所有继承IRepository和IApplicationService的类,这样的话所有的继承类方法都AOP了,虽然实际的事务只有在访问dbcontext的时候UOW才会被初始化,但单查询的方法,ABP也要开启一次事务,是不是非常低效啊。
2.如果我在Appcliation对象中手写事务想缩短事务执行时间,它会不会被ABP的事务机制影响。

A:如果仅仅是读数据,那么可以在方法上加上特性[UnitOfWork(isTransactional: false)]以关闭事务。

 

Q:这种方式感觉不是很好。
我仔细看了下代码,ABP默认事务的隔离级别是IsolationLevel=ReadUncommitted,作者的意图是不是要给读操作加个nolock而这么实现的啊。因为EF加nolock都是要起事务的。

 

A:IsolationLevel=ReadUncommitted 不等于给读操作加个nolock。 ABP是通过TransactionScope来控制事务的。没有对EF操作做特殊处理。

 

A:作者分析的不错,但是ABP得工作单元也是可以实现EF和MongoDb的这种切换的。

 

A:引用作者分析的不错,但是ABP得工作单元也是可以实现EF和MongoDb的这种切换的。


Q:今天在一个方法中有EF和MongoDb结果一直报错。。。 Unable to cast object of type 'Abp.EntityFrameworkCore.Uow.EfCoreUnitOfWork' to type 'Abp.MongoDb.Uow.MongoDbUnitOfWork'.

  

Q:应该是UnitOfWorkRegistrar而不是UnitOfWorkRegister

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/436736.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【转】ABP源码分析十一:Timing

Timing这个简单实用的功能主要用来以统一的方式表示时间。因为ABP中有大量的module,另外还支持自定义module,所以将时间统一表示为local时间(默认)或utc时间是必要的。 IClockProvider:提供获取当前时间和标准化时间的接口。 UtcClockProvide…

【转】ABP源码分析十二:本地化

本文逐个分析ABP中涉及到localization的接口和类,以及他们之间的关系。本地化主要涉及两个方面:一个是语言(Language)的管理,这部分相对简单。另一个是语言对应得本地化资源(Localization)的管理…

【转】ABP源码分析十三:缓存Cache实现

ABP中有两种cache的实现方式:MemoryCache 和 RedisCache. 如下图,两者都继承自ICache接口(准确说是CacheBase抽象类)。ABP核心模块封装了MemoryCache 来实现ABP中的默认缓存功能。 Abp.RedisCache这个模块封装RedisCache来实现缓存…

java 酒店预定 app_Android应用源码酒店在线预定app项目全套

【实例简介】Android应用源码酒店在线预定app项目全套【实例截图】【核心代码】package com.bn.summer;import android.graphics.Bitmap;import android.graphics.BitmapFactory;import android.graphics.Canvas;import android.graphics.Color;import android.graphics.Paint;…

【转】ABP源码分析十四:Entity的设计

IEntity<TPrimaryKey>: 封装了PrimaryKey&#xff1a;Id,这是一个泛型类型 IEntity: 封装了PrimaryKey&#xff1a;Id,这是一个int类型 Entity<TPrimaryKey> &#xff1a;支持主键是泛型类型的Entity Entity&#xff1a;支持主键是int类型的Entity IHasCreation…

【转】ABP源码分析十六:DTO的设计

IDTO:空接口&#xff0c;用于标注Dto对象。 ComboboxItemDto&#xff1a;用于combobox/list中Item的DTO NameValueDto<T>/NameValueDto:用于name value键值对的DTO&#xff0c; name为string类型&#xff0c; value为泛型或string类型。 Entity Dto IEntityDto<TPri…

php session 机制,Cookie、Session机制详解及PHP中Session处理

会话机制Cookie/Session&#xff1a;在web应用中&#xff0c;常用的会话追踪机制是Cookie和Session。而Cookie是通过在浏览器里记录确定用户身份&#xff0c;Session在服务器端记录信息确定用户身份。Http协议&#xff1a;http协议本身是无状态的&#xff0c;也就是说我们无法通…

【转】ABP源码分析十七:DTO 自动校验的实现

对传给Application service对象中的方法的DTO参数&#xff0c;ABP都会在方法真正执行前自动完成validation&#xff08;根据标注到DTO对象中的validate规则&#xff09;。 ABP是如何做到的? 思路无外乎通过Castle的拦截器实现AOP。本文主要分析ABP是如何设计。 Ivalidate: 空…

【转】ABP源码分析十八:UI Inputs

以下图中描述的接口和类都在Abp项目的Runtime/Validation, UI/Inputs目录下的。在当前版本的ABP&#xff08;0.83&#xff09;中这些接口和类并没有实际使用到。阅读代码时可以忽略&#xff0c;无需浪费时间去寻找其是如何被ABP使用的(本文的目的)。 这些接口和类最终都是通过…

【转】ABP源码分析十九:Auditing

审计跟踪&#xff08;也叫审计日志&#xff09;是与安全相关的按照时间顺序的记录&#xff0c;它们提供了活动序列的文档证据&#xff0c;这些活动序列可以在任何时间影响一个特定的操作。 AuditInfo&#xff1a;定义如下图中需要被Audit的信息。 AuditedAttribute&#xff1a;…

【转】WebServices:WSDL的结构分析

WSDL&#xff08;Web Services Description Language&#xff0c;Web服务描述语言&#xff09;是为描述Web Services发布的XML格式。W3C组织没有批准1.1版的WSDL&#xff0c;但是2.0版本已经在製訂中&#xff0c;2.0版将被作为推荐标准&#xff08;recommendation&#xff09;&…

【转】WebService WSDL结构分析

转载自&#xff1a;http://kalogen.javaeye.com/blog/418958 WSDL (Web Services Description Language,Web服务描述语言)是一种XML Application&#xff0c;他将Web服务描述定义为一组服务访问点&#xff0c;客户端可以通过这些服务访问点对包含面向文档信息或面向过程调用的服…

【转】WebService 之 WSDL文件 讲解

恩&#xff0c;我想说的是&#xff0c;是不是经常有人在开发的时候&#xff0c;特别是和第三方有接口的时候&#xff0c;走的是SOAP协议&#xff0c;然后用户给你一个WSDL文件&#xff0c;说按照上面的进行适配&#xff0c;嘿嘿&#xff0c;这个时候&#xff0c;要是你以前没有…

集卡php源码,独角数卡自动发卡网PHP源码+教程:虚拟产品自助售卖

这款独角数卡自动发卡源码比大大目前在用的源码还要强大&#xff0c;测试了一下&#xff0c;不光可以零售还能批发&#xff0c;相当给力&#xff01;支付接口也是集成了很多&#xff0c;不仅支持支付宝当面付&#xff0c;还支持第三方的支付&#xff01;支付接口如下&#xff1…

思想已经高过行动好多了

好几天过去了&#xff0c;依然没什么起色&#xff0c;今天搜索一下论坛上自己的老帖&#xff0c;整理出来做个见证&#xff0c;看着自己才开始ASP的时候问的问题&#xff0c;不知所云。现在就不一样了&#xff0c;哈哈……在听了些微软的讲座之后&#xff0c;对设计模式很感兴趣…

【转】自旋锁-SpinLock(.NET 4.0+)

短时间锁定的情况下&#xff0c;自旋锁&#xff08;spinlock&#xff09;更快。&#xff08;因为自旋锁本质上不会让线程休眠&#xff0c;而是一直循环尝试对资源访问&#xff0c;直到可用。所以自旋锁线程被阻塞时&#xff0c;不进行线程上下文切换&#xff0c;而是空转等待。…

【转】.NET 自带的动态代理+Expression 实现AOP

下面代码&#xff08;摘抄之别处&#xff0c;原创在哪不知&#xff09;是采用TransparentProxy和RealProxy实现对象的动态代理。碍于其使用反射调用方法&#xff0c;所以就小试着将反射改成Expression以提高执行的效率。第15行就是原来代码中反射调用方法的关键代码。 1 using …

剖析Jive的缓存机制

剖析Jive的缓存机制- - 作者&#xff1a;张磊 本文选自&#xff1a;开放系统世界 2003年06月06日Jive是一个广受欢迎的开放源码的论坛项目&#xff0c;虽然推出了很多年&#xff0c;但至今很多Java程序员还对它津津乐道。从框架结构上看&#xff0c;它采用了很多设计模式&#…

主题:的中间层框架 第一节

主题:<插件式>的中间层框架 时间:2004-12-31 15:00 主讲:D10.天地弦 2004-12-31 14:56:15 /:>D10.天地弦(185511468) 开始吧&#xff0c;我们 2004-12-31 14:57:22 /:>D10.天地弦(185511468) 请大家先看图 http://www.jqk.net.cn/dkFrameworkWeb/dkFramework_fi…

qt5.11 linux oracle,Qt5.11.1 + VS2017环境搭建(Qt5.11在windows上的安装)

安装视频&#xff1a;《Qt5.11在windows‘上的编译安装》安装VisualStudio2017VS2017安装包 提取码&#xff1a;7db11&#xff0c;安装vs2017请确保勾选了“通用Windows平台开发”组件&#xff0c;否则VS2017将无法用来进行开发右侧的安装详细信息部分也尽量与上图一致。安装完…