文档章节

Spring + Atomikos配置多个数据源,并且管理事务

猪刚烈
 猪刚烈
发布于 2014/09/24 14:06
字数 1479
阅读 52
收藏 2

本例子中使用的spring3,atomikos的下载地址:Atomikos,一个免费版和收费版的,注意区分。

我下载的是AtomikosTransactionsEssentials-3.7.0M5-bin.zip免费版的。

1、新建一个web项目(spring3  mvc+ hibernate3.6 + freemarker):atomikos,以下是我的包结构:
Spring + Atomikos配置多个数据源,并且管理事务 - java_jian - java_jian的博客

 2、数据源配置在config-spring.xml中,如下:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:dwr="http://www.directwebremoting.org/schema/spring-dwr"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
http://www.directwebremoting.org/schema/spring-dwr http://www.directwebremoting.org/schema/spring-dwr-3.0.xsd">

<context:annotation-config/>
<context:component-scan base-package="code.main.bean"/>
<context:property-placeholder location="classpath:jdbc.properties"/>
<bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
        <description>UserTransactionImp</description>
        <property name="transactionTimeout" value="300"/>
    </bean>
    
    <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">
        <description>UserTransactionManager</description>
        <property name="forceShutdown" value="true"/>
    </bean>
    
    <bean id="transactionManager"
        class="org.springframework.transaction.jta.JtaTransactionManager">
        <description>JtaTransactionManager</description>
        <property name="transactionManager" ref="atomikosTransactionManager"/>
        <property name="userTransaction" ref="atomikosUserTransaction"/>
        <property name="allowCustomIsolationLevels" value="true"/>
    </bean> 
<bean id="dataSource1" class="com.atomikos.jdbc.AtomikosDataSourceBean">
<property name="uniqueResourceName" value="mysql_jndi1"/>
<property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
<property name="poolSize" value="3"/>
<property name="maxPoolSize" value="100"/>
<property name="minPoolSize" value="1"/>
<property name="xaProperties">
<props>
<prop key="user">root</prop>
<prop key="password">1234</prop>
<prop key="url">jdbc:mysql://localhost:3306/atomikos1?useUnicode=true&amp;characterEncoding=UTF-8</prop>
</props>
</property>
<property name="testQuery" value="select 1"/>
</bean>
<bean id="dataSource2" class="com.atomikos.jdbc.AtomikosDataSourceBean">
<property name="uniqueResourceName" value="mysql_jndi2"/>
<property name="xaDataSourceClassName" value="com.mysql.jdbc.jdbc2.optional.MysqlXADataSource"/>
<property name="poolSize" value="3"/>
<property name="maxPoolSize" value="100"/>
<property name="minPoolSize" value="1"/>
<property name="xaProperties">
<props>
<prop key="user">root</prop>
<prop key="password">1234</prop>
<prop key="url">jdbc:mysql://localhost:3306/atomikos2?useUnicode=true&amp;characterEncoding=UTF-8</prop>
</props>
</property>
<property name="testQuery" value="select 1"/>
</bean>
<bean id="sessionFactory1"
class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
<property name="dataSource" ref="dataSource1" />
<property name="namingStrategy">
<bean class="org.hibernate.cfg.ImprovedNamingStrategy"/>
</property>
<property name="packagesToScan" value="code.main.bean.*" />
<property name="hibernateProperties">
<value>
hibernate.dialect=${hibernate.dialect}
hibernate.hbm2ddl.auto=${hibernate.hbm2ddl.auto}
hibernate.show_sql=${hibernate.show_sql}
hibernate.format_sql=${hibernate.format_sql} 
</value>
</property>
</bean>
<bean id="sessionFactory2"
class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
<property name="dataSource" ref="dataSource2" />
<property name="namingStrategy">
<bean class="org.hibernate.cfg.ImprovedNamingStrategy"/>
</property>
<property name="annotatedClasses">
<list>
<value>code.main.bean.pojo.User</value>
</list>
</property>
<property name="hibernateProperties">
<value>
hibernate.dialect=${hibernate.dialect}
hibernate.hbm2ddl.auto=${hibernate.hbm2ddl.auto}
hibernate.show_sql=${hibernate.show_sql}
hibernate.format_sql=${hibernate.format_sql} 
</value>
</property>
</bean>
<bean id="hibernateTemplate1" class="org.springframework.orm.hibernate3.HibernateTemplate" >
<property name="sessionFactory" ref="sessionFactory1" />
</bean>
<bean id="hibernateTemplate2" class="org.springframework.orm.hibernate3.HibernateTemplate" >
<property name="sessionFactory" ref="sessionFactory2" />
</bean>
<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>
配置了2个mysql的数据库,新建了2个实体类:
package code.main.bean.pojo;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;

