真香！基于ShardingSphere-JDBC的MySQL讀寫分離

前言

為了減輕每臺MySQL主機的訪問壓力，還可以對MySQL進行讀寫分離，實際上，主從復制和讀寫分離一般就是聯合使用的，

找到一份好的資料也是學習程序中，非常重要的一個點，你的檢索能力越強，你就會越容易找到最合適你的資料，

我這邊也整理了一些最新的面試題資料和Java架構學習資料，學習技術內容包含有：Spring，Dubbo，MyBatis, RPC,原始碼分析，高并發、高性能、分布式,性能優化，微服務 高級架構開發等等，，

有需要的小伙伴可以戳這里免費領取，暗號：CSDN，

這篇水文來聊一下MySQL的讀寫分離，借助于一些資料庫中間件，實作起來賊容易，一看就會！

MySQL讀寫分離

MySQL讀寫分離基本原理是讓master資料庫處理寫操作，slave資料庫處理讀操作，master將寫操作的變更同步到各個slave節點，

MySQL讀寫分離能提高系統性能：

• 物理服務器增加，機器處理能力提升，拿硬體換性能，
• slave可以配置myiasm引擎，提升查詢性能以及節約系統開銷，
• master直接寫是并發的，slave通過主庫發送來的binlog恢復資料是異步的，
• slave可以單獨設定一些引數來提升其讀的性能，
• 增加冗余，提高可用性，

如何實作讀寫分離

MySQL官方提供了MySQL Proxy，但是已經不建議使用了：

與此同時它建議我們使用MySQL Router，再但是，MySQL Router不僅功能少，而且需要在應用程式代碼中指定讀/寫的不同埠，在實際生產環境中應該沒人會這樣用，
其實，當前已經有不少比較不錯的MySQL中間件，像shardingsphere-jdbc，mycat，amoeba等，這些都是比較不錯的選擇，
這里，我們使用Apache開源專案ShardingSphere的JDBC來實作MySQL的讀寫分離，#

ShardingSphere-JDBC

ShardingSphere的JDBC組件，稱之為Sharding-JDBC，它是一個輕量級的Java框架，在Java的JDBC層提供的額外服務， 它使用客戶端直連資料庫，以jar包形式提供服務，無需額外部署和依賴，可理解為增強版的JDBC驅動，完全兼容JDBC和各種ORM框架，

這就意味著，在專案中我們不需要額外安裝什么軟體，直接引入Jar包依賴，就可以實作資料庫的分庫分表、讀寫分離等，

說的直白一點，Sharding-JDBC就是包含了分庫分表讀寫分離功能的JDBC，因此我們可以直接把Sharding-JDBC當做普通的JDBC來使用，

Sharding-JDBC實作讀寫分離的核心概念

主庫

• 添加、更新以及洗掉資料操作所使用的資料庫，目前僅支持單主庫，

從庫

• 查詢資料操作所使用的資料庫，可支持多從庫，
• 我們使用一主兩從的MySQL資料庫架構來實作主從復制和讀寫分離，

主從同步

• 將主庫的資料異步的同步到從庫的操作，由于主從同步的異步性，從庫與主庫的資料會短時間內不一致，

負載均衡策略

• 如果有多個從庫，可以通過負載均衡策略將查詢請求疏導至不同的從庫，

基于Sharding-JDBC的MySQL讀寫分離代碼實作

1. 主從復制主機配置：
   主從同步的資料庫為shardingsphere_demo：

log-bin=master-bin
binlog-format=ROW
server-id=1
binlog-do-db=shardingsphere_demo

shardingsphere_demo庫有一個表叫laogong：

create table laogong( id int, 
name varchar(20),
 age int
 );

2. 創建SpringBoot專案，引入Jar包

引入ShardingSphere的Jar包依賴：

<dependency>    
     <groupId>org.apache.shardingsphere</groupId>         
     <artifactId>sharding-jdbc-spring-boot-starter</artifactId>    
     <version>4.1.1</version>
