码迷，mamicode.com
首页 > 其他好文 > 详细

Atomikos多数据源配置项目实例

时间：2014-12-23 19:39:31      阅读：222      评论：0      收藏：0      [点我收藏+]

标签：atomikos

applicationContext.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:jee="http://www.springframework.org/schema/jee"
	xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
	xsi:schemaLocation="http://www.springframework.org/schema/beans 
	http://www.springframework.org/schema/beans/spring-beans-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/jee 
	http://www.springframework.org/schema/jee/spring-jee-3.0.xsd 
	http://www.springframework.org/schema/context 
	http://www.springframework.org/schema/context/spring-context-3.0.xsd"
	default-lazy-init="true">

	<description>Spring公共配置 </description>

	<!-- 定义受环境影响易变的变量 -->
	<bean
		class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
		<property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
		<property name="ignoreResourceNotFound" value="true" />
		<property name="locations">
			<list>
				<!-- 标准配置 -->
				<value>classpath*:/application.properties</value>
				<!--
					集群中节点配置 <value>classpath*:/application.cluster.properties</value>
				-->

				<!--
					本地开发环境配置 <value>classpath*:/application.local.properties</value>
				-->

				<!--
					服务器生产环境配置 <value>/pom/application.server.properties</value>
				-->

			</list>
		</property>
	</bean>

	<!-- 使用annotation 自动注册bean,并保证@Required,@Autowired的属性被注入 -->
	<context:component-scan base-package="com.wiseweb.pom" />
	
	
	<!-- orable配置 -->
	<!-- <bean id="dataSourceContent" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">      
        <property name="uniqueResourceName">      
            <value>jdbc/dataSourceContent</value>      
        </property>      
        <property name="xaDataSourceClassName">      
            <value>oracle.jdbc.xa.client.OracleXADataSource</value>      
        </property>      
        <property name="xaProperties">
            <props>    
                <prop key="URL">${jdbc.url}</prop>  
                <prop key="user">${jdbc.username}</prop>    
                <prop key="password">${jdbc.password}</prop>    
            </props>          
        </property>          
        <property name="poolSize">      
            <value>5</value>      
        </property>
        <property name="maxPoolSize">
			<value>15</value>
		</property>
    </bean>
    <bean id="dataSourceIndex" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">      
        <property name="uniqueResourceName">      
            <value>jdbc/dataSourceIndex</value>      
        </property>      
        <property name="xaDataSourceClassName">      
            <value>oracle.jdbc.xa.client.OracleXADataSource</value>      
        </property>      
        <property name="xaProperties">      
            <props>    
                <prop key="URL">${jdbc.url}</prop>   
                <prop key="user">${jdbc.username}</prop>    
                <prop key="password">${jdbc.password}</prop>    
            </props>     
        </property>           
        <property name="poolSize">      
            <value>5</value>      
        </property>
        <property name="maxPoolSize">
			<value>15</value>
		</property>
    </bean> -->
    
    
	<!-- 本地数据库配置 -->
	<bean id="dataSourceContent" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">      
        <property name="uniqueResourceName">      
            <value>jdbc/dataSourceContent</value>      
        </property>      
        <property name="xaDataSourceClassName">      
            <value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>      
        </property>      
        <property name="xaProperties">
            <props>    
                <prop key="serverName">${jdbc.servername}</prop>
                <prop key="portNumber">${jdbc.portnumber}</prop>    
                <prop key="databaseName">${jdbc.databasename}</prop>
                <prop key="user">${jdbc.username}</prop>    
                <prop key="password">${jdbc.password}</prop>    
            </props>          
        </property>          
        <property name="poolSize">      
            <value>5</value>      
        </property>
        <property name="maxPoolSize">
			<value>15</value>
		</property>
        <property name="testQuery">        
			<value>select 1</value>    
		</property>   
    </bean>
    <bean id="dataSourceIndex" class="com.atomikos.jdbc.AtomikosDataSourceBean" init-method="init" destroy-method="close">      
        <property name="uniqueResourceName">      
            <value>jdbc/dataSourceIndex</value>      
        </property>      
        <property name="xaDataSourceClassName">      
            <value>com.mysql.jdbc.jdbc2.optional.MysqlXADataSource</value>      
        </property>      
        <property name="xaProperties">      
            <props>    
                <prop key="serverName">${jdbc.servername_index}</prop>    
                <prop key="portNumber">${jdbc.portnumber_index}</prop>    
                <prop key="databaseName">${jdbc.databasename_index}</prop>    
                <prop key="user">${jdbc.username_index}</prop>    
                <prop key="password">${jdbc.password_index}</prop>    
            </props>     
        </property>           
        <property name="poolSize">      
            <value>5</value>      
        </property>
        <property name="maxPoolSize">
			<value>15</value>
		</property>
        <property name="testQuery">        
			<value>select 1</value>    
		</property>        
    </bean>


	<!-- 数据源配置,使用应用内的DBCP数据库连接池 
	<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
		destroy-method="close">
		 Connection Info 
		<property name="driverClassName" value="${jdbc.driver}" />
		<property name="url" value="${jdbc.url}" />
		<property name="username" value="${jdbc.username}" />
		<property name="password" value="${jdbc.password}" />

		 Connection Pooling Info 
		<property name="maxIdle" value="${dbcp.maxIdle}" />
		<property name="maxActive" value="${dbcp.maxActive}" />
		<property name="defaultAutoCommit" value="false" />
		<property name="timeBetweenEvictionRunsMillis" value="3600000" />
		<property name="minEvictableIdleTimeMillis" value="3600000" />
	</bean>

	--><!-- 数据源配置,使用应用服务器的数据库连接池 -->
	<!--
		<jee:jndi-lookup id="dataSource"
		jndi-name="java:comp/env/jdbc/ExampleDB" />
	-->

	<!-- Hibernate配置 
	<bean id="sessionFactory"
		class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
		<property name="dataSource" ref="dataSource" />
		<property name="namingStrategy">
			<bean class="org.hibernate.cfg.ImprovedNamingStrategy" />
		</property>
		<property name="hibernateProperties">
			<props>
				<prop key="hibernate.dialect">${hibernate.dialect}</prop>
				<prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
				<prop key="hibernate.format_sql">${hibernate.format_sql}</prop>
				<prop key="hibernate.cache.use_second_level_cache">${hibernate.use_second_level_cache}</prop>
				<prop key="hibernate.cache.use_query_cache">${hibernate.use_query_cache}</prop>
				<prop key="hibernate.cache.provider_class">org.hibernate.cache.EhCacheProvider</prop>
				<prop key="hibernate.cache.provider_configuration_file_resource_path">ehcache/ehcache-hibernate-local.xml</prop>
			</props>
		</property>
		<property name="packagesToScan" value="com.wiseweb.pom.entity" />
	</bean>

	-->
	<!-- Hibernate配置 -->
	<!-- 本地数据库Hibernate配置 -->
    <bean id="sessionFactoryContent" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
        <property name="dataSource" ref="dataSourceContent" />
        <property name="namingStrategy">
            <bean class="org.hibernate.cfg.ImprovedNamingStrategy" />
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">org.hibernate.dialect.MySQL5InnoDBDialect</prop>
                <prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
                <prop key="hibernate.format_sql">${hibernate.format_sql}</prop>
                <prop key="hibernate.cache.provider_class">org.hibernate.cache.EhCacheProvider</prop>
                <prop key="hibernate.cache.provider_configuration_file_resource_path">ehcache/ehcache-hibernate-local.xml</prop>
            </props>
        </property>
        <property name="packagesToScan" value="com.wiseweb.pom.entity" />
    </bean>
    <!-- 远程数据库Hibernate配置 -->
    <bean id="sessionFactoryIndex" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
        <property name="dataSource" ref="dataSourceIndex" />
        <property name="namingStrategy">
            <bean class="org.hibernate.cfg.ImprovedNamingStrategy" />
        </property>
        <property name="hibernateProperties">
            <props>
                <prop key="hibernate.dialect">org.hibernate.dialect.MySQL5InnoDBDialect</prop>
                <prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
                <prop key="hibernate.format_sql">${hibernate.format_sql}</prop>
                <prop key="hibernate.cache.provider_class">org.hibernate.cache.EhCacheProvider</prop>
                <prop key="hibernate.cache.provider_configuration_file_resource_path">ehcache/ehcache-hibernate-local.xml</prop>
            </props>
        </property>
        <property name="packagesToScan" value="com.wiseweb.pom.entity" />
    </bean>
    
	<!-- 事务管理器配置,单数据源事务
	<bean id="transactionManager"
		class="org.springframework.orm.hibernate3.HibernateTransactionManager">
		<property name="sessionFactory" ref="sessionFactory" />
	</bean>
 	-->
 	
 	<!-- ActiveMQ JMS服务 -->
	<!--创建连接工厂-->
    <bean id="connectionFactory"
        class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://127.0.0.1:61616"></property>
    </bean>
    <!-- 声明ActiveMQ队列消息目标-->
    <!-- <bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
    	<constructor-arg index="0" value="wiseweb.queue"></constructor-arg>
    </bean> -->
    <!-- 声明ActiveMQ主题消息目标 -->
    <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">
        <constructor-arg index="0" value="wiseweb.topic"></constructor-arg>
    </bean>
    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="connectionFactory"></property>
        <property name="defaultDestination" ref="destination"></property>
        <property name="receiveTimeout" value="10000"></property>
    </bean>
    <!-- 消息监听适配器 -->
    <bean id="messageListenerAdapter" class="org.springframework.jms.listener.adapter.MessageListenerAdapter">
    	<property name="delegate">
    		<bean class="com.wiseweb.pom.jms.listener.MessageListener"></bean>
    	</property>
    	<property name="defaultListenerMethod" value="receiveMessage"></property>
    	<property name="defaultResponseDestination" ref="destination"></property>
    </bean>
    <!-- 监听容器 -->
    <!-- <bean id="messageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    	<property name="connectionFactory" ref="connectionFactory"></property>
    	<property name="destination" ref="destination"></property>
    	<property name="messageListener" ref="messageListenerAdapter"></property>
    </bean> -->
    <bean id="messageSender" class="com.wiseweb.pom.jms.MessageSender">
    	<property name="jmsTemplate" ref="jmsTemplate"></property>
    </bean>
    
	<!-- 事务管理器配置,多数据源JTA事务-->
    <bean id="atomikosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager" init-method="init" destroy-method="close">   
        <property name="forceShutdown"><value>true</value></property>   
    </bean>   
       
    <bean id="atomikosUserTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">   
        <property name="transactionTimeout" value="300"/>
    </bean>   
    <bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
        <property name="transactionManager" ref="atomikosTransactionManager" />
        <property name="userTransaction" ref="atomikosUserTransaction"/>
        <property name="allowCustomIsolationLevels" value="true"/>
    </bean>

	<!-- 使用annotation定义事务 -->
	<tx:annotation-driven transaction-manager="transactionManager"
		proxy-target-class="true" />

	<!-- 加载网站类型 -->


	<bean id="groupMap" class="java.util.TreeMap">
		<constructor-arg>
			<map>
				<entry key="1" value="新闻" />
				<entry key="2" value="论坛" />
				<entry key="3" value="博客" />
				<entry key="4" value="微博" />
				<entry key="5" value="纸媒" />
		   <!-- <entry key="6" value="视频" />--> 
		   		<entry key="7" value="外媒" />
		   <!-- <entry key="8" value="广播" />
				<entry key="9" value="电视" />
				<entry key="10" value="空间" />
				<entry key="11" value="微信" />-->
			</map>
		</constructor-arg>
	</bean>

	<bean id="staticValue" class="com.wiseweb.util.StaticValue"
		lazy-init="false">
		<property name="groupMap">
			<ref bean="groupMap" />
		</property>
	</bean>

	<bean id="hibernateDaoImple" class="com.wiseweb.pom.dao.HibernateGeneralDao">
		<property name="sessionFactory" ref="sessionFactoryContent"></property>
	</bean>

	<!-- 配置定时器 -->
	<bean id="scheduler"
		class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
	</bean>
	<bean id="quartzTimerUtil" class="com.wiseweb.util.sms.QuartzTimerUtil">
		<property name="scheduler" ref="scheduler" />
	</bean>
	<bean id="startAllTimer" class="com.wiseweb.util.sms.StartAllTimer">
		<property name="scheduler" ref="scheduler" />
		<property name="hibernateDaoImple" ref="hibernateDaoImple"></property>
	</bean>
	<!-- 配置定时器结束 -->
