本文主要探讨如何利用spring来装配组件，包括其事务上下文。从j2ee应用程序内部连接到单个的数据库并不是什么难事。但是，如果要装配或者集成企业级的组件，情况就复杂了。一个组件可以有一个或多个支持它的数据库，因此，当装配两个或更多的组件时，我们希望能够保持在跨组件的多个数据库中进行的操作的原子性。j2ee服务器为这些组件提供了一个容器来保证事务原子性和跨组件独立性。如果使用的不是j2ee服务器，则可以利用spring来帮助我们。spring基于inversion of control（控制反转）模式(也称为依赖注入)，它不仅可以连接组件服务，还可以连接关联的事务上下文。在本文中，我们将hibernate用作对象/关系持久性存储和查询服务。
装配组件事务
假设在企业组件库里，我们已经有一个审计组件，里面有可以被客户端调用的服务方法。然后，当我们想要构建一个订单处理系统时，我们发现存在这样的设计要求：orderlistmanager组件服务同样需要审计组件服务。orderlistmanager创建和管理订单，因此所有的orderlistmanager服务都有自己的事务属性。当我们从orderlistmanager服务内调用审计组件时，我们实际上是在把orderlistmanager服务的事务上下文传播给审计服务。也许将来新的业务服务组件同样需要审计组件，但那时将在一个不同的事务上下文中调用它。实际结果就是，即使审计组件的功能保持不变，它也可能是由别的业务服务功能组成，包含了混搭的（mix-and-match）事务属性来提供不同的运行时事务性行为。
在图1中有两个独立的调用上下文流程。在流程1里，如果客户端有tx上下文，那么orderlistmanager既可以参与其中，也可以启动一个新的tx，这取决于客户端是否在tx中，以及为orderlistmanager方法指定了什么样的tx属性。这同样适用于orderlistmanager服务依次调用auditmanager方法的情况。
图1 装配组件事务
ejb架构允许组件装配者声明式地给出正确的事务属性，从而为他们提供这种灵活性。我们不探讨声明式事务管理的替代方案（即所谓的编程式事务控制），因为这会牵涉到代码更改，从而产生不同的运行时事务行为。几乎所有的j2ee应用服务器都按照x/open xa规范提供了服从两阶段提交协议的分布式事务管理器。现在的问题是，我们能不能利用ejb服务器来实现相同的功能？spring就是其中的一种解决方案。让我们来看一下spring如何帮助我们解决事务组装的问题:
使用spring进行事务管理
我们将看到一个轻量级的事务基础架构，它实际上可以管理组件级的事务装配。spring是其中的一个解决方案。它的优点在于，我们不会被捆绑到j2ee容器服务（如jndi datasource）上。最棒的一点是，如果我们想把这个轻量级事务基础架构关联到一个已可用的j2ee容器基础架构，将不会有任何问题。看起来我们可以利用两者的优点。
另一方面，spring这个轻量级事务基础架构使用了一个面向方面编程（aspect-oriented programming，aop）框架。spring aop框架使用了一个支持aop的spring bean工厂。在特定于spring的配置文件applicationcontext.xml中，通过在组件服务级指定事务特性来划分事务。
<beans>
<!-- other code goes here... -->
<bean id="orderlistmanager"
class="org.springframework.transaction
.interceptor.transactionproxyfactorybean">
<property name="transactionmanager">
<ref local="transactionmanager1"/>
</property>
<property name="target">
<ref local="orderlistmanagertarget"/>
</property>
<property name="transactionattributes">
<props>
<prop key="getallorderlist">
propagation_required
</prop>
<prop key="getorderlist">
propagation_required
</prop>
<prop key="createorderlist">
propagation_required
</prop>
<prop key="addlineitem">
propagation_required,
-com.example.exception.facadeexception
</prop>
<prop key="getalllineitems">
propagation_required,readonly
</prop>
<prop key="querynumberoflineitems">
propagation_required,readonly
</prop>
</props>
</property>
</bean>
</beans>
一旦我们在服务级指定了事务属性，org.springframework.transaction.platformtransactionmanager接口的一个特定实现就会截获并解释它们。该接口如下：
public interface platformtransactionmanager{
transactionstatus gettransaction
(transactiondefinition definition);
void commit(transactionstatus status);
void rollback(transactionstatus status);
}
hibernate事务管理器
由于我们已决定使用hibernate作为orm工具，下一步要做的就是配置一个特定于hibernate的事务管理器实现。
<beans>
<!-- other code goes here... -->
<bean id="transactionmanager1"
class="org.springframework.orm.hibernate.
hibernatetransactionmanager">
<property name="sessionfactory">
<ref local="sessionfactory1"/>
</property>
</bean>
</beans>
设计多个组件中的事务的管理
现在，我们来讨论什么是“装配组件事务”。您也许注意到了为域中的服务级组件orderlistmanager所指定的各种tx属性。图2所示的业务域对象模型（business domain object model，bdom）显示了我们的域所确定的主要对象：
图2 业务域对象模型（bdom）
图字：order：订单；audit：审计
为了更好的说明，我们来列出我们的域中的一些非功能性需求（non-functional requirement，nfr）：
业务对象需要保存在一个数据库中（appfuse1）。
审计时要登录到另一个数据库中（appfuse2），出于安全的考虑，数据库要有防火墙保护。
业务组件应该可以重用。
必须尽一切努力审计业务服务层的所有活动。
考虑了以上要求之后，我们决定，orderlistmanager服务会将所有的审计日志调用委托给已经可用的auditmanager组件。这样就得出了详细设计，如图3所示：
图3 组件服务的设计
这里值得注意的一点是，由于我们的nfr，我们要将与orderlistmanager相关的对象映射到appfuse1数据库，而将与审计相关的对象映射到appfuse2。这样，无论要审计什么，orderlistmanager组件都会调用auditmanager组件。我们会看到，orderlistmanager组件中的所有方法都应该是事务性的，因为我们通过服务来创建订单和线项目（line item）。那么auditmanager组件中的服务呢？因为它做的是审计跟踪，我们关心的是尽可能维持长时间的审计跟踪，并针对系统中所有可能的业务活动。这就产生了如下的需求：“即使主要的业务活动失败了，也要进行审计跟踪记录”。auditmanager组件同样要有自己的事务，因为它也与自己的数据库进行交互。如下所示：
<beans>
<!-- other code goes here... -->
<bean id="auditmanager"
class="org.springframework.transaction.
interceptor.transactionproxyfactorybean">
<property name="transactionmanager">
<ref local="transactionmanager2"/>
</property>
<property name="target">
<ref local="auditmanagertarget"/>
</property>
<property name="transactionattributes">
<props>
<prop key="log">
propagation_requires_new
</prop>
</props>
</property>
</bean>
</beans>
现在，为了演示，我们把注意力放到createorderlist和addlineitem这两个业务服务上。同时请注意，我们并没有要求最佳设计策略――你可能注意到了，addlineitem方法抛出了facadeexception异常，而createorderlist却没有。在生产设计中，您也许希望每一个服务方法都可以处理异常场景。
public class orderlistmanagerimpl
implements orderlistmanager{
private auditmanager auditmanager;
public long createorderlist
(orderlist orderlist){
long orderid = orderlistdao.createorderlist(orderlist);
auditmanager.log(new auditobject(order + orderid, create));
return orderid;
}
public void addlineitem
(long orderid, lineitem lineitem)
throws facadeexception{
long lineitemid = orderlistdao.addlineitem(orderid, lineitem);
auditmanager.log(new auditobject(line_item + lineitemid, create));
int numberoflineitems = orderlistdao.
querynumberoflineitems(orderid);
if(numberoflineitems > 2){
log("added lineitem " + lineitemid +" to order " + orderid + ";
but rolling back *** !");
throw new facadeexception("make a new order for this line item");
}
else{
log("added lineitem " + lineitemid +" to order " + orderid + ".");
}
}
//other code goes here...
}
为了创建一个异常场景来进行演示，我们引入了另一种业务规则，它规定一个特定的订单不能包含多于两个的线项目。现在应该注意，我们是从createorderlist和addlineitem中调用auditmanager.log()方法的。您应该也注意到了为上述方法所指定的事务属性。
<bean id="orderlistmanager"
class="org.springframework.transaction.
interceptor.transactionproxyfactorybean">
<property name="transactionattributes">
<props>
<prop key="createorderlist">
propagation_required
</prop>
<prop key="addlineitem">
propagation_required,-com.
example.exception.facadeexception
</prop>
</props>
</property>
</bean>
<bean id="auditmanager" class="org.
springframework.transaction.interceptor.
transactionproxyfactorybean">
<property name="transactionattributes">
<props>
<prop key="log">
propagation_requires_new
</prop>
</props>
</property>
</bean>
propagation_required等效于tx_required，而propagation_requires_new等效于ejb中的tx_requires_new。如果我们想让服务方法始终在事务中运行，我们可以使用propagation_required。当使用propagation_required时，如果已经运行了一个tx，bean方法就会加入到该tx中；否则的话，spring的轻量级tx管理器就会启动一个tx。如果在调用组件服务时我们总是希望开始新的事务，那么可以利用propagation_requires_new属性。
我们还指定，当方法抛出facadeexception类型的异常时，addlineitem就总是回滚事务。这就达到了另一个粒度级别：在异常场景中，我们的控制可以精细到tx的具体结束方式。前缀符号“-”指定回滚tx，而前缀符号“+”指定提交tx。
接下来的问题是，为什么我们要为log方法设置propagation_requires_new属性呢？这是由我们的以下需求决定的：无论主服务方法发生什么情况，对所有创建订单以及向系统添加线项目的尝试都要记录审计跟踪。也就是说，即使在createorderlist和addlineitem的实现过程中出现了异常也要记录审计跟踪。这仅在启动一个新的tx并在这个新的tx上下文中调用log的时候起作用。这就是为什么要为log设置propagation_requires_new tx属性的原因：如果对下述方法的调用成功了
auditmanager.log(new auditobject(line_item +lineitemid, create));
，auditmanager.log()就将在新的tx上下文中执行，而且只要auditmanager.log()本身成功（即，没有抛出异常），新的上下文就会被提交。
设置演示环境
准备演示环境时，我参考了spring live这本书的流程：
- 下载并安装以下组件，这时请注意使用准确的版本，不然就会引起版本不兼容问题。
- jdk 1_5_0_01或更高版本
- apache tomcat 5.5.7
- apache ant 1.6.2
- equinox 1.2
- 在系统中设置以下环境变量：
- java_home
- catalina_home
- ant_home
- 把下列目录添加到您的path环境变量中，或者使用完全路径来执行脚本：
- java_homein
- catalina_homein
- ant_homein
- 要设置tomcat，在文本编辑器中打开/conf/tomcat-users.xml文件，验证以下各行是否存在。如果不存在，必须手动添加进去：
<role rolename="manager"/> <user username="admin"
password="admin" roles="manager"/>
- 要创建基于struts、spring和hibernate的web应用程序，必须用equinox来构建一个基本的框架程序(bare-bones starter application)，它将包含预定义的文件夹结构、所有需要用到的.jar文件以及ant构建脚本。把equinox解压到一个文件夹中，它将创建一个equinox文件夹。将目录更改为equinox文件夹，输入命令ant_homeinnt new -dapp.name=myusers。这样就会创建一个与equinox同级的文件夹myusers。该文件夹的具体内容如下：
图4 equinox的myusers应用程序文件夹模板
删除myuserswebweb-inf文件夹下的所有。xml文件。
复制equinoxxtrasstrutswebweb-infibstruts*.jar文件至myuserswebweb-infib文件夹下，这样，这个示例应用程序就可以利用struts了。
从参考资料小节的示例代码中，解压myusersextra.zip到一个合适的位置。将目录更改为新创建的myusersextra文件夹，复制myusersextra文件夹中的所有内容，并将它们粘贴到myusers文件夹。
打开命令提示符，将目录转至myusers目录下。执行catalina_homeinstartup.要从myusers文件夹启动tomcat，这一点非常重要，否则数据库将不会创建在myusers文件夹中，从而导致在执行一些定义在build.xml中的任务时出现错误。
再次打开命令提示符并将目录转至myusers目录下。执行ant_homeinnt install.这将构建应用程序并把它部署到tomcat中。这时，我们可以看到myusers中多了一个db目录，以便存放数据库appfuse1和appfuse2.
打开浏览器并验证myusers应用程序已经部署在http://localhost：8080/myusers/上了。
要重新安装应用程序，执行ant_homeinnt remove，然后执行catalina_homeinshutdown关闭tomcat.现在，从catalina_homewebapps文件夹删除所有的myusers文件夹。然后执行catalina_homeinstartup重新启动tomcat，并通过执行ant_homeinnt install重新安装应用程序。
运行演示
为了运行测试用例，myusers estmxampleservice中提供了一个junit测试类，orderlistmanagertest.要执行它，可以在构建应用程序的命令提示符中输入以下命令：
catalina_homeinnt test -dtestcase=orderlistmanager 测试用例分为两个主要部分：第一部分创建一个由两个线项目组成的订单，然后把这两个线项目链接到订单中。它可以成功运行，如下所示：
orderlist orderlist1 = new orderlist();
long orderid1 = orderlistmanager.
createorderlist(orderlist1);
log("created orderlist with id '"
+ orderid1 + "'...");
orderlistmanager.addlineitem(orderid1,lineitem1);
orderlistmanager.addlineitem(orderid1,lineitem2);
第二部分执行类似的操作，但是这次我们试图向订单添加三个线项目，这将产生一个异常：
orderlist orderlist2 = new orderlist();
long orderid2 = orderlistmanager.
createorderlist(orderlist2);
log("created orderlist with id '" + orderid2 + "'...");
orderlistmanager.addlineitem(orderid2,lineitem3);
orderlistmanager.addlineitem(orderid2,lineitem4);
//we know, we will have an exception here,still want to proceed
try{
orderlistmanager.addlineitem
(orderid2,lineitem5);
}
catch(facadeexception facadeexception){
log("error : " + facadeexception.getmessage());
}
控制台的输出如图5所示：
图5 客户端控制台输出
我们创建了order1，并向其添加了两个id为1和2的线项目。然后我们创建order2，并尝试添加3个项目，前两个（id为3和4）添加成功，但是图5显示，添加第三个项目（id为5）时业务方法遇到了异常。因此，业务方法tx被回滚，数据库中没有id为5的线项目。从控制台执行以下命令，就可以通过图6和图7进行验证：
catalina_homeinnt browse1
图6 appfuse1数据库中创建的订单
图7 appfuse1数据库中创建的线项目
在接下来的也是最重要的演示部分中可以看出，订单和线项目保存在appfuse1数据库中，而审计对象保存在appfuse2数据库中。实际上，orderlistmanager中的服务方法可以与多个数据库交互。启动appfuse2数据库，查看审计跟踪，如下所示：
catalina_homeinnt browse2
图8 创建到appfuse2数据库中的审计跟踪，包括失败tx的记录项
表8最后一行尤其值得注意，resource列显示这一行对应的是lineitem5。但是当我们回过来看图7时，却发现并没有对应于lineitem5的线项目。哪里出错了呢？事实上并没有出错，图7没有的那一行其实正是这篇文章的关键所在，让我们来看看是怎么回事。
我们知道，addlineitem()方法包含propagation_required属性，而log()方法有propagation_requires_new属性。而且addlineitem()在内部调用了log()方法。因此，当我们试图向order2添加第三个线项目时，就（按照我们的业务规则）引发了异常，于是这个线项目的创建以及将其链接到order2的操作都被回滚了。但是，因为还从addlineitem()中调用了log()，还因为log()具有propagation_requires_new tx属性，回滚addlineitem()将不会造成回滚log()，因为log()是在一个新的tx中执行。
让我们对log()的tx属性做一下改动，把propagation_requires_new替换为propagation_supports。propagation_supports属性允许服务方法在客户端有tx上下文时在客户端tx中运行；如果客户端没有tx，就不用tx而直接运行。您可能必须重新安装应用程序，以便数据库中已经可用的数据可以自动刷新。重新安装请按照“设置演示环境”中的步骤12进行。
如果再次运行，我们会发现一点不同。这次，在试图向order2添加第三个线项目时依然有异常，这将回滚试图添加第三个线项目的事务。而这个方法又调用了log()方法。但是由于它的propagation_supports tx属性，log()将在与addlineitem()方法相同的tx上下文中调用。由于addlineitem()回滚，log()也回滚了，没有留下回滚的tx的审计跟踪。所以在图9中没有对应于失败tx的审计跟踪记录项!
图9 创建在appfuse2数据库中的审计跟踪，没有失败tx的记录项
我们改动的仅仅是spring配置文件中的tx属性，就产生了这样不同的事务行为，如下所示：
<bean id="auditmanager" class="org.springframework.transaction.interceptor.transactionproxyfactorybean">
<property name="transactionattributes">
<props>
<!-- prop key="log">
propagation_requires_new
</prop -->
<prop key="log">
propagation_supports
</prop>
</props>
</property>
</bean>
这就是声明式事务管理的效果。自从ejb出现以来我们就一直在使用这种方法，但是我们需要一个高端的应用服务器来驻留ejb组件。现在，我们可以看到，利用spring，没有ejb服务器也可以达到类似的结果。
结束语
这篇文章重点介绍了j2ee领域的强大组合之一：spring和hibernate。利用二者的功能，现在对于容器管理持久性(container-managed persistence，cmp)、容器管理关系(container-managed relationships，cmr)和声明式事务管理，我们多了一种技术选择。虽然spring不能视为ejb的替代方案，但是它提供的许多功能，例如普通java对象的声明式事务管理，使得在许多项目中没有ejb也完全可以。
本文的目的不是要寻找ejb的替代方案，而是为当前的问题找出一个最可行的技术方案。至于spring和hibernate的轻量级组合的更多功能，就留给我们的读者去探索了。
闽公网安备 35060202000074号