Sharding-JDBC教程：Spring Boot整合Sharding-JDBC实现读写分离

小灰灰 2021-12-10 23:39 307阅读 0赞

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;

1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
在上一篇文章中，主从数据库已经搭建好了，所以执行完上面的脚本后，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>

1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
在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

1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
22  
23  
24  
25  
26  
27  
28  
29  
30  
31  
32  
33  
34  
35  
36  
37  
38  
39  
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);  
    \}  
\}

1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
11  
12  
13  
14  
15  
16  
17  
18  
19  
20  
21  
在上一篇文章中，已经开启了数据库的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'  
        )

1  
2  
3  
4  
5  
6  
7  
8  
9  
10  
从库对应主机的日志目录下查看查询数据的日志：

2019-06-20T02:41:28.450643Z     7367 Query    SELECT u.\* FROM user u  
1  
这就说明，Sharding-JDBC实现了数据库的读写分离。

源码下载  
https://github.com/forezp/SpringBootLearning/tree/master/sharding-jdbc-example/sharding-jdbc-master-slave

参考资料  
https://github.com/apache/incubator-shardingsphere-example/releases/tag/3.1.0.M1

https://shardingsphere.apache.org/document/current/cn/overview/

https://github.com/apache/incubator-shardingsphere

扫码关注有惊喜

（转载本站文章请注明作者和出处 方志朋的博客）  
\---------------------   
作者：方志朋   
来源：CSDN   
原文：https://blog.csdn.net/forezp/article/details/94174114   
版权声明：本文为博主原创文章，转载请附上博文链接！