2. 程式人生 > >SSM整合系列之 配置多資料來源 利用AOP動態切換資料來源 實現讀寫分離

SSM整合系列之 配置多資料來源 利用AOP動態切換資料來源 實現讀寫分離

阿新 • • 發佈：2018-12-27

摘要：在開發的專案中大都都會使用讀寫分離的技術，本人目前開發的專案接觸到的都是主從複製(一主一從)，就是一個Master資料庫，一個Slave資料庫。主庫負責資料插入、更新和實時資料查詢，從庫庫負責非實時資料查詢。在實際專案應用中，都是讀多寫少，而讀取資料通常比較複雜而且耗時，SQL語句需要各種優化。採用讀寫分離技術可以有效緩解資料庫的壓力，加快響應速度，提升使用者體驗。如果隨著業務不斷擴充套件，資料不斷增加，那麼可以擴充套件多個從節點（一主多從），使用負載均衡，減輕每個從庫的查詢壓力。本文將從一主一從說開去。
SpringAop面向切面程式設計在本文就不詳細介紹，如果不清楚可自行百度Google。

1.專案搭建
可以參考本系列文章，部落格地址：https://blog.csdn.net/caiqing116/article/details/84573166
或者直接下載專案，git地址：https://github.com/gitcaiqing/SSM_DEMO.git
2.搭建MySQL主從複製
在寫本文的時候我特地搭建了2個MySQL服務，埠號分別是3306，3308
搭建MySQL主從複製可參考：https://blog.csdn.net/caiqing116/article/details/84995472
3.專案配置
（1）config/jdbc.config配置

#連線驅動
jdbc.driverClassName=com.mysql.jdbc.Driver

#埠號3306的資料來源
jdbc.url = jdbc\:mysql\://localhost\:3306/db_ssmdemo?useUnicode\=true&characterEncoding\=UTF-8&allowMultiQueries\=true
jdbc.username = root
jdbc.password = 123456

#埠號3308的資料來源
jdbc.3308.url = jdbc\:mysql\://localhost\:3308/db_ssmdemo?useUnicode\=true&characterEncoding\=UTF-8&allowMultiQueries\=true
jdbc.3308.username = root
jdbc.3308.password = 123456

#定義初始連線數 
jdbc.initialSize=2 
#定義最大連線數 
jdbc.maxActive=20
#定義最大空閒 
jdbc.maxIdle=20
#定義最小空閒 
jdbc.minIdle=1
#定義最長等待時間 
jdbc.maxWait=60000
#驗證資料庫連線的有效性
jdbc.validationQuery=select 1

