SSM企业版:多数据源+事务_戰士的博客-程序员宝宝

技术标签: 架构  多数据源  Spring  SSM  事务  

前言

之前博客中《SSM+nginx+tomcat+maven+mysql+redis环境搭建及工程全套配置,实现前后端动静分离》只是初级版的SSM体系建设,在这篇文章之前,可参照:https://blog.csdn.net/qq_36632174/article/details/102461255

来了解前博客内容。本篇对上一篇做一个升级,配置多数据源,加入事务、定时任务、流程组件activity。

多数据源

基础配置参照前言中提到的之前写的博客,这次直接加入多数据源部分,多数据源的实现首先在spring-mybatis.xml中添加基础配置:

<!-- 数据源1与数据源2的url相同,数据源3和数据源4都分别有自己连接的数据连接url。四个数据源分别是不同数据库,账号密码都不相同-->

<!-- 数据源1 -->
    <bean id="dataSource1" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <property name="driverClassName" value="${driver}" />
        <property name="url" value="${url}" />
        <property name="username" value="${username1}" />
        <property name="password" value="${password1}" />
        <!-- 从池中获取连接前进行验证 -->
        <property name="testOnBorrow" value="false" />
        <!-- 向池中还回连接前进行验证 -->
        <property name="testOnReturn" value="false" />
        <!-- 连接空闲时验证 -->
        <property name="testWhileIdle" value="true" />
        <!-- 运行判断连接超时任务(evictor)的时间间隔,单位为毫秒,默认为-1,即不执行任务。 -->
        <property name="timeBetweenEvictionRunsMillis" value="300000" />
        <!-- 连接的超时时间,设定为三小时。 -->
        <property name="minEvictableIdleTimeMillis" value="10800000" />
        <!-- 每次evictor启动检查的空闲连接数,-2标识1/2的总空闲连接 -->
        <property name="numTestsPerEvictionRun" value="-1"></property>
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="${initialSize}"></property>
        <!-- 连接池最大数量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="${maxWait}"></property>
    </bean>
    <!-- 数据源2 -->
    <bean id="dataSource2" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <property name="driverClassName" value="${driver}" />
        <property name="url" value="${url}" />
        <property name="username" value="${username2}" />
        <property name="password" value="${password2}" />
        <!-- 从池中获取连接前进行验证 -->
        <property name="testOnBorrow" value="false" />
        <!-- 向池中还回连接前进行验证 -->
        <property name="testOnReturn" value="false" />
        <!-- 连接空闲时验证 -->
        <property name="testWhileIdle" value="true" />
        <!-- 运行判断连接超时任务(evictor)的时间间隔,单位为毫秒,默认为-1,即不执行任务。 -->
        <property name="timeBetweenEvictionRunsMillis" value="300000" />
        <!-- 连接的超时时间,设定为三小时。 -->
        <property name="minEvictableIdleTimeMillis" value="10800000" />
        <!-- 每次evictor启动检查的空闲连接数,-2标识1/2的总空闲连接 -->
        <property name="numTestsPerEvictionRun" value="-1"></property>
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="${initialSize}"></property>
        <!-- 连接池最大数量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="${maxWait}"></property>
    </bean>
    <!-- 数据源3-->
    <bean id="dataSource3" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <property name="driverClassName" value="${driver}" />
        <property name="url" value="${url_3}" />
        <property name="username" value="${username3}" />
        <property name="password" value="${password3}" />
        <!-- 从池中获取连接前进行验证 -->
        <property name="testOnBorrow" value="false" />
        <!-- 向池中还回连接前进行验证 -->
        <property name="testOnReturn" value="false" />
        <!-- 连接空闲时验证 -->
        <property name="testWhileIdle" value="true" />
        <!-- 运行判断连接超时任务(evictor)的时间间隔,单位为毫秒,默认为-1,即不执行任务。 -->
        <property name="timeBetweenEvictionRunsMillis" value="300000" />
        <!-- 连接的超时时间,默认为半小时。 -->
        <property name="minEvictableIdleTimeMillis" value="10800000" />
        <!-- 每次evictor启动检查的空闲连接数,-2标识1/2的总空闲连接 -->
        <property name="numTestsPerEvictionRun" value="-1"></property>
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="${initialSize}"></property>
        <!-- 连接池最大数量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="${maxWait}"></property>
    </bean>
    <!-- 数据源4,链接人员数据库-->
    <bean id="dataSource4" class="org.apache.commons.dbcp.BasicDataSource"
        destroy-method="close">
        <property name="driverClassName" value="${driver}" />
        <property name="url" value="${url4}" />
        <property name="username" value="${username4}" />
        <property name="password" value="${password4}" />
        <!-- 从池中获取连接前进行验证 -->
        <property name="testOnBorrow" value="false" />
        <!-- 向池中还回连接前进行验证 -->
        <property name="testOnReturn" value="false" />
        <!-- 连接空闲时验证 -->
        <property name="testWhileIdle" value="true" />
        <!-- 运行判断连接超时任务(evictor)的时间间隔,单位为毫秒,默认为-1,即不执行任务。 -->
        <property name="timeBetweenEvictionRunsMillis" value="300000" />
        <!-- 连接的超时时间,默认为半小时。 -->
        <property name="minEvictableIdleTimeMillis" value="10800000" />
        <!-- 每次evictor启动检查的空闲连接数,-2标识1/2的总空闲连接 -->
        <property name="numTestsPerEvictionRun" value="-1"></property>
        <!-- 初始化连接大小 -->
        <property name="initialSize" value="${initialSize}"></property>
        <!-- 连接池最大数量 -->
        <property name="maxActive" value="${maxActive}"></property>
        <!-- 连接池最大空闲 -->
        <property name="maxIdle" value="${maxIdle}"></property>
        <!-- 连接池最小空闲 -->
        <property name="minIdle" value="${minIdle}"></property>
        <!-- 获取连接最大等待时间 -->
        <property name="maxWait" value="${maxWait}"></property>
    </bean>

