在SpringSide 3 中使用多个数据库的方法

叁歲伎倆 2021-09-16 06:52 458阅读 0赞

在 **SpringSide** 3社区中，不断有人提出  **多数据源**配置的问题，但是时至今日却一直没有一个完美的答案。经过一个星期的折腾，我总算搞清楚了在 **SpringSide** 3中配置 **多数据源**的各种困难并加以解决，在这里，特地把我配置 **SpringSide** 3项目中 **多数据源**的过程写出来，与大家分享。  
  
我使用的 **SpringSide**的版本是江南白衣最新发布的3.1.4翻墙版，在上一篇博文中，记录了我折腾的全过程，感兴趣的朋友可以看看：  
http://www.blogjava.net/youxia/archive/2009/07/12/286454.html  
  
下面进入正题：  
  
结论：在基于 **SpringSide** 3的项目中，如果要使用多个数据库，首先要配置多个数据源，然后配置多个SessionFactory，这本身没有问题，但是一涉及到事务，问题就来了，在 **多数据源**的环境下，必须使用JTATransactionManager，而使用JTATransactionManager，就必须得有提供JTA功能的应用服务器或提供JTA功能的别的什么组件。  
  
以上结论绝对正确，是属于 **SpringSide** 3中关于使用多个数据库的最权威解答，下面来看具体过程：  
  
方法一、使用GlassFish应用服务器  
  
1、准备GlassFish服务器，下载地址为http://download.java.net/glassfish/v3/promoted/，我选择的是08-Jul-2009 17:20发布的大小为72M的latest-glassfish.zip，这里需要强调的一点是千万不要选择latest-glassfish-windows.exe这个版本，因为这个版本在Windows环境中只安装GlassFish而不提供合理的初始化配置，对于新手来说使用门槛太高，而ZIP版一解压缩就可以使用，其服务器是配置好了的；  
  
2、在GlassFish中配置多个数据源，启动GlassFish后，访问4848端口就可以进入到GlassFish的管理界面，在其中配置两个数据源，其资源名称分别为jdbc/dataSourceContent和jdbc/dataSourceIndex，如下图：  
![在SpringSide 3 中使用多个数据库的方法 - 海边沫沫 - BlogJava - dingchaoqun12 - dingchaoqun12 的博客][SpringSide 3 _ - _ - BlogJava - dingchaoqun12 - dingchaoqun12]  
  
3、在项目中配置多个DataSource和多个SessionFactory，并选择JTATransactionManager作为事务管理器，这里的DataSource是使用JNDI查找从应用服务器中获得的。下面是我项目中的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"="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"="http://www.springframework.org/schema/context"="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd"="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></list></property></bean><context:component-scan base-package="cn.puretext"/><jee:jndi-lookup id="dataSourceContent" jndi-name="jdbc/dataSourceContent"/><jee:jndi-lookup id="dataSourceIndex" jndi-name="jdbc/dataSourceIndex"/><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">$\{hibernate.ehcache\_config\_file\}</prop></props></property><property name="packagesToScan" value="cn.puretext.entity.\*"/></bean><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">$\{hibernate.ehcache\_config\_file\}</prop></props></property><property name="packagesToScan" value="cn.puretext.entity.\*"/></bean><bean id="transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager"/><tx:annotation-driven transaction-manager="transactionManager"/></beans>

4、由于配置了多个SessionFactory，所以需要在web.xml中配置两个OpenSessionInViewFilter，下面是我的web.xml文件：

<?xml version="1.0" encoding="UTF-8"?>  
<web-app version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
    xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app\_2\_4.xsd">  
  
<display-name>PureText</display-name>  
  
<context-param>  
<param-name>contextConfigLocation</param-name>  
<param-value>classpath\*:/applicationContext\*.xml</param-value>  
</context-param>  
  
  
<filter>  
<filter-name>encodingFilter</filter-name>  
<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>  
<init-param>  
<param-name>encoding</param-name>  
<param-value>UTF-8</param-value>  
</init-param>  
<init-param>  
<param-name>forceEncoding</param-name>  
<param-value>true</param-value>  
</init-param>  
</filter>  
  
