mysql的主从备份是实现读写分离的基础架构,通过配置主库和从库的数据同步,可将写请求分配到主库,读请求分配到从库,从而提升数据库的整体处理能力。这种架构尤其适合读多写少的业务场景,能有效缓解单库的性能压力。
主从备份核心原理
mysql主从备份依赖二进制日志(binlog)实现数据同步,整体流程分为三个步骤:
- 主库将所有写操作记录到binlog中
- 从库的IO线程连接主库,读取主库的binlog内容并写入到本地的中继日志(relay log)中
- 从库的SQL线程读取中继日志的内容,执行其中的SQL语句,完成数据同步
主从备份配置步骤
1. 主库配置
首先修改主库的mysql配置文件,通常路径为/etc/my.cnf或者/etc/mysql/my.cnf,添加以下配置:
[mysqld] # 启用二进制日志,日志文件名前缀为mysql-bin log-bin=mysql-bin # 主库唯一ID,集群内所有节点ID不能重复 server-id=1 # 可选:指定需要同步的数据库,不配置则同步所有数据库 binlog-do-db=test_db # 可选:指定不需要同步的数据库 binlog-ignore-db=mysql
配置完成后重启mysql服务,然后登录主库执行以下命令,创建用于从库同步的账号并授权:
-- 创建同步账号,用户名slave_user,密码slave_pass,允许从库IP访问 CREATE USER 'slave_user'@'从库IP' IDENTIFIED BY 'slave_pass'; -- 授予复制权限 GRANT REPLICATION SLAVE ON *.* TO 'slave_user'@'从库IP'; -- 刷新权限 FLUSH PRIVILEGES; -- 查看主库状态,记录File和Position的值,后续从库配置需要用到 SHOW MASTER STATUS;
2. 从库配置
修改从库的mysql配置文件,添加以下配置:
[mysqld] # 从库唯一ID,需要和主库以及其他从库区分 server-id=2 # 可选:指定需要复制的数据库 replicate-do-db=test_db # 可选:指定不需要复制的数据库 replicate-ignore-db=mysql # 开启只读模式,避免从库被误写入数据 read-only=1
重启从库服务后,登录从库执行以下命令配置主库连接信息:
-- 配置主库连接,替换对应的参数 CHANGE MASTER TO MASTER_HOST='主库IP', MASTER_USER='slave_user', MASTER_PASSWORD='slave_pass', MASTER_LOG_FILE='上一步记录的File值', MASTER_LOG_POS=上一步记录的Position值; -- 启动从库同步 START SLAVE; -- 查看从库同步状态 SHOW SLAVE STATUSG;
如果Slave_IO_Running和Slave_SQL_Running两个字段的值都为Yes,说明主从同步配置成功。
读写分离实现方式
主从备份配置完成后,就可以实现读写分离,常见的实现方式有两种:
1. 应用层代码实现
在业务代码中根据SQL类型选择对应的数据源,写操作使用主库连接,读操作使用从库连接。以下是Java Spring Boot框架中的简单示例:
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
@Service
public class UserService {
// 主库JdbcTemplate
@Autowired
private JdbcTemplate masterJdbcTemplate;
// 从库JdbcTemplate
@Autowired
private JdbcTemplate slaveJdbcTemplate;
// 写操作:插入用户数据,使用主库
public void addUser(String name, int age) {
String sql = "INSERT INTO user (name, age) VALUES (?, ?)";
masterJdbcTemplate.update(sql, name, age);
}
// 读操作:查询用户数据,使用从库
public List<Map<String, Object>> getUsers() {
String sql = "SELECT * FROM user";
return slaveJdbcTemplate.queryForList(sql);
}
}
2. 中间件代理实现
使用数据库中间件如MyCat、ShardingSphere-Proxy等,中间件会自动解析SQL语句,将写请求转发到主库,读请求转发到从库,应用层只需要连接中间件即可,不需要关心数据源的切换逻辑。以下是ShardingSphere的简单配置示例:
# ShardingSphere配置
spring:
shardingsphere:
datasource:
names: master, slave
master:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://主库IP:3306/test_db?useUnicode=true&characterEncoding=utf8
username: root
password: 主库密码
slave:
type: com.zaxxer.hikari.HikariDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
jdbc-url: jdbc:mysql://从库IP:3306/test_db?useUnicode=true&characterEncoding=utf8
username: root
password: 从库密码
rules:
readwrite-splitting:
data-sources:
readwrite_ds:
type: Static
props:
write-data-source-name: master
read-data-source-names: slave
load-balancer-name: round_robin
load-balancers:
round_robin:
type: ROUND_ROBIN
注意事项
- 主从同步存在延迟,对于实时性要求高的读操作,建议还是走主库,避免出现数据不一致问题
- 从库的
read-only配置只对普通用户生效,超级管理员账号仍然可以写入数据,需要做好权限管控 - 如果主库宕机,需要手动或者配合高可用工具将从库提升为主库,保证服务可用性
- 定期检查主从同步状态,避免同步中断影响业务