释放双眼，带上耳机，听听看~！
分布式事务是指操作多个数据库之间的事务，spring的org.springframework.transaction.jta.JtaTransactionManager，提供了分布式事务支持。如果使用WAS的JTA支持，把它的属性改为WebSphere对应的TransactionManager。
在tomcat下，是没有分布式事务的，不过可以借助于第三方软件jotm（Java Open Transaction Manager ）和AtomikosTransactionsEssentials实现，在spring中分布式事务是通过jta（jotm，atomikos）来进行实现。
一、使用JOTM例子
(1) Dao及实现
GenericDao接口：
2
3
4
5
2 public int save(String ds, String sql, Object[] obj) throws Exception;
3 public int findRowCount(String ds, String sql);
4 }
5
GenericDaoImpl 实现：
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
2 private JdbcTemplate jdbcTemplateA;
3 private JdbcTemplate jdbcTemplateB;
4 public void setJdbcTemplateA(JdbcTemplate jdbcTemplate) {
5 this.jdbcTemplateA = jdbcTemplate;
6 }
7 public void setJdbcTemplateB(JdbcTemplate jdbcTemplate) {
8 this.jdbcTemplateB = jdbcTemplate;
9 }
10 public int save(String ds, String sql, Object[] obj) throws Exception{
11 if(null == ds || "".equals(ds))
12 return -1;
13 try{
14 if(ds.equals("A")){
15 return this.jdbcTemplateA.update(sql, obj);
16 }else{
17 return this.jdbcTemplateB.update(sql, obj);
18 }
19 }catch(Exception e){
20 e.printStackTrace();
21 throw new Exception("执行" + ds + "数据库时失败！");
22 }
23 }
24 public int findRowCount(String ds, String sql) {
25 if(null == ds || "".equals(ds))
26 return -1;
27 if(ds.equals("A")){
28 return this.jdbcTemplateA.queryForInt(sql);
29 }else{
30 return this.jdbcTemplateB.queryForInt(sql);
31 }
32 }
33}
34
(2) Service及实现
UserService 接口：
2
3
4
2 public void saveUser() throws Exception;
3}
4
UserServiceImpl 实现：
2
3
4
5
2 private GenericDao genericDao;
3 public void setGenericDao(GenericDao genericDao) {
4 this.genericDao = genericDao; } public void saveUser() throws Exception { String userName = "user_" + Math.round(Math.random()*10000); System.out.println(userName); StringBuilder sql = new StringBuilder(); sql.append(" insert into t_user(username, gender) values(?,?); "); Object[] objs = new Object[]{userName,"1"}; genericDao.save("A", sql.toString(), objs); sql.delete(0, sql.length()); sql.append(" insert into t_user(name, sex) values(?,?); "); objs = new Object[]{userName,"男的"};//值超出范围 genericDao.save("B", sql.toString(), objs); }}
5
(3) applicationContext-jotm.xml
2
2
(4) 测试
2
2
二、关于使用atomikos实现
(1) 数据源配置
2
2
(2)、事务配置
2
2
有关JTA
JTA全称为Java Transaction API，顾名思义JTA定义了一组统一的事务编程的接口，这些接口如下：
**XAResource **
XAResource接口是对实现了X/Open CAE规范的资源管理器 (Resource Manager，数据库就是典型的资源管理器) 的抽象，它由资源适配器 (Resource Apdater) 提供实现。XAResource是支持事务控制的核心。
Transaction
Transaction接口是一个事务实例的抽象，通过它可以控制事务内多个资源的提交或者回滚。二阶段提交过程也是由Transaction接口的实现者来完成的。
TransactionManager
托管模式 (managed mode) 下，TransactionManager接口是被应用服务器调用，以控制事务的边界的。
UserTransaction
非托管模式 (non-managed mode) 下，应用程序可以通过UserTransaction接口控制事务的边界
托管模式下的事务提交场景
注意：在上图中3和5的步骤之间省略了应用程序对资源的操作 (如CRUD)。另外，应用服务器什么时机 enlistResource，又是什么时候delistResource呢？这在后文中会解释。
有关JCA
下图为JCA的架构图
中间涉及元素说明如下：
1）Enterprise Information System
简称EIS，在JTA中它又被称为资源管理器。典型的EIS有数据库，事务处理系统(Transaction Processing System)，ERP系统。
2）Resource Adapter
资源适配器(Resource Adaper)是JCA的关键。要想把不同的EIS整合(或者连接)到J2EE运行环境中，就必须为每个EIS提供资源适配器，它会将将EIS适配为一个具备统一编程接口的资源 (Resource) 。这个统一编程接口就是上图中的System Contracts和Client API。下面的UML类图将完美诠释资源适配器。
3）Application Server
应用服务器 (Application Server) 通过System Contracts来管理对EIS的安全、事务、连接等。典型的应用服务器有JBoss、JOnAS、Geronimo、GlassFish等。
4）Application Component
应用组件 (Application Component) ，它封装了应用业务逻辑，像对资源的访问和修改。典型的应用组件就是EJB。
更多细节请参见：
Sun Microsystems Inc.J2EE Connector Architecture 1.5
