Sharding-JDBC教程：Spring Boot整合Sharding-JDBC實現讀寫分離

Sharding-JDBC簡介

Sharding-JDBC是的分佈式數據庫中間件解決方案。Sharding-JDBC、Sharding-Proxy和Sharding-Sidecar（計劃中）是3款相互獨立的產品，共同 組成了ShardingSphere。Sharding-JDBC定位於輕量級的Java框架，它使用客戶端直連數據庫，可理解爲加強版的JDBC驅動，徹底兼容JDBC和各類ORM框架。

• 適用於任何基於Java的ORM框架，如：JPA, Hibernate, Mybatis, Spring JDBC Template或直接使用JDBC。
• 基於任何第三方的數據庫鏈接池，如：DBCP, C3P0, BoneCP, Druid, HikariCP等。
• 支持任意實現JDBC規範的數據庫。目前支持MySQL，Oracle，SQLServer和PostgreSQL。

架構圖以下：

支持如下的特效：

• 分庫分表
• 讀寫分離
• 柔性事務
• 分佈式主鍵
• 分佈式治理能力

工程準備

在上一篇文章中已經詳細的講解了如何構建Mysql5.7的讀寫分離，而且已經構建好了。詳細信息以下：

數據庫類型	數據庫	ip
主	cool	10.0.0.3
從	cool	10.0.0.13
從	cool	10.0.0.17

在主庫裏面執行如下的數據庫初始化腳本：

USE `cool`;

DROP TABLE IF EXISTS `user`;

CREATE TABLE `user` (
  `id` int(12) NOT NULL AUTO_INCREMENT,
  `username` varchar(12) NOT NULL,
  `password` varchar(30) NOT NULL,
  PRIMARY KEY (`id`),
  UNIQUE KEY `idx-username` (`username`)
) ENGINE=InnoDB AUTO_INCREMENT=12 DEFAULT CHARSET=utf8;

複製代碼

在上一篇文章中，主從數據庫已經搭建好了，因此執行完上面的腳本後，2個從庫應該也有user表。

案例講解

在本篇文章中使用Spring Boot 2.0.3+MyBatis+Druid+Sharding-JDBC+MySQL進行讀寫分離的案件講解。 關於Mybatis部分的代碼生成能夠參考https://github.com/forezp/mybatis-generator這裏，Mybatis部分的配置和代碼在這裏 就不詳細說明，詳情能夠查看源代碼。工程結構以下圖所示：

在工程的pom文件引入如下的依賴，包括Spring Boot的Web起步依賴spring-boot-starter-web，mybatis的起步依賴mybatis-spring-boot-starter， mysql的連機器，鏈接池druid的起步依賴druid-spring-boot-starter，sharding-jdbc的起步依賴sharding-jdbc-spring-boot-starter。代碼以下：

<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>1.3.2</version>
        </dependency>

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

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>

        <dependency>
            <groupId>io.shardingsphere</groupId>
            <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
            <version>3.1.0.M1</version>
        </dependency>

複製代碼

在spring boot工程配置文件application.yml作如下的配置：

sharding:
  jdbc:
    dataSource:
      names: db-test0,db-test1,db-test2
      # 配置主庫
      db-test0: #org.apache.tomcat.jdbc.pool.DataSource
        type: com.alibaba.druid.pool.DruidDataSource
        driverClassName: com.mysql.jdbc.Driver
        url: jdbc:mysql://10.0.0.3:3306/cool?useUnicode=true&characterEncoding=utf8&tinyInt1isBit=false&useSSL=false&serverTimezone=GMT
        username: root
        password:
        #最大鏈接數
        maxPoolSize: 20
      db-test1: # 配置第一個從庫
        type: com.alibaba.druid.pool.DruidDataSource
        driverClassName: com.mysql.jdbc.Driver
        url: jdbc:mysql://10.0.0.13:3306/cool?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&useSSL=false&serverTimezone=GMT
        username: root
        password:
        maxPoolSize: 20
      db-test2: # 配置第二個從庫
        type: com.alibaba.druid.pool.DruidDataSource
        driverClassName: com.mysql.jdbc.Driver
        url: jdbc:mysql://10.0.0.17:3306/cool?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&useSSL=false&serverTimezone=GMT
        username: root
        password:
        maxPoolSize: 20
    config:
      masterslave: # 配置讀寫分離
        load-balance-algorithm-type: round_robin # 配置從庫選擇策略，提供輪詢與隨機，這裏選擇用輪詢//random 隨機 //round_robin 輪詢
        name: db1s2
        master-data-source-name: db-test0
        slave-data-source-names: db-test1,db-test2
    props:
      sql: # 開啓SQL顯示，默認值: false，注意：僅配置讀寫分離時不會打印日誌！！！
        show: true

複製代碼

sharding.jdbc.dataSource.names配置的是數據庫的名稱，就是多個數據源的名稱。 sharding.jdbc.dataSource配置多個數據源。須要配置數據庫名稱，和上面配置的對應。以及數據的配置，包括鏈接池的類型、鏈接器、數據庫地址、 數據庫帳戶密碼信息等。 sharding.jdbc.config.masterslave.load-balance-algorithm-type查詢時的負載均衡算法，目前有2種算法，round_robin（輪詢）和random（隨機）。 sharding.jdbc.config.masterslave.master-data-source-name主數據源名稱。 sharding.jdbc.config.masterslave.slave-data-source-names從數據源名稱，多個用逗號隔開。

案例驗證

寫2個接口，代碼以下：

@RestController
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/users")
    public Object list() {
        return userService.list();
    }

    @GetMapping("/add")
    public Object add(@RequestParam Integer id,@RequestParam String username,@RequestParam String  password) {
        User user = new User();
        user.setId(id);
        user.setUsername(username);
        user.setPassword(password);
        return userService.addUser(user);
    }
}

複製代碼

在上一篇文章中，已經開啓了數據庫的CRUD日誌，日誌目錄在/var/lib/mysql目錄下。

調用2個接口，能夠在主庫對應主機的日誌目錄下查看插入數據的日誌：

2019-06-20T02:50:25.183174Z	 2030 Query	select @@session.transaction_read_only
2019-06-20T02:50:25.193506Z	 2030 Query	INSERT INTO user (
          id, username, password
        )
        VALUES (
        134,
        'forezp134',
        '1233edwd'
        )

複製代碼

從庫對應主機的日誌目錄下查看查詢數據的日誌：

2019-06-20T02:41:28.450643Z	 7367 Query	SELECT u.* FROM user u
複製代碼

這就說明，Sharding-JDBC實現了數據庫的讀寫分離。

源碼下載

github.com/forezp/Spri…

參考資料

github.com/apache/incu…

shardingsphere.apache.org/document/cu…

github.com/apache/incu…

掃碼關注有驚喜

（轉載本站文章請註明做者和出處 方誌朋的博客）