首頁 資料庫 mysql教程 關於spring整合mybatis如何實現mysql資料庫讀寫分離的實例分析

關於spring整合mybatis如何實現mysql資料庫讀寫分離的實例分析

Aug 09, 2017 pm 02:17 PM
mybatis spring 如何

本文透過實例程式碼介紹了spring整合mybatis實作mysql資料庫讀寫分離,需要的朋友可以參考下

##前言

       在網站的使用者達到某一規模後,資料庫因為負載壓力過高而成為網站的瓶頸。幸運的是目前大部分的主流資料庫都提供主從熱備功能,透過配置兩台資料庫主從關係,可以將一台資料庫的資料更新同步到另一台伺服器上。網站利用資料庫的這項功能,實現資料庫讀寫分離,進而改善資料庫負載壓力。如下圖所示:

  應用程式伺服器在寫資料的時候,存取主資料庫,主資料庫透過主從複製機制將資料更新同步到從資料庫,這樣當應用伺服器讀資料的時候,就可以透過從資料庫取得資料。為了方便應用程式存取讀寫分離後的資料庫,通常在應用程式伺服器使用專門的資料庫存取模組,使資料庫讀寫分離對應用透明。

       而本部落格就是來實現“專門的資料庫存取模組”,使資料庫讀取和寫入分離對應用透明。另外,mysql資料庫的主從複製可以參考我的mysql5.7.18的安裝與主從複製。注意,資料庫實作了主從複製,才能做資料庫的讀寫分離,所以,沒有實作資料庫主從複製的記得先去實作資料庫的主從複製##設定讀寫資料來源(主從資料庫)

       mysqldb.properties


