分布式事务是指操作多个数据库之间的事务，为了保证事物的一致性，一般都采用2阶段提交的办法实现。
这里强调下一致性要求，如果追求强一致性就只能采用JTA事物实现。如果是最终一致性就不需要JTA实现了，可以采用异步消息队列实现。我这里用的是spring提供的JTA事物，因为这是个人习惯。
2.服务端实现与配置
服务端采用CXF 写webservice实现，关于webservice的实现与配置可以自行百度实现。我在服务端写了多个配置文件，其中一个是webservice的发布文件，一个是实现DAO层的配置，这里是不需要声明事物和对应切面的，但是一定要配置支持XA的数据源。JTA事物的配置在客户端实现。我项目里数据源采用阿里的druid。服务端的结果通过json传递给客户端。
服务端部分配置如下：
<bean/>
<jaxws:server serviceClass="com.liuyu.service.HelloServiceI" address="/Hello">
<jaxws:serviceBean>
<ref bean="helloServiceBean"/>
</jaxws:serviceBean>
</jaxws:server>
3.客户端测试
客户端部分配置文件如下：
<bean
init-method="init" destroy-method="close">
<property value="true" />
</bean>
<beanhttps://www.linuxidc.com/topicnews.aspx?tid=3" target="_blank" title="SUSE">SUSErTransaction">
<property value="300" />
</bean>
<!-- JTA事务管理器 -->
<bean
>
<property ref="atomikosTransactionManager" />
<property ref="atomikosUserTransaction" />
</bean>
<!-- 事务管理 -->
<tx:advice transaction-manager="springTransactionManager">
<tx:attributes>
<tx:method propagation="REQUIRED"/>
<tx:method propagation="REQUIRED"/>
<tx:method propagation="REQUIRED"/>
<tx:method propagation="REQUIRED"/>
<tx:method propagation="REQUIRED"/>
<tx:method propagation="REQUIRED"/>
<tx:method read-only="true" />
</tx:attributes>
</tx:advice>
<aop:config proxy-target-class="true">
<aop:advisor advice-ref="txAdvice" pointcut="execution(* com.liuyu.test..*.*(..))" />
</aop:config>
客户端实现类部分如下：
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath*:applicationContext-client.xml" })
@Transactional
@TransactionConfiguration(defaultRollback = false)
public class TestClient {
@Autowired
private HelloServiceI service;
@Autowired
private DemoServiceI demoService;
@Test
public void saveInfo() {
service.insertHello("2222", "kkkkk");
demoService.insertHello("2222", "jjj");
}
//@Test
public void queryAllXA() {
String str = demoService.queryAll();
List<HashMap<String, Object>> list=JSON.parseObject(str, new TypeReference<List<HashMap<String,Object>>>(){});
for(Map<String, Object> m:list){
System.out.println(m.get("id").toString()+" "+m.get("username").toString());
}
}
}
测试结果如下：
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING core version: 3.9.3
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.automatic_resource_registration = true
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.client_demarcation = false
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.threaded_2pc = false
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.serial_jta_transactions = true
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.serializable_logging = true
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.log_base_dir = .\
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.max_actives = 50
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.checkpoint_interval = 500
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.enable_logging = true
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.output_dir = .\
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.log_base_name = tmlog
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.max_timeout = 300000
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.tm_unique_name = 192.168.135.100.tm
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING java.naming.factory.initial = com.sun.jndi.rmi.registry.RegistryContextFactory
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING java.naming.provider.url = rmi://localhost:1099
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.service = com.atomikos.icatch.standalone.UserTransactionServiceFactory
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.force_shutdown_on_vm_exit = false
[com.atomikos.icatch.config.imp.AbstractUserTransactionService]USING com.atomikos.icatch.default_jta_timeout = 10000
[org.springframework.transaction.jta.JtaTransactionManager]Using JTA UserTransaction: com.atomikos.icatch.jta.UserTransactionImp@101b7cf
[org.springframework.transaction.jta.JtaTransactionManager]Using JTA TransactionManager: com.atomikos.icatch.jta.UserTransactionManager@1cab519
一月 20, 2015 4:44:56 下午 org.apache.cxf.wsdl.service.factory.ReflectionServiceFactoryBean buildServiceFromClass
信息: Creating Service {}HelloServiceIService from class com.liuyu.service.HelloServiceI
一月 20, 2015 4:44:57 下午 org.apache.cxf.wsdl.service.factory.ReflectionServiceFactoryBean buildServiceFromClass
信息: Creating Service {}DemoServiceIService from class com.liuyu.demo.service.DemoServiceI
[com.atomikos.icatch.imp.thread.TaskManager]THREADS: using JDK thread pooling...
[com.atomikos.icatch.imp.BaseTransactionManager]createCompositeTransaction ( 300000 ): created new ROOT transaction with id 192.168.135.100.tm0000100002
[org.springframework.test.context.transaction.TransactionContext]Began transaction (1) for test context [DefaultTestContext@f2ed42 testClass = TestClient, testInstance = com.liuyu.test.TestClient@b691c6, testMethod = saveInfo@TestClient, testException = [null], mergedContextConfiguration = [MergedContextConfiguration@1c63a8 testClass = TestClient, locations = '{classpath*:applicationContext-client.xml}', classes = '{}', contextInitializerClasses = '[]', activeProfiles = '{}', propertySourceLocations = '{}', propertySourceProperties = '{}', contextLoader = 'org.springframework.test.context.support.DelegatingSmartContextLoader', parent = [null]]]; transaction manager [org.springframework.transaction.jta.JtaTransactionManager@1d2d7c9]; rollback [false]
[com.atomikos.icatch.imp.CompositeTransactionImp]commit() done (by application) of transaction 192.168.135.100.tm0000100002
基于 Spring 设计并实现 RESTful Web Services