网站设计导航,wordpress获取文章发表时间,做养生网站需要证件吗,怎么样做网站爬虫在介绍这两个概念之前#xff0c;我们先看看是什么是X/Open DTP模型。X/Open X/Open#xff0c;即现在的open group#xff0c;是一个独立的组织#xff0c;主要负责制定各种行业技术标准。X/Open组织主要由各大知名公司或者厂商进行支持#xff0c;这些组织不光遵循X/Ope…在介绍这两个概念之前我们先看看是什么是X/Open DTP模型。X/Open X/Open即现在的open group是一个独立的组织主要负责制定各种行业技术标准。X/Open组织主要由各大知名公司或者厂商进行支持这些组织不光遵循X/Open组织定义的行业技术标准也参与到标准的制定。官网地址http://www.opengroup.org/X/Open DTP 全称 X/Open Distributed Transaction Processing Reference是X/Open这个组织定义出的一套分布式事务标准。DTP参考模型https://pubs.opengroup.org/onlinepubs/9294999599/toc.pdfX/Open DTP模型组成X/Open DTP 定义了三个组件APTMRM 和两个协议XA、TXAP(Application Program)也就是应用程序可以理解为使用DTP的程序RM(Resource Manager)资源管理器这里可以理解为一个DBMS系统或者消息服务器管理系统应用程序通过资源管理器对资源进行控制。TM(Transaction Manager)事务管理器负责协调和管理事务提供给AP应用程序编程接口以及管理资源管理器。XA协议应用或应用服务器与事务管理之前通信的接口TX协议全局事务管理器与资源管理器之间通信的接口编程方式1. 配置TM通过TM或者RM提供的方式把RM注册到TM。可以理解为给TM注册RM作为数据源。一个TM可以注册多个RM。1. AP从TM获取资源管理器的代理(例如使用JTA接口从TM管理的上下文中获取出这个TM所管理的RM的JDBC连接或JMS连接)2. AP向TM发起一个全局事务。这时TM会通知各个RM。XID(全局事务ID)会通知到各个RM。3. AP通过1中获取的连接直接操作RM进行业务操作。这时AP在每次操作时把XID(包括所属分支的信息)传递给RMRM正是通过这个XID与2步中的XID关联来知道操作和事务的关系的。4. AP结束全局事务。此时TM会通知RM全局事务结束。5. 开始二段提交也就是prepare - commit的过程。XA协议如上图所示XA规范的最主要的作用是就是定义了RM-TM的交互接口。下图更加清晰了演示了XA规范在DTP模型中发挥作用的位置。其实这个协议只是定义了xa_和ax_系列的函数原型以及功能描述、约束和实施规范等。至于RM和TM之间通过什么协议通信则没有提及。目前知名的数据库如Oracle, DB2等都是实现了XA接口的都可以作为RM。XA规范除了定义的RM-TM交互的接口(XA Interface)之外还对两阶段提交协议进行了优化。两阶段提交和三阶段提交这里不做介绍了。XA规范中定义的RM 和 TM交互的接口如下图所示 JTA上述接口规范不是针对某种语言的java是如何来落实上述规范的呢这就是JTA的内容了。JTAJava Transaction API Java事务API。oracle官方JTA规范https://download.oracle.com/otn-pub/jcp/jta-1.1-spec-oth-JSpec/jta-1_1-spec.pdf?AuthParam1607398216_8fd3922762196dfe6e8b27eb50190cc1规范中定义了JTA模型图如下包括五个参与者TM(transaction manager): 事务管理器提供支持事务界定、事务资源管理、同步和事务上下文传播所需的服务和管理功能。AS(application server): 应用服务器提供了支持应用程序运行时环境所需的基础设施其中包括事务状态管理。此类应用程序服务器的一个例子就是EJB服务器。jboss、weblogic、websphere等都是支持JTA规范的。注意tomcat不支持JTA规范所以只能使用第三方的TM库如JOTM和Atomikos。将TM直接整合进应用中不再依赖于AS。RM(resource manager)资源管理器为应用程序提供对资源的访问。RM通过实现事务资源接口来参与分布式事务。这个事务资源接口是给TM用于沟通事务关联、事务完成和恢复工作的。例如关系数据库服务器。AP(application program)一个基于组件的事务型应用程序通过声明性事务属性设置提供事务管理支持。CRM(communication resource manager)通信资源管理器支持事务上下文传播和对传入和传出请求的事务服务的访问。JTA规范没有指定与通信相关的要求。有关TM之间互操作性的更多细节请参阅JTS规范。JTA接口JTA是java扩展包在应用中需要额外引入相应的jar包依赖 javax.transaction jta 1.1一共8个接口XAResourceXA资源管理器接口RM提供给TM调用。XAResource接口是基于X/Open CAE规范(分布式事务处理:XA规范)的行业标准XA接口的Java映射。XidXid接口是X/Open事务标识Xid结构的Java映射。此接口指定三个方法:分别获取全局事务的格式化ID、全局事务ID和分支限定符。TM和RM使用Xid接口。此接口对AP和AS都不可见。Status:定义事务状态。共指定10个状态Synchronization同步接口。事务同步允许AS在事务完成之前和之后从TM获得通知。Transaction事务定义接口。每个全局事务都与一个事务对象关联。TransactionManager事务管理器。管理事务的全生命周期。TransactionSynchronizationRegistry事务同步注册器。用于系统级AS组件(如持久化管理器)。这提供了注册具有特殊排序语义的同步对象、将资源对象与当前事务关联、获取当前事务的事务上下文、获取当前事务状态以及将当前事务标记为回滚的能力。UserTransaction事务客户端封装了用户可直接操作事务的接口。注意这些接口都不需要开发者去实现XAResource、Xid 由数据库厂商实现。TransactionManager、UserTransaction等操作事务相关的接口由AS厂商实现(例如web服务就是jboss、weblogic或者第三方事务类库jotm、Atomikos)。用户只需要使用UserTransaction的实现类来操控事务的创建、提交、回滚即可是不是轻松加愉快- -当然简单点直接使用注解也是可以的。TM供应商 实现UserTransaction、TransactionManager、Transaction、TransactionSynchronizationRegistry、Synchronization、Xid接口通过与XAResource接口交互来实现分布式事务。此外TM厂商如果要支持跨应用的分布式事务那么还要实现JTS规范定义的接口。 常见的TM提供者包括我们前面提到的application server包括:jboss、ejb server、weblogic等以及一些以第三方类库形式提供事务管理器功能的jotm、Atomikos。RM供应商 XAResource接口需要由资源管理器者来实现XAResource接口中定义了一些方法这些方法将会被TM进行调用如 start方法开启事务分支 end方法结束事务分支 prepare方法准备提交 commit方法提交 rollback方法回滚 recover方法列出所有处于PREPARED状态的事务分支 一些RM提供者可能也会提供自己的Xid接口的实现。 此外不同的资源管理器有一些各自的特定接口要实现 如JDBC2.0规范定义支持分布式事务的jdbc driver需要实现javax.sql.XAConnection、javax.sql.XADataSource接口 JMS1.0规范规定支持分布式事务的JMS厂商需要实现javax.jms.XAConnection、javax.jms.XASession接口开发者用户只需要使用UserTransaction的实现类来操控事务的创建、提交、回滚即可。以下案例演示了UserTransaction接口的基本使用构建一个分布式事务来操作位于2个不同的数据库的数据假设这两个库中都有一个user表。 UserTransaction userTransaction... try{ //开启分布式事务 userTransaction.begin(); //执行事务分支1 conn1 db1.getConnection(); ps1 conn1.prepareStatement(INSERT into user(name,age) VALUES (tianshouzhi,23)); ps1.executeUpdate(); //执行事务分支2 conn2 db2.getConnection(); ps2 conn2.prepareStatement(INSERT into user(name,age) VALUES (tianshouzhi,23)); ps2.executeUpdate(); //提交两阶段提交发生在这个方法内部 userTransaction.commit(); }catch (Exception e){ try { userTransaction.rollback();//回滚 } catch (SystemException ignore) { } }AS对JTA的支持基于2个条件分析AS对JTA的支持。1.应用程序的事务和资源使用由AS管理。2.对底层TM的访问是通过资源适配器实现的。例如可以使用JDBC 2.0驱动程序访问关系数据库(底层通过connection管理事务资源)典型场景如上图1. 上图底部蓝色方框RMAdapter适配器.AS调用Adapter来创建TransactionalResource对象。TransactionalResource关联2个对象:一个对象实现Connection接口另一个实现javax.transaction.xa.XAResource接口。2.上图中部红色方框AS获取一个TransactionalResource对象通过getXAResource方法获得XAResource对象。AS使用Transaction.enlistResource()方法将XAResource注册到TM。3.上图左上角TM调用XAResource.start()方法,通过Connection,将执行的工作与事务关联起来。4.上图右上角AP调用AS的getConnection()方法来获取Connection对象执行业务操作。时序图附上时序图如下1.AS调用TM的start()方法开启一个事务。2.Ap调用AS的getConnection()方法获取Connection。3.AS调用RM适配器的ResourceFactory.getTransactionalResource()获取TransactionalResource对象(内部new 一个Connection,new 一个XAResource)4.AS调用RM适配器getXAResource()方法获取XAResource。5.AS调用TM的enlistResource()方法把XAResource注册到TM中。6.TM调用start()方法把当前事务关联到XAResource上。7.AS调用TransactionalResource的getConnection()方法并返回Connection给AP。8.Ap通过这个Connection执行操作。执行完毕后close 这个connection。9.RM适配器通知AS connection 已经close,AS调用TM的delistResouce()删除这些XAResource。10.TM调用XAResource.end()方法将事务与XAResource分离。11.AS调用TM的commit()方法提交事务。12.TM调用XAResource.prepare()方法通知RM预提交事务。13.TM调用XAResource.commit()方法通知RM提交事务。参考博客https://www.cnblogs.com/dennyzhangdd/p/10638201.htmlhttp://www.tianshouzhi.com/api/tutorials/distributed_transaction/385