#主数据库数据源
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://192.168.0.4:3306/mybatis?useUnicode=true&characterEncoding=utf-8&useSSL=false
jdbc.username=root
jdbc.password=123456
jdbc.initialSize=1
jdbc.minIdle=1
jdbc.maxActive=20
jdbc.maxWait=60000
jdbc.removeAbandoned=true
jdbc.removeAbandonedTimeout=180
jdbc.timeBetweenEvictionRunsMillis=60000
jdbc.minEvictableIdleTimeMillis=300000
jdbc.validationQuery=SELECT 1
jdbc.testWhileIdle=true
jdbc.testOnBorrow=false
jdbc.testOnReturn=false
#从数据库数据源
slave.jdbc.driverClassName=com.mysql.jdbc.Driver
slave.jdbc.url=jdbc:mysql://192.168.0.221:3306/mybatis?useUnicode=true&characterEncoding=utf-8&useSSL=false
slave.jdbc.username=root
slave.jdbc.password=123456
slave.jdbc.initialSize=1
slave.jdbc.minIdle=1
slave.jdbc.maxActive=20
slave.jdbc.maxWait=60000
slave.jdbc.removeAbandoned=true
slave.jdbc.removeAbandonedTimeout=180
slave.jdbc.timeBetweenEvictionRunsMillis=60000
slave.jdbc.minEvictableIdleTimeMillis=300000
slave.jdbc.validationQuery=SELECT 1
slave.jdbc.testWhileIdle=true
slave.jdbc.testOnBorrow=false
slave.jdbc.testOnReturn=false
登入後複製

    主、從資料庫的位址記得改成自己的,帳號和密碼也需要改成自己的;其他設定項,大家可以酌情自行設定

       mybatis-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"
  xsi:schemaLocation="http://www.springframework.org/schema/beans 
   http://www.springframework.org/schema/beans/spring-beans.xsd
   http://www.springframework.org/schema/context
   http://www.springframework.org/schema/context/spring-context.xsd
   http://www.springframework.org/schema/aop
   http://www.springframework.org/schema/aop/spring-aop.xsd
   http://www.springframework.org/schema/tx 
   http://www.springframework.org/schema/tx/spring-tx.xsd">
  <!-- master数据源 -->
  <bean id="masterDataSource" class="com.alibaba.druid.pool.DruidDataSource">
    <!-- 基本属性 url、user、password --> 
    <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="minIdle" value="${jdbc.minIdle}" />  
    <property name="maxActive" value="${jdbc.maxActive}" /> 
    <property name="maxWait" value="${jdbc.maxWait}" />
    <!-- 超过时间限制是否回收 -->
    <property name="removeAbandoned" value="${jdbc.removeAbandoned}" />
    <!-- 超过时间限制多长; -->
    <property name="removeAbandonedTimeout" value="${jdbc.removeAbandonedTimeout}" />
    <!-- 配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 -->
    <property name="timeBetweenEvictionRunsMillis" value="${jdbc.timeBetweenEvictionRunsMillis}" />
    <!-- 配置一个连接在池中最小生存的时间,单位是毫秒 -->
    <property name="minEvictableIdleTimeMillis" value="${jdbc.minEvictableIdleTimeMillis}" />
    <!-- 用来检测连接是否有效的sql,要求是一个查询语句-->
    <property name="validationQuery" value="${jdbc.validationQuery}" />
    <!-- 申请连接的时候检测 -->
    <property name="testWhileIdle" value="${jdbc.testWhileIdle}" />
    <!-- 申请连接时执行validationQuery检测连接是否有效,配置为true会降低性能 -->
    <property name="testOnBorrow" value="${jdbc.testOnBorrow}" />
    <!-- 归还连接时执行validationQuery检测连接是否有效,配置为true会降低性能 -->
    <property name="testOnReturn" value="${jdbc.testOnReturn}" />
  </bean>
  <!-- slave数据源 -->
  <bean id="slaveDataSource" class="com.alibaba.druid.pool.DruidDataSource">
    <property name="driverClassName" value="${slave.jdbc.driverClassName}" /> 
    <property name="url" value="${slave.jdbc.url}" /> 
    <property name="username" value="${slave.jdbc.username}" /> 
    <property name="password" value="${slave.jdbc.password}" /> 
    <property name="initialSize" value="${slave.jdbc.initialSize}" /> 
    <property name="minIdle" value="${slave.jdbc.minIdle}" />  
    <property name="maxActive" value="${slave.jdbc.maxActive}" /> 
    <property name="maxWait" value="${slave.jdbc.maxWait}" />
    <property name="removeAbandoned" value="${slave.jdbc.removeAbandoned}" />
    <property name="removeAbandonedTimeout" value="${slave.jdbc.removeAbandonedTimeout}" />
    <property name="timeBetweenEvictionRunsMillis" value="${slave.jdbc.timeBetweenEvictionRunsMillis}" />
    <property name="minEvictableIdleTimeMillis" value="${slave.jdbc.minEvictableIdleTimeMillis}" />
    <property name="validationQuery" value="${slave.jdbc.validationQuery}" />
    <property name="testWhileIdle" value="${slave.jdbc.testWhileIdle}" />
    <property name="testOnBorrow" value="${slave.jdbc.testOnBorrow}" />
    <property name="testOnReturn" value="${slave.jdbc.testOnReturn}" />
  </bean>
  <!-- 动态数据源,根据service接口上的注解来决定取哪个数据源 -->
  <bean id="dataSource" class="com.yzb.util.DynamicDataSource"> 
    <property name="targetDataSources">   
     <map key-type="java.lang.String">   
       <!-- write or slave -->  
       <entry key="slave" value-ref="slaveDataSource"/>   
       <!-- read or master  --> 
       <entry key="master" value-ref="masterDataSource"/>   
     </map>        
    </property>  
    <property name="defaultTargetDataSource" ref="masterDataSource"/>   
  </bean>
  <!-- Mybatis文件 -->
  <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="configLocation" value="classpath:mybatis-config.xml" /> 
    <property name="dataSource" ref="dataSource" />
    <!-- 映射文件路径 -->
    <property name="mapperLocations" value="classpath*:dbmappers/*.xml" />
  </bean>
  <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="com.yzb.dao" />
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
  </bean>
  <!-- 事务管理器 -->
  <bean id="transactionManager"
    class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <property name="dataSource" ref="dataSource" />
  </bean>
  <!-- 声明式开启 -->
  <tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true" order="1"/>
  <!-- 为业务逻辑层的方法解析@DataSource注解 为当前线程的HandleDataSource注入数据源 -->  
  <bean id="dataSourceAspect" class="com.yzb.util.DataSourceAspect" />  
  <aop:config proxy-target-class="true">  
    <aop:aspect id="dataSourceAspect" ref="dataSourceAspect" order="2">  
      <aop:pointcut id="tx" expression="execution(* com.yzb.service.impl..*.*(..)) "/>  
      <aop:before pointcut-ref="tx" method="before" />        
    </aop:aspect>  
  </aop:config>
</beans>
登入後複製

AOP實作資料來源的動態切換

DataSource.java


#

package com.yzb.util;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.annotation.Target;
/** 
 * RUNTIME 
 * 编译器将把注释记录在类文件中,在运行时 VM 将保留注释,因此可以反射性地读取。 
 * 
 */ 