@Table(name="t_user")
public class User {
private int id;
private String name;
private String password;
private String email;

@Id
@GeneratedValue(strategy=GenerationType.AUTO)
public int getId() {
return id;
}

public void setId(int id) {
this.id = id;
}

@Column(length=20)
public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

@Column(length=20)
public String getPassword() {
return password;
}

public void setPassword(String password) {
this.password = password;
}

@Column(length=100)
public String getEmail() {
return email;
}

public void setEmail(String email) {
this.email = email;
}
}


package code.main.bean.pojo;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;

@Entity
@Table(name="t_person")
public class Person {
private int id;
private String personName;

@Id
@GeneratedValue(strategy=GenerationType.AUTO)
public int getId() {
return id;
}

public void setId(int id) {
this.id = id;
}

@Column(length=20)
public String getPersonName() {
return personName;
}

public void setPersonName(String personName) {
this.personName = personName;
}
}
3、启动项目,生成数据库如下图(有2个数据库atomikos1和atomikos2,一个有2涨表,1个有一张表,请看上面配置文件中sessionFactory中的配置就能发现,一个是映射包,一个是映射单个类,配置方式有点不一样):
Spring + Atomikos配置多个数据源,并且管理事务 - java_jian - java_jian的博客

4、插入一些数据来测试一下,多个数据库的跨事务问题,
首先写了一个hibernate的dao,就是增删改查(略,但是有一点,因为配置文件中配置了2个sessionFactory,所以dao层要写2个实现类,对应不同的sessionFactory)。。。
Spring + Atomikos配置多个数据源,并且管理事务 - java_jian - java_jian的博客
第一个实现类注入的是hibernateTemplate1这个类,配置文件中有定义。
@Resource(name="hibernateTemplate1")
private HibernateTemplate template;
第一个实现类如下, 也就是说,多个数据库就要对应多个实现类。
@Resource(name="hibernateTemplate2")
private HibernateTemplate template;
commonDao就是常用的操作的父接口,
我们自己的实体类的只要继承它就可以了。
5、service层的写法:
@Service("userService")
@Transactional
public class UserServiceImpl implements UserService {

@Resource(name="userDao1")
private UserDao dao1;
@Resource(name="userDao2")
private UserDao dao2;
public void save(User o){
User user = new User();
user.setEmail(o.getEmail());
user.setName(o.getName());
user.setPassword(o.getPassword());
User user1 = new User();
user1.setEmail(o.getEmail());
user1.setName(o.getName());
user1.setPassword(o.getPassword());
dao1.add(user1);
dao2.add(user);
}
}
注入2个userDao,看我的保存的方法:
注意: 传进来一个user对象,本来可以直接保存的,但是我new了2个,分别保存,这是因为这里有一个小问题:
当你没有分别new的时候,id是自动分配的,只会分配一次,假如你的2个数据库保存的时候id不是同一个,往数据库里面插入的时候就为违反自动增长的那个顺序,从而报错。

6、controller的写法:
@Controller
@RequestMapping("/user")
public class UserController {
@Resource(name="userService")
private UserService userService;
@RequestMapping("toAdd")
public String toAdd(){
System.out.println("进入添加用户页面");
return "/user/add";
}
@RequestMapping("add")
public String add(User user) {
try {
userService.save(user);
} catch (Exception e) {
e.printStackTrace();
}
return "/user/add";
}
}

看了就行了,此处比较简单。

7、页面
<body>
<form action="${app}/user/add" method="post">
用户名: <input type="text" name="name"/>
密&nbsp;&nbsp;码:<input type="text" name="password"/>
email: <input type="text" name="email"/>
<input type="submit" value="添加用户"/>
<form>
<hr/>
<a href="${app}/user/list">用户列表</a> 
</body>    
</html>
8、测试结果
保存的时候没有问题。
我为了测试2个数据库事务的问题,把其中一个数据库的表的email字段改成了唯一约束,插入的时候显然报错,后面一个数据库也没有插入成功, 说明事务起作用了。
截个图看下:
Spring + Atomikos配置多个数据源,并且管理事务 - java_jian - java_jian的博客
下一个数据库的:
 