</dependency>

還用到了druid連接池，mybatis，mysql驅動，這里不展示了，

3. 組態檔

配置是整個Sharding-JDBC的核心，是Sharding-JDBC中唯一與應用開發者打交道的模塊，

配置模塊也是Sharding-JDBC的門戶，通過它可以快速清晰的理解Sharding-JDBC所提供的功能，

配置讀寫分離

根據前文主從復制主機的資訊，配置如下：

spring:  
  shardingsphere:    
   # 資料源相關配置    
  datasource:      
   # 資料源名稱      
   names: master,s1,s2      
   # MySQL master資料源      
   master:        
 # 資料庫連接池        
   type: com.alibaba.druid.pool.DruidDataSource        
   driver-class-name: com.mysql.jdbc.Driver        
   url: jdbc:mysql://192.168.2.158:3306/shardingsphere_demo? serverTimezone=UTC        
   username: root        
   password: 123456      
 # 兩個slave資料源      
 s1:        
   type: com.alibaba.druid.pool.DruidDataSource        
   driver-class-name: com.mysql.jdbc.Driver        
   url: jdbc:mysql://192.168.2.159:3306/shardingsphere_demo?serverTimezone=UTC        
   username: root        
   password: 123456      
 s2:        
   type: com.alibaba.druid.pool.DruidDataSource        
   driver-class-name: com.mysql.jdbc.Driver        
   url: jdbc:mysql://192.168.2.157:3306/shardingsphere_demo? serverTimezone=UTC        
   username: root        
   password: 123456    
   masterslave:      
   load-balance-algorithm-type: round_robin      
   name: ms      
   master-data-source-name: master      
  slave-data-source-names: s1,s2    
# 其他屬性    
 props:      
   # 開啟SQL顯示      
    sql.show: true

4. 創建物體類和Mapper類

物體類的代碼這里不貼了，侮辱智商

Mapper類：

@Repository
@Mapper
public interface LaogongMapper {    
	@Insert("insert into laogong(id, name, age) values(#{id}, #{name}, #{age})")    public void addLaogong(Laogong laogong);    
	@Select("select * from laogong where id=#{id}")    
	public Laogong queryLaogong(Integer id);
}

5. 測驗
   測驗寫入資料

向laogong表插入5條資料：

@Test
public void testMSInsert(){    
	for (int i = 1; i <= 5; i++) {        
		Laogong laogong = new Laogong();        
		laogong.setId(i);        
		laogong.setName("xblzer" + i);        
		laogong.setAge(new Random().nextInt(30));
		laogongMapper.addLaogong(laogong);    
	}
}

運行結果：

可以看到，插入的SQL陳述句，全部往master主庫寫入資料，

6. 測驗讀取資料

讀取id=1的資料，回圈讀取10次，看都從哪個庫讀取：

@Test
public void testMSQuery(){    
	for (int i = 0; i < 10; i++) {        
		Laogong laogong = laogongMapper.queryLaogong(1);        		
		System.out.println(laogong);    
	}
}

結果驗證：

只從S1、S2這兩個從庫中讀取資料，

通過以上兩個讀取和寫入資料的測驗，可以可到，通過Sharding-JDBC真的很方便就幫我們實作了讀寫分離！這個時候我們可以說真香了！

最后

基于Sharding-JDBC的MySQL讀寫分離用起來真是很方便，而且ShardingSphere 已于2020年4月16日成為 Apache 軟體基金會的頂級專案了，相信ShardingSphere會很快的火起來的，

我們專案上已經用這個做MySQL分庫分表讀寫分離了，這次這篇文章只提到了讀寫分離，其實Sharding-JDBC還可以實作很多功能：

• 資料分片（分庫&分表）
• 讀寫分離
• 分布式事務
• 分布式治理
• 資料加密
• …

ShardingSphere已經形成了一個生態圈，其功能仍在不斷完善，

本次導航結束，以上，