（2）spring/mybatis.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:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.1.xsd">
	
	<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
		<property name="dataSource" ref="dataSource" />
		<property name="mapperLocations">
			 <list>
                <value>classpath:sql/*.xml</value>
            </list>
		</property>
	</bean>

	<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
		<property name="basePackage" value="com.ssm.mapper" />
		<property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
	</bean>
	<bean id="sqlSession" class="org.mybatis.spring.SqlSessionTemplate" scope="prototype">
  		<constructor-arg index="0" ref="sqlSessionFactory" />
	</bean>
	
	<!-- 使用annotation定義事務，使用cglib代理，解決同一service中事務方法相互呼叫的 巢狀事務失效問題 -->
	<tx:annotation-driven transaction-manager="transactionManager"  proxy-target-class="true"/>
	<!--事務配置 -->
	<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
		<property name="dataSource" ref="dataSource" />
	</bean>
	
</beans>

（3）spring/dataAccessContext.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:tx="http://www.springframework.org/schema/tx"
	xmlns:aop="http://www.springframework.org/schema/aop"
	xsi:schemaLocation="
		http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd
		http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.1.xsd
		http://www.springframework.org/schema/aop
		http://www.springframework.org/schema/aop/spring-aop-4.0.xsd">
	<description>資料庫、事務配置</description>
	
	<!-- 埠號3306的資料來源(主節點)-->
	<bean id="dataSource3306" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
		<property name="driverClassName" value="${jdbc.driverClassName}" />
		<property name="url" value="${jdbc.url}" />
		<property name="username" value="${jdbc.username}" />
		<property name="password" value="${jdbc.password}" />
		<property name="initialSize" value="${jdbc.initialSize}" />
		<property name="maxActive" value="${jdbc.maxActive}" />
		<property name="maxIdle" value="${jdbc.maxIdle}" />
		<property name="minIdle" value="${jdbc.minIdle}" />
		<property name="maxWait" value="${jdbc.maxWait}"></property>
		<property name="validationQuery" value="${jdbc.validationQuery}" />
		<!-- 監控資料庫 -->
		<!--<property name="filters" value="mergeStat" />-->
		<property name="filters" value="stat" /> 
		<property name="connectionProperties" value="druid.stat.mergeSql=true" />  
	</bean>
	
	<!-- 埠號3308的資料來源(從節點) -->
	<bean id="dataSource3308" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
		<property name="driverClassName" value="${jdbc.driverClassName}" />
		<property name="url" value="${jdbc.3308.url}" />
		<property name="username" value="${jdbc.3308.username}" />
		<property name="password" value="${jdbc.3308.password}" />
		<property name="initialSize" value="${jdbc.initialSize}" />
		<property name="maxActive" value="${jdbc.maxActive}" />
		<property name="maxIdle" value="${jdbc.maxIdle}" />
		<property name="minIdle" value="${jdbc.minIdle}" />
		<property name="maxWait" value="${jdbc.maxWait}"></property>
		<property name="validationQuery" value="${jdbc.validationQuery}" />
		<!-- 監控資料庫 -->
		<!--<property name="filters" value="mergeStat" />-->
		<property name="filters" value="stat" /> 
		<property name="connectionProperties" value="druid.stat.mergeSql=true" />  
	</bean>
	
	<!-- 資料來源，需要自定義類繼承AbstractRoutingDataSource，實現determineCurrentLookupKey -->
	<bean id="dataSource" class="com.ssm.datasource.DynamicDataSource">
		<!-- 設定預設資料來源 -->
		<property name="defaultTargetDataSource" ref="dataSource3306"></property>
		<!-- 設定多個數據源，後臺切換資料來源key與這裡key配置需要一致 -->
		<property name="targetDataSources">
			<map key-type="java.lang.String">
				<entry key="dataSource3306" value-ref="dataSource3306"/>
				<entry key="dataSource3308" value-ref="dataSource3308"/>
			</map>
		</property>
          <!-- 實現類自定義屬性DynamicDataSource賦值切換從庫的方法名字首 -->
		<property name="methodPrefix">
			<map key-type="java.lang.String">
				<entry key="slave">
					<!-- "list","count","find","get","select","query" 等，根據開發人員方法命名習慣配置 -->
					<list>
						<value>list</value>
						<value>count</value>
						<value>find</value>
						<value>get</value>
						<value>select</value>
						<value>query</value>
					</list>
				</entry>
			</map>
		</property>
	</bean>
    
</beans>

（5）修改spring/applicationContext.xml 配置啟用AOP註解

<?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:tx="http://www.springframework.org/schema/tx"
	   xmlns:task="http://www.springframework.org/schema/task" 
	   xmlns:cache="http://www.springframework.org/schema/cache" 
	   xmlns:aop="http://www.springframework.org/schema/aop"
	   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.1.xsd
		http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.1.xsd 
		http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd 
		http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache.xsd
		http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.1.xsd ">

	<!--引入配置屬性檔案 -->
	<context:property-placeholder location="classpath*:config/*.properties" />
	
	<!-- 包掃描,掃描切面 -->
	<context:component-scan base-package="com.ssm,com.ssm.aspect">
		<context:exclude-filter type="annotation" expression="org.springframework.stereotype.Controller"/>
	</context:component-scan>
	
	<!-- 基於註解 使AspectJ註解起 作用：自動為匹配的類生成代理物件 -->
  	<aop:aspectj-autoproxy proxy-target-class="true"/>
	
    <!-- 執行緒池配置 -->
    <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
		<!-- 核心執行緒數 -->	 
		<property name="corePoolSize" value="5"/>
		<!-- 最大執行緒數 -->  
		<property name="maxPoolSize" value="50"/>
		<!-- 佇列最大長度 -->
		<property name="queueCapacity" value="1000"/>
		<!-- 執行緒池維護執行緒所允許的空閒時間，預設為60s -->
		<property name="keepAliveSeconds" value="6"/>
	</bean>
</beans>

4.自定義類繼承AbstractRoutingDataSource，實現determineCurrentLookupKey，並且自定義屬性methodPrefix用於設定切換到從節點的方法名字首
AbstractRoutingDataSource的相關原始碼在我的另一篇文章中有介紹，參考博文：https://blog.csdn.net/caiqing116/article/details/84979682
我們實現determineCurrentLookupKey方法，返回值為dataSource3306或dataSource3308，定義屬性Map<String,List> methodPrefix用於方法名字首賦值，具體實現如下：

package com.ssm.datasource;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

/**
 * 定義動態資料來源，整合spring提供的AbstractRoutingDataSource，實現determineCurrentLookupKey
 * @author https://blog.csdn.net/caiqing116
 */
