Sharding-JDBC 几行配置实现读写分离~

Posted 2022-06-06 码猿技术专栏

大家好，我是不才陈某~

今天聊一下如何通过Sharding-JDBC简单的实现读写分离~

为什么要读写分离？

读写分离则是将事务性的增、改、删操作在主库执行，查询操作在从库执行。

一般业务的写操作都是比较耗时，为了避免写操作影响查询的效率，可以使用读写分离。

当然读写分离并不是万能的，还有前面的分库分表方案。

读写分离如何搭建？

mysql搭建读写分离非常简单，一般有一主一从、一主多从，对于MySQL的主从的相关概念这里就不再详细介绍了。

下面陈某就以MySQL5.7为例，使用docker搭建一个一主一从的架构，步骤如下：

1. pull镜像

使用如下命令从镜像仓库中下载镜像：

docker pull mysql:5.7.26

2. 创建目录

MySQL数据和配置文件挂载的目录：

mkdir -p /usr/local/mysqlData/master/cnf
mkdir -p /usr/local/mysqlData/master/data

mkdir -p /usr/local/mysqlData/slave/cnf
mkdir -p /usr/local/mysqlData/slave/data

3. 编写配置master节点配置

修改MySQL主节点的配置文件，内容如下：

vim /usr/local/mysqlData/master/cnf/mysql.cnf

[mysqld]
## 设置server_id,注意要唯一
server-id=1
## 开启binlog
log-bin=mysql-bin
## binlog缓存
binlog_cache_size=1M
## binlog格式(mixed、statement、row,默认格式是statement)
binlog_format=mixed

4. 编写配置slave节点配置

修改MySQL从节点的配置文件，内容如下：

vim /usr/local/mysqlData/slave/cnf/mysql.cnf

[mysqld]
## 设置server_id,注意要唯一
server-id=2
## 开启binlog,以备Slave作为其它Slave的Master时使用
log-bin=mysql-slave-bin
## relay_log配置中继日志
relay_log=edu-mysql-relay-bin
## 如果需要同步函数或者存储过程
log_bin_trust_function_creators=true
## binlog缓存
binlog_cache_size=1M
## binlog格式(mixed、statement、row,默认格式是statement)
binlog_format=mixed
## 跳过主从复制中遇到的所有错误或指定类型的错误,避免slave端复制中断
## 如:1062错误是指一些主键重复,1032错误是因为主从数据库数据不一致
slave_skip_errors=1062

5. 启动MySQL主节点

命令如下：

docker run -itd -p 3306:3306 --name master -v /usr/local/mysqlData/master/cnf:/etc/mysql/conf.d -v /usr/local/mysqlData/master/data:/var/lib/mysql -e MYSQL_ROOT_PASSWORD=123456 mysql:5.7.26

6. 添加复制master数据的用户reader，供从服务器使用

命令如下：

[root@aliyun /]# docker ps
CONTAINER ID        IMAGE               COMMAND                  CREATED             STATUS              PORTS                               NAMES
6af1df686fff        mysql:5.7           "docker-entrypoint..."   5 seconds ago       Up 4 seconds        0.0.0.0:3306->3306/tcp, 33060/tcp   master

[root@aliyun /]# docker exec -it master /bin/bash

root@41d795785db1:/# mysql -u root -p123456

mysql> GRANT REPLICATION SLAVE ON *.* to reader@% identified by reader;
Query OK, 0 rows affected, 1 warning (0.00 sec)

mysql> FLUSH PRIVILEGES;
Query OK, 0 rows affected (0.00 sec)

7. 创建并运行mysql从服务器

命令如下：

docker run -itd -p 3307:3306 --name slaver -v /usr/local/mysqlData/slave/cnf:/etc/mysql/conf.d -v /usr/local/mysqlData/slave/data:/var/lib/mysql -e MYSQL_ROOT_PASSWORD=123456 mysql:5.7.26