@Retention(RetentionPolicy.RUNTIME) 
@Target(ElementType.METHOD) 
public @interface DataSource
{
  String value();
}
登入後複製

DataSourceAspect.java


package com.yzb.util;
import java.lang.reflect.Method;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.reflect.MethodSignature;
public class DataSourceAspect
{
  /**
   * 在dao层方法获取datasource对象之前,在切面中指定当前线程数据源
   */
  public void before(JoinPoint point)
  {
    Object target = point.getTarget();
    String method = point.getSignature().getName();
    Class<?>[] classz = target.getClass().getInterfaces();            // 获取目标类的接口, 所以@DataSource需要写在接口上
    Class<?>[] parameterTypes = ((MethodSignature) point.getSignature())
        .getMethod().getParameterTypes();
    try
    {
      Method m = classz[0].getMethod(method, parameterTypes);
      if (m != null && m.isAnnotationPresent(DataSource.class))
      {
        DataSource data = m.getAnnotation(DataSource.class);
        System.out.println("用户选择数据库库类型:" + data.value());
        HandleDataSource.putDataSource(data.value());            // 数据源放到当前线程中
      }
    } catch (Exception e)
    {
      e.printStackTrace();
    }
  }
  }
登入後複製

DynamicDataSource.java


package com.yzb.util;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
public class DynamicDataSource extends AbstractRoutingDataSource
{
  /**
   * 获取与数据源相关的key 此key是Map<String,DataSource> resolvedDataSources 中与数据源绑定的key值
   * 在通过determineTargetDataSource获取目标数据源时使用
   */
  @Override
  protected Object determineCurrentLookupKey()
  {
    return HandleDataSource.getDataSource();
  }
}
登入後複製

HandleDataSource.java


package com.yzb.util;
public class HandleDataSource
{
  public static final ThreadLocal<String> holder = new ThreadLocal<String>();
  /**
   * 绑定当前线程数据源
   * 
   * @param key
   */
  public static void putDataSource(String datasource)
  {
    holder.set(datasource);
  }
  /**
   * 获取当前线程的数据源
   * 
   * @return
   */
  public static String getDataSource()
  {
    return holder.get();
  }
}
登入後複製

service介面上套用@DataSource實作資料來源的指定


package com.yzb.service;
import java.util.List;
import com.yzb.model.Person;
import com.yzb.util.DataSource;
public interface IPersonService {
  /**
   * 加载全部的person
   * @return
   */
  List<Person> listAllPerson();
  /**
   * 查询某个人的信息
   * @param personId
   * @return
   */
  @DataSource("slave")      // 指定使用从数据源
  Person getPerson(int personId);
  boolean updatePerson(Person person);
}
登入後複製
注意點

  測試的時候,怎麼樣知道讀取的是從資料庫了? 我們可以修改從資料庫中查詢到的那筆記錄的某個欄位的值,以區分主、從資料庫;

       事務需要注意,盡量確保在一個資料來源上進行事務;

       當某個service上有多個aop時,需要注意aop織入的順序問題,利用order關鍵字控制好織入順序;

總結

###

以上是關於spring整合mybatis如何實現mysql資料庫讀寫分離的實例分析的詳細內容。更多資訊請關注PHP中文網其他相關文章!

本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章

<🎜>:泡泡膠模擬器無窮大 - 如何獲取和使用皇家鑰匙
3 週前 By 尊渡假赌尊渡假赌尊渡假赌
北端:融合系統,解釋
3 週前 By 尊渡假赌尊渡假赌尊渡假赌
Mandragora:巫婆樹的耳語 - 如何解鎖抓鉤
3 週前 By 尊渡假赌尊渡假赌尊渡假赌

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Java教學
1664
14
CakePHP 教程
1423
52
Laravel 教程
1321
25
PHP教程
1269
29
C# 教程
1249
24
利用Spring Boot以及Spring AI建構生成式人工智慧應用 利用Spring Boot以及Spring AI建構生成式人工智慧應用 Apr 28, 2024 am 11:46 AM

Spring+AI作為行業領導者,透過其強大、靈活的API和先進的功能,為各種行業提供了領先性的解決方案。在本專題中,我們將深入探討Spring+AI在各領域的應用範例,每個案例都將展示Spring+AI如何滿足特定需求,實現目標,並將這些LESSONSLEARNED擴展到更廣泛的應用。希望這個專題能對你有所啟發,更深入地理解和利用Spring+AI的無限可能。 Spring框架在軟體開發領域已經有超過20年的歷史,自SpringBoot1.0版本發布以來已有10年。現在,無人會質疑,Spring