public class DynamicDataSource extends AbstractRoutingDataSource{
	
	private static final Logger log = LoggerFactory.getLogger(DynamicDataSource.class);
	
	/*
	 * 定義一個方法字首methodPrefix屬性，通過配置檔案賦值，該map儲存資料來源和方法字首的值形如形如
	 * {"slave",["list","count","find","get","select","query","等不一一列舉"]}
	 * 這裡的方法字首根據開發人員的習慣可自行配置
	*/
	public static Map<String,List<String>> methodPrefix = new HashMap<String, List<String>>();
	
	//設定切換到從庫的方法字首
	@SuppressWarnings("static-access")
	public void setMethodPrefix(Map<String, List<String>> methodPrefix) {
		this.methodPrefix = methodPrefix;
	}

	@Override
	protected Object determineCurrentLookupKey() {
		Object dataType = DataSourceContextHolder.getDataType();
		log.info("當前資料來源：{}",dataType);
		return dataType;
	}
 
}

5.藉助ThreadLocal類，通過ThreadLocal類傳遞引數設定資料來源，並且新增方法isSlave根據引數判斷是否切換到從節點

package com.ssm.datasource;

import java.util.List;
import java.util.Map;

import org.apache.commons.lang3.StringUtils;

/**
 * 切換資料來源，清除資料來源資訊等
 * @author https://blog.csdn.net/caiqing116
 */
public class DataSourceContextHolder {
	
	
	//定義資料來源標識和配置檔案dataAccessContext.xml配置的bean id一致
	public static final String DATASOURCE = "dataSource3306";
	public static final String DATASOURCE3308 = "dataSource3308";
	//定義從庫標識，和配置
	public static final String SLAVE = "slave";

	private static final ThreadLocal<String> contextHolder = new ThreadLocal<String>();
	
	/**
	 * 設定當前資料來源
	 * @param dataType 資料元型別 DATASOURCE | DATASOURCE3308
	 */
	public static void setDatatype(String dataType) {
		contextHolder.set(dataType);
	}
	
	/**
	 * 獲取當前資料來源
	 * @return
	 */
	public static String getDataType(){
		return contextHolder.get();
	}
	
	/**
	 * 清除
	 */
	public static void clear() {
		contextHolder.remove();
	}
	
	/**
	 * 切到3306埠資料來源
	 */
	public static void mark3306() {
		setDatatype(DATASOURCE);
	}
	
	/**
	 * 切到3308埠資料來源
	 */
	public static void mark3308() {
		setDatatype(DATASOURCE3308);
	}

	/**
	 * 判斷是否進入從庫
	 * @return
	 */
	public static boolean isSlave(String methodName) {
		//未配置切換到從庫的方法名字首，返回false,預設切換到主庫
		Map<String, List<String>> methodPrefix = DynamicDataSource.methodPrefix;
		if(methodPrefix == null) {
			return false;
		}
		List<String> methodPrefixs = methodPrefix.get(SLAVE);
		if(methodPrefixs.isEmpty()) {
			return false;
		}
		//方法名字首和配置的相同則切換到從庫
		if(StringUtils.startsWithAny(methodName, methodPrefixs.toArray(new CharSequence[methodPrefixs.size()]))) {
			return true;
		}
		return false;
	}
	
}

6.定義切面類
建立包com.ssm.aspect，建立類DataSourceAspect.java，具體實現如下

package com.ssm.aspect;

import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;

import com.ssm.datasource.DataSourceContextHolder;

/**
 * 定義一個數據源切換的切面
 * @aspect 註釋對於在類路徑中自動檢測是不夠的：為了達到這個目的，您需要新增一個單獨的@component註解
 * @author https://blog.csdn.net/caiqing116 
 */
@Aspect
@Component
public class DataSourceAspect {

	private static final Logger log = LoggerFactory.getLogger(DataSourceAspect.class);
	