<!-- 3个数据源自动切换 -->
    <bean id="dynamicDataSource" class="com.dlg.common_utils.utils.dynamicds.DynamicDataSource">
        <property name="targetDataSources">
            <map key-type="java.lang.String">
                <!-- 指定lookupKey和与之对应的数据源,由于数据源3和数据源4的特殊性,下面会有其它处理-->
                <entry key="dataSource1" value-ref="dataSource1"></entry>
                <entry key="dataSource2" value-ref="dataSource2"></entry>
                <entry key="dataSource3" value-ref="dataSource3"></entry>
            </map>
        </property>
    </bean>

<!-- 数据源3和数据源4开启的另外的bean -->

<bean id="sqlSessionFactory3" class="org.mybatis.spring.SqlSessionFactoryBean">
      <property name="dataSource" ref="dataSource3" />
      <property name="mapperLocations">
        <list>
            <value>classpath*:com/dlg/**/sqlmap/GWorkflowRequestlogMapper.xml</value> <!-- 映射到mapper.xml文件-->
            <value>classpath*:com/dlg/**/sqlmap/GOaUserMapper.xml</value> <!-- 映射到mapper.xml文件-->
        </list>
      </property>
    </bean>
    <bean id="sqlSessionFactory4" class="org.mybatis.spring.SqlSessionFactoryBean">
      <property name="dataSource" ref="dataSource4" />
      <property name="mapperLocations">
        <list>
            <value>classpath*:com/dlg/**/sqlmap/JKDeptMapper.xml</value> <!-- 映射到mapper.xml文件-->
            <value>classpath*:com/dlg/**/sqlmap/PersCardMapper.xml</value>
            <value>classpath*:com/dlg/**/sqlmap/RyddMapper.xml</value>
            <value>classpath*:com/dlg/**/sqlmap/TugUsercheckMapper.xml</value>
        </list>
      </property>
    </bean>

<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.3" />
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory3"></property>
    </bean>
    <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <property name="basePackage" value="com.4" />
        <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory4"></property>
    </bean>

以上,spring-mybatis.xml文件就配置完成,由于使用的是spring框架体系,所以采用注解的形式来实现数据源的自动切换和指定,还需要在工具类中定义好注解:

1、首先定义注解类:DataSource.java,以后在Dao层文件中,指定数据源使用@DataSource注解

import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;

/**
 * 切换数据源自定义注解
 */
@Target({ ElementType.METHOD, ElementType.TYPE }) // 定义注解应用于类(Type)和方法(method)
@Retention(RetentionPolicy.RUNTIME) // 注解的@Retention为RUNTIME时,才能够通过运行时的反射机制来处理注解
public @interface DataSource {
    String value();
}

2、接下来是两个基础类,分别:

数据源控制类:DynamicDataSourceHolder.java

数据源标识获取类:DynamicDataSource.java,让数据源注解通过参数指定数据源。

DynamicDataSourceHolder.java如下:

/**
 * 数据源的控制
 *
 */
public class DynamicDataSourceHolder {
    /*数据源标识保存在线程变量中,避免多线程操作数据源时互相干扰*/
    private static final ThreadLocal<String> THREAD_DATA_SOURCE = new ThreadLocal<String>();
    
    public static String getDataSource() {
        return THREAD_DATA_SOURCE.get();
    }
    public static void setDataSource(String dataSource) {
        THREAD_DATA_SOURCE.set(dataSource);
    }
    
    public static void clearDataSource() {
        THREAD_DATA_SOURCE.remove();
    }
}

DynamicDataSource.java如下:

import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