<filter>  
<filter-name>hibernateOpenSessionInViewFilterContent</filter-name>  
<filter-class>org. **springside**.modules.orm.hibernate.OpenSessionInViewFilter</filter-class>  
<init-param>  
<param-name>excludeSuffixs</param-name>  
<param-value>js,css,jpg,gif</param-value>  
</init-param>  
<init-param><param-name>sessionFactoryBeanName</param-name>  
<param-value>sessionFactoryContent</param-value></init-param></filter>  
<filter>  
<filter-name>hibernateOpenSessionInViewFilterIndex</filter-name>  
<filter-class>org. **springside**.modules.orm.hibernate.OpenSessionInViewFilter</filter-class>  
<init-param>  
<param-name>excludeSuffixs</param-name>  
<param-value>js,css,jpg,gif</param-value>  
</init-param>  
<init-param><param-name>sessionFactoryBeanName</param-name>  
<param-value>sessionFactoryIndex</param-value></init-param></filter>  
  
<filter>  
<filter-name>springSecurityFilterChain</filter-name>  
<filter-class>org.springframework.web.filter.DelegatingFilterProxy</filter-class>  
</filter>  
  
  
<filter>  
<filter-name>struts2Filter</filter-name>  
<filter-class>org.apache.struts2.dispatcher.ng.filter.StrutsPrepareAndExecuteFilter</filter-class>  
</filter>  
  
<filter-mapping>  
<filter-name>encodingFilter</filter-name>  
<url-pattern>/\*</url-pattern>  
</filter-mapping>  
  
  
<filter-mapping>  
<filter-name>springSecurityFilterChain</filter-name>  
<url-pattern>/\*</url-pattern>  
</filter-mapping>  
<filter-mapping>  
<filter-name>hibernateOpenSessionInViewFilterContent</filter-name>  
<url-pattern>/\*</url-pattern>  
</filter-mapping>  
<filter-mapping>  
<filter-name>hibernateOpenSessionInViewFilterIndex</filter-name>  
<url-pattern>/\*</url-pattern>  
</filter-mapping>  
<filter-mapping>  
<filter-name>struts2Filter</filter-name>  
<url-pattern>/\*</url-pattern>  
</filter-mapping>  
  
  
<listener>  
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>  
</listener>  
  
  
<listener>  
<listener-class>org.springframework.web.util.IntrospectorCleanupListener</listener-class>  
</listener>  
  
  
<session-config>  
<session-timeout>20</session-timeout>  
</session-config>  
  
  
<error-page>  
<exception-type>java.lang.Throwable</exception-type>  
<location>/common/500.jsp</location>  
</error-page>  
<error-page>  
<error-code>500</error-code>  
<location>/common/500.jsp</location>  
</error-page>  
<error-page>  
<error-code>404</error-code>  
<location>/common/404.jsp</location>  
</error-page>  
<error-page>  
<error-code>403</error-code>  
<location>/common/403.jsp</location>  
</error-page>  
</web-app>

5、由于项目中有多个SessionFactory，所以编写Dao层的时候需要使用@Resource注解来明确指定使用哪一个SessionFactory，如下面代码所示，ArticleDao使用sessionFactoryContent，而ArticleIndexDao使用sessionFactoryIndex：

package cn.puretext.dao;  
  
import javax.annotation.Resource;  
  
import org.hibernate.SessionFactory;  
import org.springframework.stereotype.Repository;  
import org. **springside**.modules.orm.hibernate.HibernateDao;  
  
import cn.puretext.entity.web.Article;  
  