Spring + Atomikos配置多个数据源,并且管理事务 - java_jian - java_jian的博客

看,前6条数据都一样,插入式没有问题的。

后面我又用我自己的电脑,和别的机器上的数据库做了一下测试,第一张结果图中的部分数据就是测试的结果,

其实这个就已经做到了 不同的服务器上的数据库的事物同步

后来听说jotm配置jndi也能实现多个数据库,我后来网上找了一点例子写了一下,发现保存数据没有问题,但是事物没有控制到,
估计是我写的不好,所以没有成功。

第一次写博客,写的不好,请不要骂我,谢谢~

本文转载自:http://blog.csdn.net/super_scan/article/details/39013419

猪刚烈
粉丝 22
博文 708
码字总数 110
作品 1
海淀
程序员
私信 提问
spring+mybatis+atomikos 实现JTA事务

atomikos支持一个分布式事务,结合spring,可以很好的满足一个应用访问多个库的需要。 atomikos 结合spring做配置也很简单 1.配置datasource <!-- 第一个数据库 --><bean id="dataSource" c...

lavafree
2013/01/04
7.3K
5
spring + ibatis 多数据源事务(分布式事务)管理配置方法(转)

1、我先要给大家讲一个概念:spring 的多数据源事务,这是民间的说法。官方的说法是:spring 的分布式事务。明白了这个概念,问题就好解决了。 2、分布式事务的应用场景:工程中使用两个及以...

IceRainYWC
2012/12/17
2.3K
2
JAVA中使用代码创建多数据源,并实现动态切换(一)

2017-06-06 11:31:57补充:近日,在本文的基础之上,扩展了下,使用atomikos来管理事务,保证多数据源操作时,事务一致性。(https://my.oschina.net/simpleton/blog/916108) 另外,感谢朋友...

十月阳光
2017/03/27
6K
0
JAVA中使用代码创建多数据源,并实现动态切换(二)-集成分布式事务

2017年8月16日11:45:39更新:这里贴出我自己写的一个demo,放在CSDN上了。http://download.csdn.net/download/llzhaoyun/9912658 前面写了一篇关于使用Spring + druid + Mybatis配置多数据源...

十月阳光
2017/06/07
2.7K
9
Guns 旗舰版 2.4 发布,更简洁的管理系统

Guns旗舰版v2.4 更新说明: 修复集成atomikos后,单数据源下事务管理器冲突的问题 修复多数据源下,atomikos和druid整合的问题,https://gitee.com/stylefeng/guns/issues/IVCQM Guns 介绍:...

stylefeng
04/29
2.2K
4

没有更多内容

加载失败,请刷新页面

加载更多

golang 不同mysql 连接库对比

待续

caucy
4分钟前
1
0
PHP JsonWebToken的实现

废话不多说,上码(thinkphp环境) <?phpnamespace app\index\controller;class Jwt{ /** * @var array jwt头部 */ private static $header = [ //生成signatu......

yehua11
8分钟前
1
0
gitlab docker Web界面打开反应迟钝的解决办法

参考:https://blog.csdn.net/happyfreeangel/article/details/88653846 解决办法: 修改gitlab的配置文件:gitlab.rb 位置在容器中的/etc/gitlab/config 使用容器时必须挂载到外面的存储,要...

bapleliu
8分钟前
1
0
AJAX 请求 浏览器F12 看不到返回值

最近在某某高校上线AA系统之后对于某一个接口,有的时候可以界面可以正常渲染并展示正确的数据,偶尔不行。 前端开发人员打开浏览F12,指着屏幕说,AJAX请求了没有返回呀,这个要后端看看到底...

特拉仔
13分钟前
1
0
好程序员Java学习路线分享JVM类加载机制

好程序员Jav学习路线分享JVM类加载机制JVM相关概念 - jdk<br> jdk(Java Development Kit)Java开发包,是Java开发人员用于编译和调试程序的一套程序的集合。 - jre<br> jre(Java Runtime ...

好程序员官方
16分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部