/**
 * 数据源标识获取
 */
public class DynamicDataSource extends AbstractRoutingDataSource{

    @Override
    protected Object determineCurrentLookupKey() {
        // 从自定义的位置获取数据源标识
        return DynamicDataSourceHolder.getDataSource();
    }
}

3、基础类准备后,是解析类,让注解生效

DataSourceAspect.java如下:

import java.lang.reflect.Method;

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.reflect.MethodSignature;


public class DataSourceAspect {

    /**
     * 拦截目标方法,获取由@DataSource指定的数据源标识,设置到线程存储中以便切换数据源
     *
     * @param point
     * @throws Exception
     */
    public void intercept(JoinPoint point) throws Exception {
        Class<?> target = point.getTarget().getClass();
        MethodSignature signature = (MethodSignature) point.getSignature();
        for (Class<?> clazz : target.getInterfaces()) {
            resolveDataSource(clazz, signature.getMethod());
        }
        resolveDataSource(target, signature.getMethod());
    }

    /**
     * 提取目标对象方法注解和类型注解中的数据源标识
     *
     * @param clazz
     * @param method
     */
    private void resolveDataSource(Class<?> clazz, Method method) {
        try {
            Class<?>[] types = method.getParameterTypes();
            // 默认使用类型注解,解析DataSource注解
            if (clazz.isAnnotationPresent(DataSource.class)) {
                DataSource source = clazz.getAnnotation(DataSource.class);
                DynamicDataSourceHolder.setDataSource(source.value());
            }
            // 方法注解可以覆盖类型注解
            Method methodtype = clazz.getMethod(method.getName(), types);
            if (methodtype != null
                    && methodtype.isAnnotationPresent(DataSource.class)) {
                DataSource dataSource = clazz.getAnnotation(DataSource.class);
                DynamicDataSourceHolder.setDataSource(dataSource.value());
            }
        } catch (Exception e) {
            System.out.println(clazz + ":" + e.getMessage());
        }
    }
}

4、最后回到spring-mybatis.xml添加切面,指定切面位置:

<!-- 加入拦截规则,比如拦截service或者dao层的所有方法 -->
    <bean id="dataSourceAspect" class="com.dlg.common_utils.utils.dynamicds.DataSourceAspect">
    </bean>
    <aop:config>
        <aop:aspect ref="dataSourceAspect">
            <!-- 拦截所有dao方法 -->
            <aop:pointcut id="dataSourcePointcut"
                expression="execution(* com.dlg.*.dao.*.*(..))" />
            <aop:before pointcut-ref="dataSourcePointcut" method="intercept" />
        </aop:aspect>
    </aop:config>

5、以上准备完成后,在Dao文件中的使用,参数必须是在spring-mybatis.xml文件中声明过的才生效

@DataSource("dataSource1")
public interface MRMaterialShipWarehouseDao {

。。。。。。

}

添加事务

多数据源已经配置完成,也需要开启多数据源的事务spring-mybatis.xml:

<tx:annotation-driven transaction-manager="transactionManager1" />
    <bean id="transactionManager1"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource1" />
    </bean>

<tx:annotation-driven transaction-manager="transactionManager2" />
    <bean id="transactionManager2"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource2" />
    </bean>

xml文件配置完成后,在service实现类的方法级别可直接使用注解@Transactional,例:

 @Override
    @Transactional(propagation=Propagation.REQUIRED)
    public boolean addApply(SYSUser user, JSONObject object) {
。。。。。。。。}

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_36632174/article/details/103215280

智能推荐

数据库学习的一些基础知识及常用命令_原地打转㐅的博客-程序员宝宝

【数据库基本概念】一个表只能有一个主键(primary key),主键列不允许为空值(null)一个表中可以有多个列作为主键列,但需要考虑最少性和稳定性外键(foreign key):确保“从表”中的某个数据项在“主表”中必须存在【基本术语】DB:数据库DBA:数据库管理员DBM:数据库管理系统DBS:数据库系统【SQL分类】DDL:数据定义语言用来创建数据库中...

ERROR org.mortbay.log - failed java.lang.NoClassDefFoundError: org/apache/log4j/PropertyConfigurator_wind520的博客-程序员宝宝_org.mortbay.log

今天安装 red5 0.7  下载地址http://osflash.org/red5按照网上的教程step by step的做报错:ERROR org.mortbay.log - failed  java.lang.NoClassDefFoundError: org/apache/log4j/PropertyConfigurator开始以为是log4j的版本问题,下载后,还是不行然

Airtest源码解析_FuWen_Hao的博客-程序员宝宝_airtest源码

