与Atomikos的两阶段提交（2PC）配置

Question

我正在创建一个示例应用程序来测试两阶段提交（2PC）。我已经从互联网上使用了这里使用的代码位。我使用Spring作为后端，使用Hibernate和Atomikos。我正在使用两个数据库并故意让对第二个数据库的调用无法检查第一个数据库调用是否回滚。可悲的是，它似乎并没有工作。有人可以指向一些示例代码的链接吗？

以下是我的配置：
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我注入了两个sessi上面定义的onFactories。以下是来自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); 
} 

任何指针都会有很大的帮助。

感谢

Answer 1

为了让你期望你需要执行你的DAO调用同一个事务中，比如行为，如下所示：

final StockBo stockBo = (StockBo)appContext.getBean("stockBo1"); 
final StockBo stockBo2 = (StockBo)appContext.getBean("stockBo2"); 
TransactionTemplate tx = new TransactionTemplate(appContext.getBean(PlatformTransactionManager.class); 

tx.execute(new TransactionCallback<Void>() { 
    public Void doInTransaction(TransactionStatus ts) { 
     /** 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); 

     return null; 
    } 
}); 

另外，我觉得你不需要下面几行，因为你与配置Hibernate的春天：

<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> 

另请参见：

• 10. Transaction Management