java - JTA，Hibernate与Atomikos多个XA数据源无法在SpringBoot中维护事务

我有2个MySQL模式和相应的MysqlXADataSource配置如下-

@Bean(name = "sourceDataSource")
@Primary
public DataSource dataSource() {
    MysqlXADataSource dataSource = new MysqlXADataSource();
    dataSource.setPinGlobalTxToPhysicalConnection(true);
    dataSource.setUrl(DB_URL);
    dataSource.setUser(DB_USERNAME);
    dataSource.setPassword(DB_PASSWORD);

    AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();
atomikosDataSourceBean.setUniqueResourceName("SourceDB");
    atomikosDataSourceBean.setXaDataSource(dataSource);

    /*DriverManagerDataSource dataSource = new DriverManagerDataSource();
    dataSource.setDriverClassName(DB_DRIVER);
    dataSource.setUrl(DB_URL);
    dataSource.setUsername(DB_USERNAME);
    dataSource.setPassword(DB_PASSWORD);*/
    System.out.println("Creatign Source data source.");
    return atomikosDataSourceBean;
}

@Bean(name = "sourceSessionFactory")
public LocalSessionFactoryBean sessionFactory(@Qualifier("jtaTransactionManager") JtaTransactionManager jts) {
    LocalSessionFactoryBean sessionFactoryBean = new LocalSessionFactoryBean();
    sessionFactoryBean.setDataSource(dataSource());
    sessionFactoryBean.setPackagesToScan(ENTITYMANAGER_PACKAGES_TO_SCAN);
    Properties hibernateProperties = new Properties();
    hibernateProperties.put("hibernate.dialect", HIBERNATE_DIALECT);
    hibernateProperties.put("hibernate.show_sql", HIBERNATE_SHOW_SQL);
    hibernateProperties.put("hibernate.hbm2ddl.auto", HIBERNATE_HBM2DDL_AUTO);
    hibernateProperties.put("hibernate.transaction.factory_class", "org.hibernate.engine.transaction.internal.jta.CMTTransactionFactory");
    hibernateProperties.put("hibernate.transaction.coordinator_class", "jta");
    hibernateProperties.put("hibernate.transaction.jta.platform", "com.atomikos.icatch.jta.hibernate4.AtomikosPlatform");

    //hibernateProperties.put("hibernate.transaction.jta.platform", AtomikosJtaPlatform.class.getName());
    sessionFactoryBean.setJtaTransactionManager(jts);
    sessionFactoryBean.setHibernateProperties(hibernateProperties);
    System.out.println("Creatign Source Session Factory.");
    return sessionFactoryBean;
}

和

@Bean(name="destinationDataSource")
public DataSource dataSource() {
    MysqlXADataSource dataSource = new MysqlXADataSource();
    dataSource.setPinGlobalTxToPhysicalConnection(true);
    dataSource.setUrl(DB_URL);
    dataSource.setUser(DB_USERNAME);
    dataSource.setPassword(DB_PASSWORD);

    AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();
atomikosDataSourceBean.setUniqueResourceName("DestinationDB");
    atomikosDataSourceBean.setXaDataSource(dataSource);

    /*DriverManagerDataSource dataSource = new DriverManagerDataSource();
    dataSource.setDriverClassName(DB_DRIVER);
    dataSource.setUrl(DB_URL);
    dataSource.setUsername(DB_USERNAME);
    dataSource.setPassword(DB_PASSWORD);

    System.out.println("Creatign Destination Data Source.");*/
    return atomikosDataSourceBean;
}

@Bean(name="destinationSessionFactory")
public LocalSessionFactoryBean sessionFactory(@Qualifier("jtaTransactionManager") JtaTransactionManager jts) {
    LocalSessionFactoryBean sessionFactoryBean = new LocalSessionFactoryBean();
    sessionFactoryBean.setDataSource(dataSource());
    sessionFactoryBean.setPackagesToScan(ENTITYMANAGER_PACKAGES_TO_SCAN);
    Properties hibernateProperties = new Properties();
    hibernateProperties.put("hibernate.dialect", HIBERNATE_DIALECT);
    hibernateProperties.put("hibernate.show_sql", HIBERNATE_SHOW_SQL);
    hibernateProperties.put("hibernate.hbm2ddl.auto", HIBERNATE_HBM2DDL_AUTO);
    hibernateProperties.put("hibernate.transaction.factory_class", "org.hibernate.engine.transaction.internal.jta.CMTTransactionFactory");
    hibernateProperties.put("hibernate.transaction.coordinator_class", "jta");
    hibernateProperties.put("hibernate.transaction.jta.platform", "com.atomikos.icatch.jta.hibernate4.AtomikosPlatform");
    sessionFactoryBean.setJtaTransactionManager(jts);
    sessionFactoryBean.setHibernateProperties(hibernateProperties);
    System.out.println("Creatign Destination Session Factoy.");
    return sessionFactoryBean;
}

交易配置

@Bean("transactionManager")
public UserTransactionManager transactionManager(){
    UserTransactionManager userTransactionManager = new UserTransactionManager();
    return userTransactionManager;
}

@Bean("userTransaction")
public UserTransaction userTransaction(){
    J2eeUserTransaction userTransaction = new J2eeUserTransaction();
    return userTransaction;
}

@Bean("jtaTransactionManager")
public JtaTransactionManager jtaTransactionManager(@Qualifier("transactionManager") UserTransactionManager userTransactionManager, @Qualifier("userTransaction") UserTransaction userTransaction) {
    JtaTransactionManager transactionManager = new JtaTransactionManager();
    transactionManager.setTransactionManager(userTransactionManager);
    transactionManager.setUserTransaction(userTransaction);
    //transactionManager.setSessionFactory(sessionFactory().getObject());
    System.out.println("Creatign JTA Transaction Manager.");
    return transactionManager;
}

服务...

@Transactional(transactionManager = "jtaTransactionManager", propagation=Propagation.REQUIRES_NEW, rollbackFor=Exception.class, timeout=500000)
public void transform() throws JobExecutionException{
    System.out.println("START == Starting Trandformation ... ");

    //Clean Up
    transformProduct.cleanUp();
    transformService.cleanUp();
    transformResources.cleanUp();

    transformResources.transform();
    transformService.transform();
    transformProduct.transform();
    LOG.info("END == Starting Transformation ... ");
    throw new JobExecutionException();
}

并且有相应的子服务类transformProduct，transformService和transformResources，这些类使用的是sessionFactory实现的dao类。我没有提到提交或回滚的地方。一切都应该是跨国的。但不知何故

最佳答案

好的。代码有误-


XA数据源必须用AtomikosDataSourceBean包装，并且应返回AtomikosDataSourceBean引用。
为AtomikosDataSourceBean指定唯一的名称。
服务方法应设为@Transactional(transactionManager = "jtaTransactionManager" ...)，提供Spring JtaTransactionManager。
应该使用具有JtaTransactionManager实现的javax.transaction.UserTransaction引用com.atomikos.icatch.jta.J2eeUserTransaction。
JtaTransactionManager应在com.atomikos.icatch.jta.UserTransactionManager实现中引用。
该问题的其余部分是正确的。


这是对Atomikos的直接支持。