	/**
	 * 定義切面
	 * 跟資料來源相關的操作都是在service包下
	 */
	@Pointcut("execution(* com.ssm.service.*.*(..))")
	public void servicePoint(){}
	
	/**
	 * 根據切入點進行資料來源的切換
	 */
	@Before("servicePoint()")
	public void before(JoinPoint joinpoint){
		String className = joinpoint.getTarget().getClass().getName();
		String methodName = joinpoint.getSignature().getName();
		//判斷如果方法名開頭符合從庫，則切換到從庫（埠號3308的服務）
		if(DataSourceContextHolder.isSlave(methodName)) {
			log.info("執行類："+className+" 方法："+methodName+"，切換到從庫");
			DataSourceContextHolder.mark3308();
		}else {
			log.info("執行類："+className+" 方法："+methodName+"，切換到主庫");
			DataSourceContextHolder.mark3306();
		}
	}
}

7.測試
編寫增刪查改Service和實現類，這些在之前的文章中有介紹，就不重複介紹了

com/ssm/service/BasicUserService.java
package com.ssm.service;

import java.util.List;

import com.ssm.entity.BasicUser;
import com.ssm.entity.Page;

/**
 * 使用者Service
 * @author https://blog.csdn.net/caiqing116
 *
 */
public interface BasicUserService {
	
	Integer insert(BasicUser basicUser);
	
	Integer deleteById(Integer id);
	
	BasicUser selectById(Integer id);
	
	Integer updateById(BasicUser basicUser);
	
	BasicUser selectByUsername(String username);
}

com/ssm/service/impl/BasicUserServiceImpl.java

package com.ssm.service.impl;


import java.util.ArrayList;
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.ssm.entity.BasicUser;
import com.ssm.entity.Page;
import com.ssm.mapper.BasicUserMapper;
import com.ssm.service.BasicUserService;

/**
 * 使用者Service實現類
 * @author https://blog.csdn.net/caiqing116
 *
 */
@Service
public class BasicUserServiceImpl implements BasicUserService{

	@Autowired
	private BasicUserMapper basicUserMapper;
	
	/**
	 * 插入使用者
	 */
	public Integer insert(BasicUser basicUser) {
		return basicUserMapper.insertSelective(basicUser);
	}

	/**
	 * 根據id刪除
	 */
	public Integer deleteById(Integer id) {
		return basicUserMapper.deleteByPrimaryKey(id);
	}

	/**
	 * 根據id查詢
	 */
	public BasicUser selectById(Integer id) {
		return basicUserMapper.selectByPrimaryKey(id);
	}

	/**
	 * 根據id更新
	 */
	public Integer updateById(BasicUser basicUser) {
		return basicUserMapper.updateByPrimaryKeySelective(basicUser);
	}

	/**
	 * 根據使用者名稱查詢
	 */
	public BasicUser selectByUsername(String username) {
		return basicUserMapper.selectByUsername(username);
	}

}

Service測試類

package com.ssm.service;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import com.ssm.entity.BasicUser;
import com.ssm.util.EncryptKit;
import com.ssm.util.UuidUtil;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = { "classpath:spring/*.xml","classpath:servlet/*.xml" })
public class BasicUserServiceTest {
	
	private static final Logger log = LoggerFactory.getLogger(BasicUserServiceTest.class);
	
	@Autowired
	private BasicUserService basicUserService;

	@Test
	public void testInsert() {
		BasicUser basicUser = new BasicUser();
		basicUser.setUtype(1);
		basicUser.setUserid(UuidUtil.getUuid());
		basicUser.setUsername("嘆稀奇");
		basicUser.setRealname("嘆稀奇");
		basicUser.setPassword(EncryptKit.MD5("123456"));
		basicUser.setAge(18);
		//手動切換資料來源測試程式碼
		//切換到3308插入資料
		/*DataSourceContextHolder.clear();
		DataSourceContextHolder.mark3306();
		int result = basicUserService.insert(basicUser);
		DataSourceContextHolder.clear();*/
		//自動切換資料來源測試
		int result = basicUserService.insert(basicUser);
		log.info("basicUser:"+basicUser);
		log.info("插入行數："+result);
	}

	@Test
	public void testDeleteById() {
		int result = basicUserService.deleteById(1);
		log.info("刪除行數："+result);
	}

