Spring分布式事务配置(atomikos)

框架：SpringBoot

组件：Atomikos

IDE：Intellij

Spring Boot supports distributed JTA transactions across multiple XA resources using either an Atomikos or Bitronix embedded transaction manager. JTA transactions are also supported when deploying to a suitable Java EE Application Server.

Atomikos is a popular open source transaction manager which can be embedded into your Spring Boot application. You can use the spring-boot-starter-jta-atomikos Starter POM to pull in the appropriate Atomikos libraries. Spring Boot will auto-configure Atomikos and ensure that appropriate depends-on settings are applied to your Spring beans for correct startup and shutdown ordering.

    <dependency>         <groupId>org.springframework.boot</groupId>         <artifactId>spring-boot-starter-jta-atomikos</artifactId>     </dependency> 

/************************** atomikos 多数据源配置 ***************************/  /*------- db1 -------*/  /**  * db1的 XA datasource  *  * @return  */ @Bean @Primary @Qualifier("db1") public AtomikosDataSourceBean db1DataSourceBean() {     AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();     atomikosDataSourceBean.setUniqueResourceName("db1");     atomikosDataSourceBean.setXaDataSourceClassName(             "com.mysql.jdbc.jdbc2.optional.MysqlXADataSource");     Properties properties = new Properties();     properties.put("URL", db1_url);     properties.put("user", db1_username);     properties.put("password", db1_password);     atomikosDataSourceBean.setXaProperties(properties);     return atomikosDataSourceBean; }  /**  * 构造db1 sessionFactory  *  * @return  */ @Bean @Autowired public AnnotationSessionFactoryBean sessionFactory(@Qualifier("db1") AtomikosDataSourceBean atomikosDataSourceBean) {     AnnotationSessionFactoryBean sessionFactory = new AnnotationSessionFactoryBean();     sessionFactory.setDataSource(atomikosDataSourceBean);     sessionFactory.setPackagesToScan(db1_entity_package);     Properties properties = new Properties();     properties.put("hibernate.dialect", "org.hibernate.dialect.MySQLInnoDBDialect");     properties.put("hibernate.show_sql", "false");     properties.put("hibernate.format_sql", "format");     properties.put("hibernate.connection.autocommit", "true");     properties.put("hibernate.connection.url", atomikosDataSourceBean.getXaProperties().get("URL"));     properties.put("hibernate.connection.driver_class", "com.mysql.jdbc.Driver");     sessionFactory.setHibernateProperties(properties);     return sessionFactory; }  /*------- db2 -------*/  /**  * db2的 XA datasource  *  * @return  */ @Bean @Qualifier("db2") public AtomikosDataSourceBean db2DataSourceBean() {     AtomikosDataSourceBean atomikosDataSourceBean = new AtomikosDataSourceBean();     atomikosDataSourceBean.setUniqueResourceName("db2");     atomikosDataSourceBean.setXaDataSourceClassName(             "com.mysql.jdbc.jdbc2.optional.MysqlXADataSource");     Properties properties = new Properties();     properties.put("URL", db2_url);     properties.put("user", db2_username);     properties.put("password", db2_password);     atomikosDataSourceBean.setXaProperties(properties);     return atomikosDataSourceBean; }  /**  * 构造db2 sessionFactory  *  * @return  */ @Bean @Autowired public AnnotationSessionFactoryBean db2SessionFactory(         @Qualifier("db2") AtomikosDataSourceBean atomikosDataSourceBean) {     AnnotationSessionFactoryBean sessionFactory = new AnnotationSessionFactoryBean();     sessionFactory.setDataSource(atomikosDataSourceBean);     sessionFactory.setPackagesToScan(db2_entity_package);     Properties properties = new Properties();     properties.put("hibernate.dialect", "org.hibernate.dialect.MySQLInnoDBDialect");     properties.put("hibernate.show_sql", "false");     properties.put("hibernate.format_sql", "format");     properties.put("hibernate.connection.autocommit", "true");     properties.put("hibernate.connection.url", atomikosDataSourceBean.getXaProperties().get("URL"));     properties.put("hibernate.connection.driver_class", "com.mysql.jdbc.Driver");     sessionFactory.setHibernateProperties(properties);     return sessionFactory; }  /*--------- atomikos -----------*/  /**  * transaction manager  *  * @return  */ @Bean(destroyMethod = "close", initMethod = "init") public UserTransactionManager userTransactionManager() {     UserTransactionManager userTransactionManager = new UserTransactionManager();     userTransactionManager.setForceShutdown(false);     return userTransactionManager; }  /**  * jta transactionManager  *  * @return  */ @Bean public JtaTransactionManager transactionManager() {     JtaTransactionManager jtaTransactionManager = new JtaTransactionManager();     jtaTransactionManager.setTransactionManager(userTransactionManager());     return jtaTransactionManager; } 

# log com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory com.atomikos.icatch.log_base_dir=translogs 

@Autowired private DB1TestDao db1Dao;  @Autowired private DB2TestDaO db2Dao;  @Test @Transactional public void testMulitSourceTransaction() {     db1Dao.saveOrUpdate(new TestEntity());     db2Dao.saveOrUpdate(new TestEntity()); }  @Test @Transactional @Rollback(false) public void testMulitSourceTransactionWithOutRollBack() {     db1Dao.saveOrUpdate(new TestEntity());     db2Dao.saveOrUpdate(new TestEntity()); }