分庫分表(3) ---SpringBoot + ShardingSphere 實現讀寫分離
分庫分表(3)---ShardingSphere實現讀寫分離
有關ShardingSphere概念前面寫了兩篇部落格:
1、分庫分表(1) --- 理論
2、 分庫分表(2) --- ShardingSphere(理論)
下面就這個專案做個整體簡單介紹,並在文章最下方附上專案Github地址
。
一、專案概述
1、技術架構
專案總體技術選型
SpringBoot2.0.6 + shardingsphere4.0.0-RC1 + Maven3.5.4 + MySQL + lombok(外掛)
2、專案說明
場景
如果實際專案中Mysql是 Master-Slave (主從)部署的,那麼資料儲存到Master庫,Master庫資料同步資料到Slave庫,資料讀取到Slave庫,
這樣可以減緩資料庫的壓力。
3、資料庫設計
我們這個專案中Mysql伺服器並沒有實現主從部署,而是同一個伺服器建立兩個庫,一個當做Master庫,一個當做Slave庫。所以這裡是不能實現的功能就是Master庫
新增資料主動同步到Slave庫。這樣也更有利於我們測試看效果。
Master庫
Slave庫
從兩幅圖中可以看出,我這裡在同一個伺服器建兩個資料庫來模擬主從資料庫。為了方便看測試效果,這裡主從資料庫中的資料是不一樣的
。
二、核心程式碼
說明
完整的程式碼會放到GitHub上,這裡只放一些核心程式碼。
1、pom.xml
<properties> <java.version>1.8</java.version> <mybatis-spring-boot>2.0.1</mybatis-spring-boot> <druid>1.1.16</druid> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>${mybatis-spring-boot}</version> </dependency> <!--mybatis驅動--> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <!--druid資料來源--> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>${druid}</version> </dependency> <!--shardingsphere最新版本--> <dependency> <groupId>org.apache.shardingsphere</groupId> <artifactId>sharding-jdbc-spring-boot-starter</artifactId> <version>4.0.0-RC1</version> </dependency> <!--lombok實體工具--> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> </dependencies>
2、application.properties
server.port=8088 #指定mybatis資訊 mybatis.config-location=classpath:mybatis-config.xml spring.shardingsphere.datasource.names=master,slave0 # 資料來源 主庫 spring.shardingsphere.datasource.master.type=com.alibaba.druid.pool.DruidDataSource spring.shardingsphere.datasource.master.driver-class-name=com.mysql.jdbc.Driver spring.shardingsphere.datasource.master.url=jdbc:mysql://localhost:3306/master?characterEncoding=utf-8 spring.shardingsphere.datasource.master.username=root spring.shardingsphere.datasource.master.password=123456 # 資料來源 從庫 spring.shardingsphere.datasource.slave0.type=com.alibaba.druid.pool.DruidDataSource spring.shardingsphere.datasource.slave0.driver-class-name=com.mysql.jdbc.Driver spring.shardingsphere.datasource.slave0.url=jdbc:mysql://localhost:3306/slave?characterEncoding=utf-8 spring.shardingsphere.datasource.slave0.username=root spring.shardingsphere.datasource.slave0.password=123456 # 讀寫分離 spring.shardingsphere.masterslave.load-balance-algorithm-type=round_robin spring.shardingsphere.masterslave.name=ms spring.shardingsphere.masterslave.master-data-source-name=master spring.shardingsphere.masterslave.slave-data-source-names=slave0 #列印sql spring.shardingsphere.props.sql.show=true
Sharding-JDBC可以通過Java
,YAML
,Spring名稱空間
和Spring Boot Starter
四種方式配置,開發者可根據場景選擇適合的配置方式。具體可以看官網。
3、UserController
@RestController
public class UserController {
@Autowired
private UserService userService;
/**
* @Description: 儲存使用者
*/
@PostMapping("save-user")
public Object saveUser() {
return userService.saveOne(new User("小小", "女", 3));
}
/**
* @Description: 獲取使用者列表
*/
@GetMapping("list-user")
public Object listUser() {
return userService.list();
}
}
三、測試驗證
1、讀資料
我們可以發現讀取的資料是Slave庫的資料。我們再來看控制檯列印的SQL。可以看到讀操作是Slave庫。
2、寫資料
請求
localhost:8088/save-user?name=小小&sex=女&age=3
檢視Mater資料庫
發現Master資料庫已經多了一條資料了,再看控制檯列印的SQL。
這個時候如果去看Slave庫的話這條新增的資料是沒有的,因為沒有同步過去。
Github地址
:https://github.com/yudiandemingzi/spring-boot-sharding-sphere
參考
1、ShardingSphere中文文件
2、ShardingSphere官網
3、Shardingsphere Github庫
我相信,無論今後的道路多麼坎坷,只要抓住今天,遲早會在奮鬥中嚐到人生的甘甜。抓住人生中的一分一秒,勝過虛度中的一月一年!(18)
<