</beans>


dao层 

package com.wiseweb.pom.dao.account;

import javax.annotation.Resource;

import org.hibernate.SessionFactory;
import org.springframework.stereotype.Component;
import org.springside.modules.orm.hibernate.HibernateDao;

import com.wiseweb.pom.entity.Company;
/**
 * HibernateDao中的Company是实体类
 * @author Benjamin
 *
 */
@Component
public class CompanyDao  extends HibernateDao<Company, Long>
{   
	//选择applicationContext中名为sessionFactoryContent的sessionFactory注入，实现多数据源访问
	@Override
	@Resource(name = "sessionFactoryContent")
    public void setSessionFactory(SessionFactory sessionFactory) {
        // TODO Auto-generated method stub
        super.setSessionFactory(sessionFactory);
    }
}

实体类entity 

package com.wiseweb.pom.entity;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

import javax.persistence.CascadeType;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.OneToMany;
import javax.persistence.Table;
import javax.persistence.Transient;


@Entity
@Table(name="wise_company")
public class Company implements Serializable{
	/**
	 * 
	 */
	private Long id ;
	private static final long serialVersionUID = 1L;
	private String name ;
	private Integer grade ;
	private Long parentId ;
	private Integer nodeType ;
	private Integer orderType ;
	private Integer flag ;
	private Company fCompany ;
	private List<Department> departments = new ArrayList<Department>() ;
	private Long companyNum ;
	private Long childNum ;
	private List<Company> childCompanys = new ArrayList<Company>() ;
	@Column(name="name", nullable=false, length=45)
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	@Column(name="grade", nullable=false)
	public Integer getGrade() {
		return grade;
	}
	public void setGrade(Integer grade) {
		this.grade = grade;
	}
	@Column(name="parent_id", nullable=false)
	public Long getParentId() {
		return parentId;
	}
	public void setParentId(Long parentId) {
		this.parentId = parentId;
	}
	@Column(name="node_type", nullable=false)
	public Integer getNodeType() {
		return nodeType;
	}
	public void setNodeType(Integer nodeType) {
		this.nodeType = nodeType;
	}
	@Column(name="order_type")
	public Integer getOrderType() {
		return orderType;
	}
	public void setOrderType(Integer orderType) {
		this.orderType = orderType;
	}
	@Column(name="flag", nullable=false)
	public Integer getFlag() {
		return flag;
	}
	public void setFlag(Integer flag) {
		this.flag = flag;
	}
	@OneToMany(mappedBy="company",cascade = {CascadeType.ALL})
	public List<Department> getDepartments() {
		return departments;
	}
	public void setDepartments(List<Department> departments) {
		this.departments = departments;
	}
	@Transient
	public Company getFCompany() {
		return fCompany;
	}
	public void setFCompany(Company fCompany) {
		this.fCompany = fCompany;
	}
	@Id
	public Long getId() {
		return id;
	}
	public void setId(Long id) {
		this.id = id;
	}
	@Transient
	public Long getCompanyNum() {
		return companyNum;
	}
	public void setCompanyNum(Long companyNum) {
		this.companyNum = companyNum;
	}
	@Transient
	public List<Company> getChildCompanys() {
		return childCompanys;
	}
	public void setChildCompanys(List<Company> childCompanys) {
		this.childCompanys = childCompanys;
	}
	@Transient
	public Long getChildNum() {
		return childNum;
	}
	public void setChildNum(Long childNum) {
		this.childNum = childNum;
	}
	
	
}

下面最重要的是service层，必须要加上@Transactional不然会报the XA resource is currently involved in a local (non-XA) transaction的错误。

@Component
@Transactional
public class AccountManager {
	...
}


最后就可以通过指定不通的sessionFactory访问不同的数据库了。

Atomikos多数据源配置项目实例

标签：atomikos

原文地址：http://blog.csdn.net/benjamin_whx/article/details/42105205
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！