一、为什么使用主从复制、读写分离?

1. 读和写的压力都由一台数据库承担,压力大
2. 数据库服务器磁盘损坏则数据丢失,单点故障
3. 为了提高数据库的并发性能,
4. 随着业务量的扩展、如果是单机部署的MySQL，会导致I/O频率过高。采用主从复制、读写分离可以提高数据库的可用性。

二、主从复制的原理

Mysql主从复制是一个异步的复制过程,底层是基于Myslq自带的二进制日志功能,就是一台或多台(从库)Mysql数据库从另一台数据库(主库)进行二进制日志的复制然后再解析应用于自身,最终实现从库的数据和主库数据一致。

在这里插入图片描述

1. 当Master节点进行insert、update、delete操作时，会按顺序写入到binlog中。
2. salve从库连接master主库，Master有多少个slave就会创建多少个binlog dump线程。
3. 当Master节点的binlog发生变化时，binlog dump 线程会通知所有的salve节点，并将相应的binlog内容推送给slave节点。
4. I/O线程接收到 binlog 内容后，将内容写入到本地的 relay-log(中继日志)。
5. SQL线程读取I/O线程写入的relay-log，并且根据 relay-log 的内容对从数据库做对应的操作。

三、 如何实现主从复制

从库可以有多台,这里使用一主一从模式

检查各自防火墙是否对数据库指定端口进行开放

3.1. Master配置

# 开启binlog【必须】
log-bin=mysql-bin
# 服务器唯一ID,唯一即可【必须】
server-id=101 
# 需要同步的数据库，如果不配置则同步全部数据库
binlog-do-db=test_demo
# binlog日志保留的天数，清除超过10天的日志
# 防止日志文件过大，导致磁盘空间不足
expire-logs-days=10 

systemctl restart mysqld

mysql -u root -p

GRANT REPLICATION SLAVE ON *.* to 'zhangsan'@'%' identified by 'Java@123456';

show master status;

3.2. Slave配置

# 不要和其他mysql服务id重复即可
server-id=102

systemctl restart mysqld

mysql -u root -p

CHANGE MASTER TO 
MASTER_HOST='192.168.100.101',//主机IP
MASTER_USER='zhangsan',//之前创建的用户账号
MASTER_PASSWORD='Java@123456',//之前创建的用户密码
MASTER_LOG_FILE='mysql-bin.000001',//master主机的binlog日志名称
MASTER_LOG_POS=367,//binlog日志偏移量
master_port=3306;//端口

start slave;

show slave status\G;

*************************** 1. row ***************************
               Slave_IO_State: Waiting for master to send event
                  Master_Host: 192.168.100.101
                  Master_User: zhangsan
                  Master_Port: 3306
                Connect_Retry: 60
              Master_Log_File: mysql-bin.000001
          Read_Master_Log_Pos: 247
               Relay_Log_File: mysqld-relay-bin.000001
                Relay_Log_Pos: 374
        Relay_Master_Log_File: mysql-bin.000001 //binlog日志文件名称
             Slave_IO_Running: Yes //Slave_IO线程、SQL线程都在运行
            Slave_SQL_Running: Yes

四、 使用ShardingJDBC配置读写分离

主从复制完成后，我们还需要实现读写分离，master负责写入数据，slave负责读取数据。

4.1. 添加sharding-jdbc的maven依赖：

<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
    <version>4.1.1-RC1</version>
</dependency>

4.2. 然后在application.yml添加配置

这是使用druid连接池的配置

spring:
  shardingsphere:
    datasource:
      names:
        master,slave1   # 配置了几个则写几个,和下面名字一致即可
      # 主数据源
      master:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://192.168.100.101:3306/test_demo?characterEncoding=utf-8
        username: root
        password: 123456
      # 从数据源
      slave1:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://192.168.100.102:3306/test_demo?characterEncoding=utf-8
        username: root
        password: 123456
 #       slave2:
  #        type: com.alibaba.druid.pool.DruidDataSource
  #        driver-class-name: com.mysql.jdbc.Driver
  #        url: jdbc:mysql://192.168.0.110:3306/test_demo?characterEncoding=utf-8
  #        username: root
  #        password: 123456
    masterslave:
      # 读写分离配置
      load-balance-algorithm-type: round_robin #轮询
      # 最终的数据源名称
      name: dataSource
      # 主库数据源名称
      master-data-source-name: master
      # 从库数据源名称列表，多个逗号分隔
      slave-data-source-names: slave1
    props:
      sql:
        show: true #开启SQL显示，默认false
  main:
    allow-bean-definition-overriding: true

load-balance-algorithm-type是路由策略，round_robin表示轮询策略。

4.3. 如果Bean定义冲突报错

可以添加如下添加配置

spring
  main:
    allow-bean-definition-overriding: true