Spring+Mybatis+Tomcat下多数据源与 atomikos 分布式事务配置

╰+攻爆jí腚メ 2022-09-23 14:54 287阅读 0赞

## 出于对作者的尊重和感谢，原文地址：https://loftor.com/archives/spring-mybatis-tomcat-jta.html ##

> 最近项目碰到一个业务场景，需要将数据分别保存到两个数据库，并查询两个数据库的内容，同时还需要保证数据的一致性。下面要说的就是我的折腾历程。

### 配置两个数据源 ###

将不同数据库的mapper和xml文件分开放在两个文件夹中如 `main` 和 `pay`

#### Main数据库配置如下： ####

#### Pay数据库配置如下： ####

这样配置之后，代码中在不需要事务时可以像平时一样操作数据库都没有任何的问题。但是如果需要使用事务时，使用注解方式`@Transactional`，我尝试以下的方法：

这样配置后数据一个结果就是main数据库的数据能正常插入，但是pay数据库中的数据没法插入，也就是说只有main数据的事务被提交，而pay数据库的事务没有被提交，如果将

<tx:annotation-driven transaction-manager="mainTransactionManager"/> <tx:annotation-driven transaction-manager="payTransactionManager"/>

顺序换一下，则pay数据库有数据，main则没有，所以TransactionManager应该是只有一个会生效。

经过一番baidu google后，得到的信息是多数据库只能用jta分布式事务管理，而且还不支持tomcat，但是辛亏还有第三方的开源解决方案:JOTM和Atomikos等。看到这两个名字后，很自然一般人都会选择JOTM，为什么?因为它名字短……抱着试试看的态度去JOTM的官网看了一下，这真的是个古董，最后一次更新都离现在有4年多了……那就看看Atomikos吧，它分为免费版和收费版，有公司负责维护，最新版目前是3.9.3。嗯好的就它了，通过下载官方的使用示例和网上前辈们的资料，折腾如下：

#### 1.下载相关jar包 ####

我们需要用到的jar有  
transactions-jdbc  
transactions-jta  
transactions-api  
transactions  
atomikos-utils  
官方下载地址在 [ http://www.atomikos.com/Main/InstallingTransactionsEssentials][http_www.atomikos.com_Main_InstallingTransactionsEssentials]  
还需要一个jta.jar包，我使用的是1.1版本  
为了方便大家  
我方的下载地址在 [http://url.cn/UW1wOH][http_url.cn_UW1wOH]

#### 2.配置数据源 ####

我使用是mysql数据库，需要注意的是数据库引擎应该使用innodb  
配置数据库有两种方式，一种是使用XA，另一种当然是不使用，可以baidu之，推荐使用，一下对应的配置

<bean id="mainDataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close"> <property name="uniqueResourceName" value="db_main"/> <property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/> <property name="xaProperties"> <props> <prop key="url">jdbc:mysql://127.0.0.1:3306/main?characterEncoding=utf8&allowMultiQueries=true</prop> <prop key="user">root</prop> <prop key="password">123456</prop> </props> </property> <property name="minPoolSize" value="10" /> <property name="maxPoolSize" value="100" /> <property name="borrowConnectionTimeout" value="30" /> <property name="testQuery" value="select 1" /> <property name="maintenanceInterval" value="60" /> </bean>

oracle可以使用

其中`uniqueResourceName`项需要配置唯一值不能重复  
多个数据源类似的配置

#### 3.sqlsessionFactory和其他的配置一致没有区别 ####

#### 4.事务管理器配置 ####

<bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close"> <property name="forceShutdown" value="true"/> </bean> <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp"> <property name="transactionTimeout" value="300"/> </bean>

这步是关键，`<tx:annotation-driven transaction-manager="transactionManager"/>` 也可以写为`<tx:annotation-driven/>` 不需要配置`transaction-manager` 因为`spring`默认取的就是`transactionManager`。

到这里应该已经可以使用了。大功告成了。但是如果要对atomikos配置的话，只要增加一个jta.properties放在和log4j.properties同样的目录就行，配置的内容可以在官方文档找到，如：

com.atomikos.icatch.service=com.atomikos.icatch.standalone.UserTransactionServiceFactory com.atomikos.icatch.log_base_name = jdbc com.atomikos.icatch.tm_unique_name = com.atomikos.spring.jdbc.tm com.atomikos.icatch.serializable_logging=false

[http_www.atomikos.com_Main_InstallingTransactionsEssentials]: http://www.atomikos.com/Main/InstallingTransactionsEssentials
[http_url.cn_UW1wOH]: http://url.cn/UW1wOH