@Repository  
publicclass ArticleDao extends HibernateDao<Article, Long> \{  
  
    @Override  
    @Resource(name ="sessionFactoryContent"publicvoid setSessionFactory(SessionFactory sessionFactory) \{  
// TODO Auto-generated method stub  
super.setSessionFactory(sessionFactory);  
    \}  
  
\}

package cn.puretext.dao;  
  
import javax.annotation.Resource;  
  
import org.hibernate.SessionFactory;  
import org.springframework.stereotype.Repository;  
import org. **springside**.modules.orm.hibernate.HibernateDao;  
  
import cn.puretext.entity.web.ArticleIndex;  
  
@Repository  
publicclass ArticleIndexDao extends HibernateDao<ArticleIndex, Long> \{  
    @Override  
    @Resource(name ="sessionFactoryIndex"publicvoid setSessionFactory(SessionFactory sessionFactory) \{  
// TODO Auto-generated method stub  
super.setSessionFactory(sessionFactory);  
    \}  
\}

6、在GlassFish中部署项目，部署项目的时候依然使用前面提到的GlassFish的管理界面，这里不赘述。  
  
经过以上六步，就可以成功的在基于 **SpringSide** 3的项目中使用多个数据库。如果你确实很不相使用GlassFish，而对Tomcat情有独钟的话，就要使用我前面提到的“提供JTA功能的其它组件”了。在这里，我推荐使用Atomikos，这是一个很优秀的JTA实现，它的官方网站为，它提供开源版和商业版，下面是从其官方网站上截取的图片：  
![在SpringSide 3 中使用多个数据库的方法 - 海边沫沫 - BlogJava - dingchaoqun12 - dingchaoqun12 的博客][SpringSide 3 _ - _ - BlogJava - dingchaoqun12 - dingchaoqun12 1]  
  
很烦人的是，该网站不直接提供下载地址，如果要下载，就必须先填写姓名邮箱和电话，如果大家不想填写这些信息，可以直接进入这个网址下载http://www.atomikos.com/Main/InstallingTransactionsEssentials，我选择的是3.5.5版。  
  
方法二、使用Tomcat服务器和Atomikos  
  
1、将Atomikos整合到Tomcat服务器中，其步骤可以参考Atomikos的文档，如下：  
http://www.atomikos.com/Documentation/Tomcat6Integration33  
  
2、在Tomcat中配置JNDI数据源，方法是修改Tomcat的content.xml文件，在文件中加入如下两个<Resource/>和一个<Transaction/>：

剩下的四步就和使用GlassFish的第3、4、5、6步一模一样了，这里不赘述。  
  
以上Atomikos和Tomcat的整合方案有时候或多或少出现一点问题，这些问题基本上都和JNDI有关，我想可能是Tomcat实现的JNDI配置有问题。如果出现这样的问题无法解决的话，还有第三种方案，那就是直接在Spring的配置文件中配置Atomikos的JTA相关组件。  
  
方法三、直接在Spring的配置文件中配置Atomikos的JTA相关组件  
  
1、将下载的Atomikos中的jta.properties拷贝到项目的classpath中，将Atomikos的相关jar文件拷贝到项目的classpath中。  
  
2、在项目的applicationContext.xml文件中配置JTA的相关组件，配置文件如下：

<?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-2.5.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.5.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.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>  
</list>  
</property>  
</bean>  
  
  
<context:component-scan base-package="cn.puretext"/>  
  
<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">localhost</prop><prop key="portNumber">3306</prop><prop key="databaseName">puretext</prop><prop key="user">\*\*\*</prop><prop key="password">\*\*\*</prop></props></property><property name="poolSize"><value>3</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">localhost</prop><prop key="portNumber">3306</prop><prop key="databaseName">puretext\_index</prop><prop key="user">\*\*\*</prop><prop key="password">\*\*\*</prop></props></property><property name="poolSize"><value>3</value></property></bean>  
  
  
  
<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">$\{hibernate.ehcache\_config\_file\}</prop>  
</props>  
</property>  
<property name="packagesToScan" value="cn.puretext.entity.\*"/>  
</bean>  
<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">$\{hibernate.ehcache\_config\_file\}</prop>  
</props>  
</property>  
<property name="packagesToScan" value="cn.puretext.entity.\*"/>  
</bean>  
<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"/>  
</bean>  
<tx:annotation-driven transaction-manager="transactionManager"/>  
  
</beans>

3、在web.xml中配置多个OpenSessionInViewFilter，其配置方法同前。  
  
4、在Dao类中使用@Resource指定使用哪一个sessionFactory。  
  
5、运行项目，成功。  
  
在以上的三个方法中，我强烈推荐第三种，因为该方法只需要将Atomikos的相关文件拷贝到项目的classpath中，并在applicationContext.xml文件中完成配置即可，不需要修改应用服务器的任何文件，是非侵入性的，是最轻量级的，同时，也是配置起来最容易成功的，在我的测试过程中基本上是一次成功，没有报错。  
  
好了，就写到这里了，希望**SpringSide**的fans们少走弯路，天天开心。

博主：  
如果有三个或三个以上的数据源怎么办？  
<bean >  
<property ref="atomikosTransactionManager" />  
<property ref="atomikosUserTransaction"/>  
</bean>  
怎么写？

请问博主，按照方法3的配置，是否依赖于web服务器，我用3的配置，然后做测试，总是提示Could not find UserTransaction in JNDI,请问用atomikos，怎么才能不依赖web容器运行？谢谢。

转自：[http://cache.baidu.com/c?m=9d78d513d98203ef03b1c13f564080711925971338c0a71768d5e35fe2174c35317193cc30546613d2b56b1107b8395afeb7762c385966f1d9df8939c0a6c27672dd3034071f824005d36efe961938977bcc0fb8f54abaf9b76e90aecf83810906d7124329c6abda470317ce6df41436e1a0994a165d14bae73366f85c772b9e2842ab&p=836cc64ad5c459f710b9c4710e11d47e&newp=b4759a46d1c003b14bb7d02d0215d0385c5bc4387ebad1127c968d5bc920&user=baidu&fm=sc&query=springside+%B6%E0%CA%FD%BE%DD%D4%B4&qid=c46e7a5b08cf2551&p1=6][http_cache.baidu.com_c_m_9d78d513d98203ef03b1c13f564080711925971338c0a71768d5e35fe2174c35317193cc30546613d2b56b1107b8395afeb7762c385966f1d9df8939c0a6c27672dd3034071f824005d36efe961938977bcc0fb8f54abaf9b76e90aecf83810906d7124329c6abda470317ce6df41436e1a0994a165d14bae73366f85c772b9e2842ab_p_836cc64ad5c459f710b9c4710e11d47e_newp_b4759a46d1c003b14bb7d02d0215d0385c5bc4387ebad1127c968d5bc920_user_baidu_fm_sc_query_springside_B6_E0_CA_FD_BE_DD_D4_B4_qid_c46e7a5b08cf2551_p1_6]

[SpringSide 3 _ - _ - BlogJava - dingchaoqun12 - dingchaoqun12]: /images/20210720/6b9df9dcd1ae4670b73d36f9241d7c17.png
[SpringSide 3 _ - _ - BlogJava - dingchaoqun12 - dingchaoqun12 1]: /images/20210720/540ee762d56d497ab17c77ce1aa97c9d.png
[http_cache.baidu.com_c_m_9d78d513d98203ef03b1c13f564080711925971338c0a71768d5e35fe2174c35317193cc30546613d2b56b1107b8395afeb7762c385966f1d9df8939c0a6c27672dd3034071f824005d36efe961938977bcc0fb8f54abaf9b76e90aecf83810906d7124329c6abda470317ce6df41436e1a0994a165d14bae73366f85c772b9e2842ab_p_836cc64ad5c459f710b9c4710e11d47e_newp_b4759a46d1c003b14bb7d02d0215d0385c5bc4387ebad1127c968d5bc920_user_baidu_fm_sc_query_springside_B6_E0_CA_FD_BE_DD_D4_B4_qid_c46e7a5b08cf2551_p1_6]: http://cache.baidu.com/c?m=9d78d513d98203ef03b1c13f564080711925971338c0a71768d5e35fe2174c35317193cc30546613d2b56b1107b8395afeb7762c385966f1d9df8939c0a6c27672dd3034071f824005d36efe961938977bcc0fb8f54abaf9b76e90aecf83810906d7124329c6abda470317ce6df41436e1a0994a165d14bae73366f85c772b9e2842ab&p=836cc64ad5c459f710b9c4710e11d47e&newp=b4759a46d1c003b14bb7d02d0215d0385c5bc4387ebad1127c968d5bc920&user=baidu&fm=sc&query=springside+%B6%E0%CA%FD%BE%DD%D4%B4&qid=c46e7a5b08cf2551&p1=6