首页 > 其他分享 >在spring、tomcat中使用多数据源并支持分布式事务管理

在spring、tomcat中使用多数据源并支持分布式事务管理

时间:2023-08-28 10:38:47浏览次数:39  
标签:事务管理 tomcat atomikos spring 配置 数据源 test jta


题目起得有点模糊,第一次接触这东西,还不怎么理解。 

起因: 
小项目,没有用分布式,但要操作两个数据库。本以为随便用spring配置两个数据源就搞定,查询是没问题,问题是有一个数据库老是插不进数据。Google狂搜之后,大概了解到是事务控制的问题。我用的是spring的声明式事务管理(<tx:annotation-driven/>)。用一般的数据源配置,只有一个数据源的事务生效,其它数据源只能读不能写。 

有帖子说,要支持多数据源的事务,只能用JTA事务管理(没用过 -_-||),而且应用服务器还不能是Tomcat(一直在用tomcat,不想换-_-!!),头疼了。幸亏后面还有说,有第三方的实现支持JTA事务管理,一是JOTM,一是Atomikos。只要用了其中一个,还能继续用Tomcat。因为名字短,先考虑用JOTM。到官网一看,最后更新日期是2010年。。呃。。转向Atomikos。在Atomikos的官网看看文档,看看例子,边做边调试,一个下午下来,总算有点成果,高兴之余做个记录。其中会涉及到一些概念,比如分布式事务、JTA、XA,我都有搜来了解一下,因理解肤浅没法做记录。下面只是记录atomikos配合spring的使用方法: 

1、依赖包 
Atomikos的: 
transactions-jdbc 
transactions-jta 
transactions-api 
transactions 
atomikos-utils 
还有一个不要忘了,是jta的包。 
用maven要简单一点,只需要加入两个依赖: 


<dependency> <groupId>com.atomikos</groupId> <artifactId>transactions-jdbc</artifactId> <version>3.7.0</version> </dependency> <dependency> <groupId>javax.transaction</groupId> <artifactId>jta</artifactId> <version>1.1</version> </dependency>


 

2、配置数据源 
    这一步是比较重要的。要用AtomikosDataSourceBean,而不是以前用的连接池如dbcp。最好也用XA(这东西我还不太懂),注意jdbc的链接地址和登陆账号与普通连接池的配置的格式不一样。下面是一个mysql数据库的配置举例: 


<bean id="dataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
	<property name="uniqueResourceName" value="ds1"/>
	<property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
	<property name="xaProperties">
		<props>
			<prop key="url">jdbc:mysql://localhost/test</prop>
			<prop key="user">test</prop>
			<prop key="password">test</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>


 

再来一个sybase的配置举例:


<bean id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">
	<property name="uniqueResourceName" value="ds2"/>
	<property name="xaDataSourceClassName" value="com.sybase.jdbc3.jdbc.SybXADataSource"/>
	<property name="xaProperties">
		<props>
			<prop key="serverName">192.168.1.10</prop>
                        <prop key="portNumber">2638</prop>
                        <prop key="databaseName">test</prop>
			<prop key="user">test</prop>
			<prop key="password">test</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>


 

3、使用数据源 
    这一步与平时好像没什么不一样。我做例子的时候是用mybatis,配置如下:

<bean id="sqlSessionFactory1" class="org.mybatis.spring.SqlSessionFactoryBean">
	<property name="dataSource" ref="dataSource1"/>
</bean>
<bean id="sqlSessionFactory2" class="org.mybatis.spring.SqlSessionFactoryBean">
	<property name="dataSource" ref="dataSource2"/>
</bean>


当然,mybatis还要配置一下映射文件的自动扫描,这里与atomikos无关:


<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
	<property name="basePackage" value="xx.xx;" />
	<property name="sqlSessionFactory" ref="sqlSessionFactory1"/>
</bean>
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
	<property name="basePackage" value="yy.yy;" />
	<property name="sqlSessionFactory" ref="sqlSessionFactory2"/>
</bean>


用spring JdbcTemplate应该与普通使用没什么不同,用hibernate可能会有点不一样,没测试过。

 

4、配置jta事务管理 
    这是很关键的一步。原理我不太懂,例子如下: 


<bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
	<property name="transactionManager">
		<bean class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">
			<property name="forceShutdown" value="true"/>
		</bean>
	</property>
	<property name="userTransaction">
		<bean class="com.atomikos.icatch.jta.UserTransactionImp"/>
	</property>
</bean>


当然,用spring的声明式事务配置,再加上一行:


<tx:annotation-driven/>

 

(注意,本来要配置transaction-manager属性,如:<tx:annotation-driven  transaction-manager="transactionManager" />。这里没有配置是因为它的默认值是transactionManager) 

5、atomikos的配置文件jta.properties 
    这个文件一般放在根路径吧,与log4j.properties类似。jta.properties也可命名为transactions.properties。如果不配置这个文件,项目也能启动,因为几乎所有配置项都有默认值。最好还是配置了,详细配置信息请查看:http://www.atomikos.com/Documentation/JtaProperties。 

6、不管是用JdbcTemplate、mybatis还是hibernate,应该都可以写代码来测试了。。。 

标签:事务管理,tomcat,atomikos,spring,配置,数据源,test,jta
From: https://blog.51cto.com/u_16237557/7260787

相关文章

  • 完美配置Tomcat的HTTPS
    Tomcat配置HTTPS的文章到处都有,过程也比较简单,随后文中会转一段过来。但对于启用APR情况下报异常“java.lang.Exception:ConnectorattributeSSLCertificateFilemustbedefinedwhen usingSSLwithAPR”的解决方法上处理的都比较偷懒,通常都是把APR注释掉不启用APR。做为一......
  • 学生信息登记表单的录入删除代码JS+HTML TOMCAT听课笔记
    <!DOCTYPEhtml><html><head></head><body><formclass="info"autocomplete="off">姓名:<inputtype="text"class="uname"name="uname"&......
  • Tomcat参数配置
    http://tomcat.apache.org/tomcat-6.0-doc/config/http.html enableLookups:是否反查域名,取值为:true或false,默认true。为了提高处理能力,如果不需要取得访问来源的域名,应设置为false,设置为false的时候,只能获取IP。 maxThreads:设置最大并发数,默认200。 acceptCount:允许的最大连接数......
  • 高版本的IDEA中怎样使用Tomcat
    在前面其实我已经学过了Tomcat服务器的使用,然后学习IDEA上面集成Tomcat应该来说是水到渠成的,但是由于老师的IDEA版本和目前我使用的版本差异较大,所以关于在IDEA上面使用集成的Tomcat一直有困惑。特别是在学习Servlet的时候,故查阅相关资料注意:关于Tomcat的配置查看原来的文档即可......
  • 字体大小自动适应DIV--亲自测试有效-tomcat
    <!DOCTYPEhtml><html><head><title>phone设计</title><metacontent="text/html;charset=utf-8"http-equiv="Content-Type"/></head><body><divstyle="......
  • 在maven中使用tomcat插件运行项目
    1.在pom.xml中配置插件<plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.2</version><configuration>......
  • Eclipse集成Tomcat
    1.打开Eclipse,点击“Window”,选择“Preferences”2.找到“Server”(如果找不到Server,查看本页最下方的解决办法)---“RuntimeEnvironments”--“Add”,——运行时环境(RuntimeEnvironments)——添加(Add),添加Tomcat服务器对应安装的Tomcat版本选择ApacheTomcat。 下一步通......
  • springboot结合baomidou dynamic-datasource组件实现多数据源
    当系统数据量过大,系统性能问题逐渐浮出水面。使用主从模式,不失是一个较好的选择。即业务在主库执行,不影响业务的查询考虑走从库。这时,程序需要动态多数据源配置。......
  • Tomcat启动黑窗口一闪而过
    Tomcat启动黑窗口一闪而过一、解决方案首先要确定Tomcat为什么会一闪而过,那么就要看黑窗口一闪而过的时候显示了什么。cmd命令进入Tomcat的bin目录,输入startup.bat(若已配置环境,可直接输入指令),回车。这样黑窗口就不会关闭,而是会显示出正常信息或者报错信息。如果你的信息和下图......
  • Tomcat修改端口号
    1.首先找到tomcat安装目录下的conf文件夹中的server.xml文件 2.找到protocol值为HTTP/1.1的Connector标签,其中port就是端口号,它原先的值为8080,现在我把它改成8081 3.运行tomcat,可以发现它的端口号变成了8081......