Spring Boot中整合Sharding-JDBC實現讀寫分離

摘要： 國慶期間研究了資料庫中介軟體例如Mycat和Sharding JDBC，Sharding-jdbc和Mycat使用不同的理念，Sharding-jdbc目前是基於Jdbc驅動，無需額外的proxy，因此也無需關注proxy本身的高可用。Mycat 是基於 Proxy，它複寫了 MySQL 協議...

國慶期間研究了資料庫中介軟體例如Mycat和Sharding JDBC，Sharding-jdbc和Mycat使用不同的理念，Sharding-jdbc目前是基於Jdbc驅動，無需額外的proxy，因此也無需關注proxy本身的高可用。Mycat 是基於 Proxy，它複寫了 SQL/">MySQL 協議，將 Mycat Server 偽裝成一個 MySQL 資料庫，而 Sharding-JDBC 是基於 JDBC 介面的擴充套件，是以jar包的形式提供輕量級服務的。

先介紹一下整合過程中用到的主要軟體的版本：

Spring Boot: 1.5.8.RELEASE
Sharding-JDBC: 2.0.3

注意：實現讀寫分離我們自己要先配置好MySQL的主從複製，我自己已經配置好了一主兩從。配置的步驟可以參考【實現MySQL主從複製】

pom.xml 依賴

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>

<dependency>
<groupId>io.shardingjdbc</groupId>
<artifactId>sharding-jdbc-core-spring-boot-starter</artifactId>
<version>2.0.3</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.2</version>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.2</version>
</dependency>
</dependencies>

application配置檔案

server.port=8080

sharding.jdbc.datasource.names=ds_master,ds_slave_1,ds_slave_2

# 主資料來源
sharding.jdbc.datasource.ds_master.type=com.alibaba.druid.pool.DruidDataSource
sharding.jdbc.datasource.ds_master.driver-class-name=com.mysql.jdbc.Driver
sharding.jdbc.datasource.ds_master.url=jdbc:mysql://localhost:3306/db1?characterEncoding=utf-8
sharding.jdbc.datasource.ds_master.username=root
sharding.jdbc.datasource.ds_master.password=123456
sharding.jdbc.datasource.ds_master.maxPoolSize=20

# 從資料來源 ds_slave_1
sharding.jdbc.datasource.ds_slave_1.type=com.alibaba.druid.pool.DruidDataSource
sharding.jdbc.datasource.ds_slave_1.driver-class-name=com.mysql.jdbc.Driver
sharding.jdbc.datasource.ds_slave_1.url=jdbc:mysql://localhost:3307/db1?characterEncoding=utf-8
sharding.jdbc.datasource.ds_slave_1.username=root
sharding.jdbc.datasource.ds_slave_1.password=123456
sharding.jdbc.datasource.ds_slave_1.maxPoolSize=20

# 從資料來源 ds_slave_2
sharding.jdbc.datasource.ds_slave_2.type=com.alibaba.druid.pool.DruidDataSource
sharding.jdbc.datasource.ds_slave_2.driver-class-name=com.mysql.jdbc.Driver
sharding.jdbc.datasource.ds_slave_2.url=jdbc:mysql://localhost:3308/db1?characterEncoding=utf-8
sharding.jdbc.datasource.ds_slave_2.username=root
sharding.jdbc.datasource.ds_slave_2.password=123456
sharding.jdbc.datasource.ds_slave_2.maxPoolSize=20

# 讀寫分離配置
sharding.jdbc.config.masterslave.load-balance-algorithm-type=round_robin
sharding.jdbc.config.masterslave.name=dataSource
sharding.jdbc.config.masterslave.master-data-source-name=ds_master
sharding.jdbc.config.masterslave.slave-data-source-names=ds_slave_1,ds_slave_2


mybatis.config-location=classpath:mybatis-config.xml
mybatis.mapper-locations=classpath:mapper/*.xml
mybatis.typeAliasesPackage=net.ydstuio.shardingjdbc.repository

到此，Sharing-Jdbc的讀寫分離就已經就配置好了，看看是不是很簡單。如果對資料的及時性要求很高，可以使用下面的程式碼，使得讀取也落到主庫上。

// 強制路由主庫
HintManager.getInstance().setMasterRouteOnly();

最後更新於2018-10-0616:02:59 並被新增「java sharding-jdbc」標籤，已有 1 位童鞋閱讀過。