8. 在从服务器上配置连接主服务器的信息

首先主服务器上查看​​master_log_file​​​、​​master_log_pos​​两个参数，然后切换到从服务器上进行主服务器的连接信息的设置。

主服务上执行：

root@6af1df686fff:/# mysql -u root -p123456

mysql> show master status;
+------------------+----------+--------------+------------------+-------------------+
| File             | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+------------------+----------+--------------+------------------+-------------------+
| mysql-bin.000003 |      591 |              |                  |                   |
+------------------+----------+--------------+------------------+-------------------+
1 row in set (0.00 sec)

docker查看主服务器容器的ip地址：

[root@aliyun /]# docker inspect --format=.NetworkSettings.IPAddress master
172.17.0.2

从服务器上执行：

[root@aliyun /]# docker exec -it slaver /bin/bash
root@fe8b6fc2f1ca:/# mysql -u root -p123456

mysql> change master to master_host=172.17.0.2,master_user=reader,master_password=reader,master_log_file=mysql-bin.000003,master_log_pos=591;

9. 从服务器启动I/O 线程和SQL线程

mysql> start slave;
Query OK, 0 rows affected, 1 warning (0.00 sec)

mysql> show slave status\\G
*************************** 1. row ***************************
               Slave_IO_State: Waiting for master to send event
                  Master_Host: 172.17.0.2
                  Master_User: reader
                  Master_Port: 3306
                Connect_Retry: 60
              Master_Log_File: mysql-bin.000003
          Read_Master_Log_Pos: 591
               Relay_Log_File: edu-mysql-relay-bin.000002
                Relay_Log_Pos: 320
        Relay_Master_Log_File: mysql-bin.000003
             Slave_IO_Running: Yes
            Slave_SQL_Running: Yes

​​Slave_IO_Running: Yes，Slave_SQL_Running: Yes​​即表示启动成功。

Sharding-JDBC 实现读写分离

上面使用Docker搭建了一个MySQL的一主一从的架构，如下：

ip:port	节点	数据库
192.168.47.149:3306	主节点	product_db_1
192.168.47.149:3307	从节点	product_db_1

Sharding-JDBC对于读写分离的配置非常简单，分为如下几个步骤：

关于数据库中的表的SQL就不再贴了，文末有案例源码，自己下载！

1. 数据源配置

无论是分库分表还是读写分离，数据源的声明肯定是必须的，如下：

spring:
  # Sharding-JDBC的配置
  shardingsphere:
    datasource:
      # 数据源，这里配置两个，分别是ds1，ds2
      names: ds1,ds2
      # 主库
      ds1:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://192.168.47.149:3306/product_db1?useUnicode=true&characterEncoding=utf-8
        username: root
        password: 123456
      # 从库
      ds2:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.jdbc.Driver
        url: jdbc:mysql://192.168.47.149:3307/product_db1?useUnicode=true&characterEncoding=utf-8
        username: root
        password: 123456

源码已经上传GitHub，关注公众号：码猿技术专栏，回复关键词：9537 获取

2. 主从节点配置

第①步仅仅配置了数据源，并未指定哪个是主库，哪个是从库，Sharding-JDBC 默认是不知道哪个主库还是从库的，因此需要自己配置。

配置规则如下：

#主库数据源名称，名称随意
spring.shardingsphere.maste以上是关于Sharding-JDBC 几行配置实现读写分离~的主要内容，如果未能解决你的问题，请参考以下文章
 
 MySQL 数据库MySQL 主从复制和 Sharding-JDBC 实现读写分离
 MySQL 数据库MySQL 主从复制和 Sharding-JDBC 实现读写分离
 MySQL 数据库MySQL 主从复制和 Sharding-JDBC 实现读写分离
 sharding-JDBC 实现读写分离
 Sharding-Jdbc实现读写分离分库分表，妙！
 三Sharding-JDBC实现读写分离