我创建了一个示例应用程序来测试两阶段提交（2PC）。 我采取从互联网上这里使用的码位。 我使用Spring，Hibernate和Atomikos公司使用MySQL作为后端。 我使用的两个数据库，故意使调用第二数据库无法检查的第一个数据库调用是否会被回滚。 可悲的是它似乎并没有工作。 有人可以点我一些示例代码一些链接？
以下是我的配置：
Hibernate的会话工厂：
<bean id="sessionFactory1" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource">
<ref bean="dataSource1"/>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.connection.isolation">3</prop>
<prop key="hibernate.current_session_context_class">jta</prop>
<prop key="hibernate.transaction.factory_class">org.hibernate.transaction.JTATransactionFactory</prop>
<prop key="hibernate.transaction.manager_lookup_class">com.atomikos.icatch.jta.hibernate3.TransactionManagerLookup</prop>
<prop key="hibernate.connection.release_mode">on_close</prop>
</props>
</property>
<property name="mappingResources">
<list>
<value>/hibernate/Stock.hbm.xml</value>
</list>
</property>
</bean>
<bean id="sessionFactory2" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource">
<ref bean="dataSource2"/>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.connection.isolation">3</prop>
<prop key="hibernate.current_session_context_class">jta</prop>
<prop key="hibernate.transaction.factory_class">org.hibernate.transaction.JTATransactionFactory</prop>
<prop key="hibernate.transaction.manager_lookup_class">com.atomikos.icatch.jta.hibernate3.TransactionManagerLookup</prop>
<prop key="hibernate.connection.release_mode">on_close</prop>
</props>
</property>
<property name="mappingResources">
<list>
<value>/hibernate/Stock1.hbm.xml</value>
</list>
</property>
</bean>
数据源配置：
<bean id="dataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
<!-- set an arbitrary but unique name for the datasource -->
<property name="uniqueResourceName"><value>XADBMS1</value></property>
<!-- set the underlying driver class to use, in this example case we use MySql -->
<property name="xaDataSourceClassName">
<value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>
</property>
<property name="xaProperties">
<!-- set the driver-specific XADataSource properties (check your driver docs for more info) -->
<props>
<prop key="user">${jdbc.username}</prop>
<prop key="password">${jdbc.password}</prop>
<prop key="URL" >${jdbc.url1}</prop>
</props>
</property>
<!-- how many connections in the pool? -->
<property name="poolSize" value="3"/>
</bean>
<bean id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
<!-- set an arbitrary but unique name for the datasource -->
<property name="uniqueResourceName"><value>XADBMS2</value></property>
<!-- set the underlying driver class to use, in this example case we use MySql -->
<property name="xaDataSourceClassName">
<value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>
</property>
<property name="xaProperties">
<!-- set the driver-specific XADataSource properties (check your driver docs for more info) -->
<props>
<prop key="user">${jdbc.username}</prop>
<prop key="password">${jdbc.password}</prop>
<prop key="URL" >${jdbc.url2}</prop>
</props>
</property>
<!-- how many connections in the pool? -->
<property name="poolSize" value="3"/>
</bean>
Spring的JTA配置：
<bean id="AtomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">
<!-- when close is called, should we force transactions to terminate or not? -->
<property name="forceShutdown" value="false" />
</bean>
<!--Also use Atomikos UserTransactionImp, needed to configure Spring -->
<bean id="AtomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
<property name="transactionTimeout" value="300" />
</bean>
<!--Configure the Spring framework to use JTA transactions from Atomikos -->
<bean id="JtaTransactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManager" ref="AtomikosTransactionManager" />
<property name="userTransaction" ref="AtomikosUserTransaction" />
</bean>
我有两个DAOImpl进我注入上述定义的两个sessionFactories。 以下是从Java代码调用：
public static void main( String[] args )
{
ApplicationContext appContext =
new ClassPathXmlApplicationContext("spring/config/appContext.xml");
StockBo stockBo = (StockBo)appContext.getBean("stockBo1");
StockBo stockBo2 = (StockBo)appContext.getBean("stockBo2");
/** insert **/
Stock stock = new Stock();
stock.setStockCode("7668");
stock.setStockName("HAIO");
stockBo.save(stock);
Stock stock1 = new Stock();
//stock1.setStockCode("1668"); **Commented to fail the second db insert**
stock1.setStockName("AAIO");
stockBo2.save(stock1);
}
任何指针将有很大的帮助。
谢谢