詳解MyBatis動態SQL標籤中的Set標籤功能 詳解MyBatis動態SQL標籤中的Set標籤功能 Feb 26, 2024 pm 07:48 PM

MyBatis動態SQL標籤解讀:Set標籤用法詳解MyBatis是一個優秀的持久層框架,它提供了豐富的動態SQL標籤,可以靈活地建構資料庫操作語句。其中,Set標籤是用來產生UPDATE語句中SET子句的標籤,在更新作業中非常常用。本文將詳細解讀MyBatis中Set標籤的用法,以及透過具體的程式碼範例來示範其功能。什麼是Set標籤Set標籤用於MyBati

MyBatis快取機制詳解:一文讀懂快取儲存原理 MyBatis快取機制詳解:一文讀懂快取儲存原理 Feb 23, 2024 pm 04:09 PM

MyBatis快取機制詳解:一文讀懂快取儲存原理引言在使用MyBatis進行資料庫存取時,快取是一個非常重要的機制,能夠有效減少對資料庫的訪問,提高系統效能。本文將詳細介紹MyBatis的快取機制,包括快取的分類、儲存原理和具體的程式碼範例。一、快取的分類MyBatis的快取主要分為一級快取和二級快取兩種。一級緩存一級緩存是SqlSession級別的緩存,當在

MyBatis Generator配置參數解讀及最佳實踐 MyBatis Generator配置參數解讀及最佳實踐 Feb 23, 2024 am 09:51 AM

MyBatisGenerator是MyBatis官方提供的程式碼產生工具,可以幫助開發人員快速產生符合資料庫表結構的JavaBean、Mapper介面以及XML映射檔。在使用MyBatisGenerator進行程式碼產生的過程中,配置參數的設定是至關重要的。本文將從配置參數的角度出發,深入探討MyBatisGenerator的

深入理解MyBatis中的批次Insert實作原理 深入理解MyBatis中的批次Insert實作原理 Feb 21, 2024 pm 04:42 PM

MyBatis是一款流行的Java持久層框架,廣泛應用於各種Java專案。其中,批次插入是常見的操作,可以有效提升資料庫操作的效能。本文將深入探討MyBatis中批量的Insert實作原理,並結合具體的程式碼範例進行詳細解析。 MyBatis中的批次Insert在MyBatis中,批量Insert操作通常使用動態SQL來實作。透過建構一條包含多個插入值的S

MyBatis 一級快取詳解:如何提升資料存取效率? MyBatis 一級快取詳解:如何提升資料存取效率? Feb 23, 2024 pm 08:13 PM

MyBatis一級快取詳解:如何提升資料存取效率?在開發過程中,高效率的資料存取一直是程式設計師關注的焦點之一。而對於MyBatis這樣的持久層框架而言,快取是提升資料存取效率的關鍵方法之一。 MyBatis提供了一級快取和二級快取兩種快取機制,其中一級快取是預設開啟的。本文將詳細介紹MyBatis一級快取的機制,並提供具體的程式碼範例,幫助讀者更好地理

安全優先:MyBatis 中防範 SQL 注入的最佳實踐 安全優先:MyBatis 中防範 SQL 注入的最佳實踐 Feb 22, 2024 pm 12:51 PM

隨著網路技術的不斷發展,資料庫攻擊也變得越來越普遍。 SQL注入是其中常見的攻擊方式,攻擊者透過在輸入框中輸入惡意SQL語句來執行非法操作,造成資料外洩、竄改甚至刪除。為了防範SQL注入攻擊,開發人員在編寫程式碼時要特別注意,而在使用MyBatis這樣的ORM框架時,更是需要遵循一些最佳實踐來確保系統的安全性。 1.參數化查詢參數化查詢是防

MyBatis中批量Insert語句的最佳化技巧分享 MyBatis中批量Insert語句的最佳化技巧分享 Feb 22, 2024 pm 04:51 PM

MyBatis是一個流行的Java持久層框架,透過XML或註解的方式實現SQL與Java方法的映射,提供了許多方便的操作資料庫的功能。在實際開發中,有時需要批量插入大量資料到資料庫中,因此,如何優化MyBatis中批量Insert語句成為一個重要的問題。本文將分享一些優化技巧,並提供具體的程式碼範例。 1.使用BatchExecu

See all articles