	@Test
	public void testSelectById() {
		BasicUser basicUser = basicUserService.selectById(1);
		log.info("basicUser:"+basicUser);
	}

	@Test
	public void testUpdateById() {
		BasicUser basicUser = new BasicUser();
		basicUser.setId(1);
		basicUser.setAge(19);
		int result = basicUserService.updateById(basicUser);
		log.info("更新行數："+result);
	}

	@Test
	public void testSelectByUsername() {
		String username = "墨傾池";
		BasicUser basicUser = basicUserService.selectByUsername(username);
		log.info("basicUser："+basicUser);
	}

}

在測試中，我們看下日誌檔案的列印
測試方法： testSelectById，日誌如下：

[INFO] 執行類：com.ssm.service.impl.BasicUserServiceImpl 方法：selectById，切換到從庫 
[INFO] 當前資料來源：dataSource3308

測試方法：insert，日誌如下：

[INFO] 執行類：com.ssm.service.impl.BasicUserServiceImpl,方法：insert，切換到主庫 
[INFO] 當前資料來源：dataSource3306

在測試插入的時候，我們可以分別查詢下主庫和從庫的資料，可以驗證主從是否正常同步，如下圖說明讀寫分離是成功的
在這裡插入圖片描述
在這裡插入圖片描述

8.Service層呼叫內部方法無法切換資料來源問題

/**
 * 根據id查詢
 */
public BasicUser selectById(Integer id) {
	//該方法內部含有一些其他業務處理，如插入刪除更新操作等等需要，需要切換到主節點
	//在這裡進行了Service層內部方法呼叫
	//一般理解，這裡會切換到從庫，實際是不會的
	log.info("執行刪除操作開始");
	this.deleteById(3);
	log.info("執行刪除操作結束");
	
	return basicUserMapper.selectByPrimaryKey(id);
}

執行測試方法testSelectById，日誌如下：

[INFO] 執行類：com.ssm.service.impl.BasicUserServiceImpl 方法：selectById，切換到從庫 
[INFO] 執行刪除操作開始 
[INFO] 進入方法deleteById..... 
[INFO] 執行刪除操作結束 
[INFO] 當前資料來源：dataSource3308 
[INFO] basicUser:BasicUser [id=1, userid=bc8bbfb770ee4f2c9ba0f988a7a92d4f, utype=1, username=墨傾池, password=E10ADC3949BA59ABBE56E057F20F883E, headimg=null, realname=雲天望垂, sex=null, age=19, mobile=null, email=null, credate=Fri Dec 07 14:50:20 CST 2018, upddate=null]

可以看出在進入方法deleteById並沒有切換資料來源。這是為什麼呢，原來Service中如此呼叫並非呼叫的是代理類中的方法，然而必須要呼叫代理類才會被切進去。
在這裡插入圖片描述
在這裡插入圖片描述

既然只有呼叫代理類的方法才能切入，那我們就拿到代理類，再進行呼叫。修改selectById方法。

/**
 * 根據id查詢
 */
public BasicUser selectById(Integer id) {
	//該方法內部含有一些其他業務處理，如插入刪除更新操作等等需要，需要切換到主節點
	//在這裡進行了Service層內部方法呼叫
	//一般理解，這裡會切換到從庫，實際是不會的
	log.info("執行刪除操作開始");
	//this.deleteById(3);
	
	//獲取代理類
	BasicUserService proxy = ((BasicUserService)AopContext.currentProxy());
	proxy.deleteById(3);
	log.info("執行刪除操作結束");
	
	return basicUserMapper.selectByPrimaryKey(id);
}

執行後報錯,提示需要設定expose-proxy屬性為true，將代理暴露出來

java.lang.IllegalStateException: Cannot find current proxy: Set 'exposeProxy' property on Advised to 'true' to make it available.
at org.springframework.aop.framework.AopContext.currentProxy(AopContext.java:64)
at com.ssm.service.impl.BasicUserServiceImpl.selectById(BasicUserServiceImpl.java:59)
at com.ssm.service.impl.BasicUserServiceImpl$$FastClassBySpringCGLIB$$f982c283.invoke(<generated>)

我們修改下spring/applicationContext.xml

<!-- 基於註解 使AspectJ註解起 作用：自動為匹配的類生成代理物件 -->
<aop:aspectj-autoproxy proxy-target-class="true" expose-proxy="true"/>