Airtest图像识别Airtest介绍源码touch方法测试代码与结果:AKAZE局部匹配介绍代码比较最终用到的就是OpenCV的两个方法:模版匹配和特征匹配Airtest介绍Airtest是一款网易出品的基于图像识别面向手游UI测试的工具,也支持原生Android App基于元素识别的UI自动化测试(现在支持Android、ios、Windows)。主要包含了三部分:Airtest IDE、Airtest(用截图写脚本)和 Poco(用界面UI元素来写脚本)。来自Google的评价:Airtest

ssh登陆服务器locale告警(-bash: warning: setlocale:)的处理方法_weixin_33857230的博客-程序员宝宝

 使用ssh远程登陆 IDC机房服务器,发现老是出现如下告警信息:-bash: warning: setlocale: LC_CTYPE: cannot change locale (en_US.UTF-8): No such file or directory-bash: warning: setlocale: LC_COLLATE: cannot change locale (en_U...

企业架构之道(四)企业架构Zachman方法_晨晨的使魔的博客-程序员宝宝

                                                                                                                                                        ——软件架构是多角度多形式的        Zachman框架由约翰 扎科曼(John Za...

Android 消息传递之Intent和IntentFilter的匹配规则_qq_34341338的博客-程序员宝宝

1.Intent概述及作用Intent 是一个消息传递对象,您可以使用它从其他应用组件请求操作。详见官方文档主要功能如下:启动Activity通过将 Intent 传递给 startActivity(),您可以启动新的 Activity 实例。Intent 描述了要启动的 Activity,并携带了任何必要的数据。如果您希望在 Activity 完成后收到结果,请调用 start...

随便推点

jstat命令查看jvm的GC情况(jdk1.8 linux)_Xing-_-L的博客-程序员宝宝

初步了解gc 变化并理解 JVM 内存回收策略一、JVM垃圾回收算法主要有以下几种:1、标记-清除法2、复制算法3、标记-整理法4、分代收集法(现在的虚拟机垃圾收集大多采用这种方式)二、使用jstat监控GC情况语法结构:$ jstat -helpUsage: jstat -help|-options jstat -&lt;option&gt; [-t] [-h&lt;lines&gt;] &lt;vmid&gt; [&lt;interval&gt; [&lt;count&

救基友记2_Rwen猿的博客-程序员宝宝

Eddy的难题Time Limit: 1000 ms Memory Limit: 65536 KiBProblem Description人随着岁数的增长是越大越聪明还是越大越笨,这是一个值得全世界科学家思考的问题,同样的问题Eddy也一直在思考,因为他在很小的时候就知道亲和串如何 判断了,但是发现,现在长大了却不知道怎么去判断亲和串了,于是他只好又再一次来请教聪明且乐于助人的你来解决这个问...

【动态规划】从子集和问题到背包问题_去门口罚站的博客-程序员宝宝

一、问题定义有一个包含n个元素{e1, e2, …, en}的集合S,每个元素ei都有一个对应的权值wi。现在有一个界限W,我们希望从S中选择出部分元素,使得这些元素的权值之和在不超过W的情况下达到最大,这个便是子集合问题(事实上还有其他类型的子集和问题,本文暂不讨论)。举个更具体一点的例子,某农民今年收成小番茄总重量为W万斤,有n个采购商想要向这位农民收购小番茄,他们想要采购的数目都有所不同,采购

Java 利用已知数组求最大值、最小值、总和、平均值_多喝清晨的粥的博客-程序员宝宝_java数组求平均值和最大值

已知数组元素为 {45,32,33,44,55}public static void main(String[] args) {/* 分析: 1.从数组中找出最大值 2.数组中找出最小值 3.求出数组总和 4.出数组平均值*/ //创建数组 int arr[]={11,22,33,44,55}; //先假设第一个索引值最大 int max=arr[0]; //循环遍历 for (int i = 1; i .

第十二章:STM32是如何进入中断函数xxx_IRQHandler的_qq_33553024的博客-程序员宝宝_irqhandler

STM32是如何进入中断函数xxx_IRQHandler的,如:void USART1_IRQHandler(void) 前段时间开始接触STM32的时候遇到这样一个问题,程序里面配置好中断设置时,程序运行的时候是怎么进入中断函数的(当然这里所说的中断都是硬件中断),因为跑C程序的时候,本人的理解是,你总得有个“接力棒”或者一个“入口”吧,它才能进入到下一个函数中去。 以uart1配置作为

tf.variance_scaling_initializer() tensorflow学习:参数初始化_weixin_ry5219775的博客-程序员宝宝

CNN中最重要的就是参数了,包括W,b。 我们训练CNN的最终目的就是得到最好的参数,使得目标函数取得最小值。参数的初始化也同样重要,因此微调受到很多人的重视,那么tf提供了哪些初始化参数的方法呢,我们能不能自己进行初始化呢?所有的初始化方法都定义在tensorflow/python/ops/init_ops.py1、tf.constant_initializer()也可以简...

推荐文章

热门文章

相关标签