再次執行我們檢視BasicUserService物件為代理物件，如下圖
在這裡插入圖片描述
檢視日誌如下，執行刪除操作的時候資料來源從從庫切到了主庫

[INFO] 執行類：com.ssm.service.impl.BasicUserServiceImpl 方法：selectById，切換到從庫 
[INFO] 執行刪除操作開始 
[INFO] 執行類：com.ssm.service.impl.BasicUserServiceImpl 方法：deleteById，切換到主庫 
[INFO] 進入方法deleteById..... 
[INFO] 執行刪除操作結束 
[INFO] 當前資料來源：dataSource3306

相關推薦

SSM整合系列之 配置多資料來源 利用AOP動態切換資料來源 實現讀寫分離

摘要：在開發的專案中大都都會使用讀寫分離的技術，本人目前開發的專案接觸到的都是主從複製(一主一從)，就是一個Master資料庫，一個Slave資料庫。主庫負責資料插入、更新和實時資料查詢，從庫庫負責非實時資料查詢。在實際專案應用中，都是讀多寫少，而讀取資料通常比較複雜而且耗時，SQL語句

SSM整合系列之 配置多資料來源並實現手動切換資料來源可實現讀寫分離

摘要：在之前的開發中有很多場景用到了多資料來源的情況，如在做資料冷熱遷移的時候，將冷資料遷移到另一個庫，查詢冷資料時需要切換資料庫；在和天貓京東等電商對接時，因為有多套系統在同時使用，在客戶授權時，需要根據客戶使用的版本，儲存到對應的資料庫中。基於此，在這裡呢簡單實現一個SSM系統的多資

SSM整合系列之 配置阿里DruidDataSource並實現SQL監控

摘要：Druid是阿里巴巴開源平臺上一個資料庫連線池實現，它結合了C3P0、DBCP、PROXOOL等DB池的優點，同時加入了日誌監控，可以很好的監控DB池連線和SQL的執行情況。正常訪問路IP地址/專案名/druid/index.html。本專案執行後效果如下圖 1.專案搭建 可以

SSM整合系列之 整合Shiro實現登陸認證

前言：Apache Shiro是一個強大且易用的Java安全框架,執行身份驗證、授權、密碼和會話管理，本文將介紹Spring整合Shiro實現登陸認證功能。對Shiro需要更深入的瞭解，請自學（一個禮貌的微笑）本人後續也會詳細總結Shiro。繼本文之後我也將繼續完善登陸的RemberMe

SSM整合系列之 實現物件的增刪查改（CRUD）操作

本文將詳細介紹SSM整合後通過Mybatis實現物件的增刪查改 1.根據Mybatis逆向工程生產實體類，Mapper(Dao),Sql 我自己實現了一個專案，並且帶有自定義註釋， 專案git地址：https://github.com/gitcaiqing/mybatis_generat

SSM整合系列之 SSM專案整合

Spring、SpringMVC和Mybatis已經是非常成熟的框架了，使用該框架開發已有些時日了，從今天開始呢就對用此框架開發的過程進行一系列的總結，旨在個人總結中提升自己，同時能幫到需要的人就更好了（大牛可忽略此文）。本文將著重介紹專案的搭建整合。 專案git地址：https://g

SSM整合系列之 整合Quartz簡單實現任務排程

1.摘要：Quartz是Java領域的開源任務排程工具，是一個任務排程框架，通過觸發器設定作業的定時執行規則，來執行定時任務。在專案中使用頻繁，本文將在SSM整合專案上整合Quartz框架實現任務排程。 基礎專案的搭建參考文章：https://blog.csdn.net/caiqing1

SSM整合系列之 基於Shiro框架實現自動登入（RememberMe）

一、前言：Shiro框架提供了記住我（RememerMe）的功能，比如我們訪問一些網站，關閉了瀏覽器，下次再開啟還是能記住你是誰，下次訪問的時候無需登入即可訪問，本文將實現記住我的功能。 專案git地址：https://github.com/gitcaiqing/SSM_DEMO.git

SSM整合系列之 實現RESTFul API

摘要：REST，即Representational State Transfer的縮寫。直接翻譯的意思是"表現層狀態轉化"。它是一種網際網路應用程式的API設計理念：URL定位資源，用HTTP動詞（GET,POST,DELETE,PUT）描述操作。本文將介紹Restful風格API在SS

SSM整合系列之 通過Mybatis攔截器獲取SQL語句 實現SQL監控

摘要：Mybatis為我們提供了一個Interceptor介面，通過實現該介面就可以定義我們自己的攔截器，MyBatis攔截器介面提供的3個方法中，plugin方法用於某些處理器(Handler)的構建過程。interceptor方法用於處理代理類的執行。setProperties方法用

Spring Boot + Mybatis 多資料來源配置實現讀寫分離

本文來自網易雲社群作者：王超應用場景：專案中有一些報表統計與查詢功能，對資料實時性要求不高，因此考慮對報表的統計與查詢去操作slave db，減少對master的壓力。根據網上多份資料測試發現總是使用master資料來源，無法切換到slave，經過多次除錯修改現已完美通過，現

springboot mysql 多資料來源配置，可實現讀寫分離

1、程式碼實現 import com.zaxxer.hikari.HikariDataSource; import javas

MySQL多資料來源 二(基於spring+aop實現讀寫分離)

一，為什麼要進行讀寫分離呢？ 　　因為資料庫的“寫操作”操作是比較耗時的（寫上萬條條資料到Mysql的可能要1分鐘分鐘）。但是資料庫的“讀操作”卻比“寫操作”耗時要少的多（從Mysql的讀幾萬條資料條資料可能只要十秒鐘），而我們在開發過程中大多數也是查詢操作比較多。所以讀寫分離解決的是，資料庫的

SpringBoot進行MySql動態資料來源配置實現讀寫分離（連線池Druid）

1.簡介 前面使用C3P0連線池進行過資料庫的讀寫分離的實驗，今天換一下資料庫連線池改造一下，原理還是和原來的一樣。 Druid是阿里出品，淘寶和支付寶專用資料庫連線池，但它不僅僅是一個數據庫連線池，它還包含一個ProxyDriver，一系列內建的JDBC元

MySQL多資料來源 二(基於spring+aop實現讀寫分離)

一、為什麼要進行讀寫分離呢？ 因為資料庫的“寫操作”操作是比較耗時的（寫上萬條條資料到Mysql可能要1分鐘分鐘）。但是資料庫的“讀操作”卻比“寫操作”耗時要少的多（從Mysql讀幾萬條資料條資料可能只要十秒鐘）,而我們在開發過程中大多數也是查詢操作比較多。所以讀寫分離解決

Spring Boot2(四)：使用Spring Boot多資料來源實現讀寫分離

前言 實際業務場景中，不可能只有一個庫，所以就有了分庫分表，多資料來源的出現。實現了讀寫分離，主庫負責增改刪，從庫負責查詢。這篇文章將實現Spring Boot如何實現多資料來源，動態資料來源切換，讀寫分離等操作。 程式碼部署 快速新建專案spring-boot專案 1、新增maven依賴 <depen

Spring配置動態數據源-讀寫分離和多數據源

brush ride 常開 resolve ttr 表達 customer 事務管理 cda 　　在現在互聯網系統中，隨著用戶量的增長，單數據源通常無法滿足系統的負載要求。因此為了解決用戶量增長帶來的壓力，在數據庫層面會采用讀寫分離技術和數據庫拆分等技術。讀寫分離就是就是一

Mysql主從配置，實現讀寫分離

windows安裝 建議 xid 分布式 唯一標識 -1 在線下載 命令 進行 大型網站為了軟解大量的並發訪問，除了在網站實現分布式負載均衡，遠遠不夠。到了數據業務層、數據訪問層，如果還是傳統的數據結構，或者只是單單靠一臺服務器扛，如此多的數據庫連接操作，數據庫必然會崩潰，

使用Spring+MySql實現讀寫分離（二）spring整合多數據庫

ont 依據 xml配置 實現 整合 配置 item 匹配 mic 緊接著上一章，因為現在做的項目還是以spring為主要的容器管理框架，所以寫以下spring如何整合多個數據源。 1. 背景 我們一般應用對數據庫而言都是“讀多寫少”，也就說對數據庫讀取數據的壓力比較大

kylin跨集群配置實現讀寫分離

KYLIN HBASE HIVE 讀寫分離 跨集群 社區提供的讀寫分離架構圖如下：通過架構圖可以看到Kylin會訪問兩個集群的HDFS，建議兩個集群的NameService務必不能相同，尤其是集群啟用NameNode HA時，相同的NameService會導致組件在跨集群訪問HDFS時因無