面试题：如何在 MySQL 中实现读写分离？

在 MySQL 中实现读写分离通常是为了提升数据库的性能和可用性。读写分离的核心思想是将读操作和写操作分配到不同的数据库服务器上，写操作集中在主库（Master），读操作分散到从库（Slave）。以下是实现读写分离的常见步骤：

1. 配置主从复制（Master-Slave Replication）

读写分离的基础是主从复制，确保主库的数据能够同步到从库。

1.1 配置主库（Master）

修改主库配置文件（my.cnf 或 my.ini）：
- server-id：主库的唯一标识。
- log-bin：启用二进制日志，用于记录所有写操作。
- binlog-do-db：指定需要复制的数据库。

创建用于复制的用户：

CREATE USER 'repl'@'%' IDENTIFIED BY 'password';
GRANT REPLICATION SLAVE ON *.* TO 'repl'@'%';
FLUSH PRIVILEGES;

查看主库状态：SHOW MASTER STATUS;
记录 File 和 Position 的值，后续配置从库时会用到。

1.2 配置从库（Slave）

修改从库配置文件（my.cnf 或 my.ini）：
- server-id：从库的唯一标识，必须与主库不同。
配置从库连接主库：
```
CHANGE MASTER TO
MASTER_HOST='master_ip',
MASTER_USER='repl',
MASTER_PASSWORD='password',
MASTER_LOG_FILE='mysql-bin.000001',
MASTER_LOG_POS=4;
```
- MASTER_HOST：主库的 IP 地址。
- MASTER_USER 和 MASTER_PASSWORD：主库上创建的复制用户。
- MASTER_LOG_FILE 和 MASTER_LOG_POS：主库状态中的 File 和 Position。
启动从库复制：START SLAVE;
检查从库状态：SHOW SLAVE STATUS\G;
确保 Slave_IO_Running 和 Slave_SQL_Running 都为 Yes。

2. 应用层实现读写分离

在应用层实现读写分离通常有以下几种方式：

2.1 使用中间件

MySQL Proxy：一个开源的 MySQL 中间件，可以自动将读请求转发到从库，写请求转发到主库。
MaxScale：MariaDB 提供的数据库代理，支持读写分离、负载均衡等功能。
ProxySQL：高性能的 MySQL 代理，支持读写分离、查询缓存、负载均衡等。

2.2 在代码中手动分离

在应用程序代码中手动区分读操作和写操作，将读操作指向从库，写操作指向主库。

例如，在 Java 中使用 Spring 框架时，可以通过配置多个数据源来实现读写分离：

@Configuration
public class DataSourceConfig {

    @Bean(name = "masterDataSource")
    public DataSource masterDataSource() {
        // 配置主库数据源
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "slaveDataSource")
    public DataSource slaveDataSource() {
        // 配置从库数据源
        return DataSourceBuilder.create().build();
    }

    @Primary
    @Bean(name = "routingDataSource")
    public DataSource routingDataSource(
            @Qualifier("masterDataSource") DataSource masterDataSource,
            @Qualifier("slaveDataSource") DataSource slaveDataSource) {
        Map<Object, Object> targetDataSources = new HashMap<>();
        targetDataSources.put("master", masterDataSource);
        targetDataSources.put("slave", slaveDataSource);

        AbstractRoutingDataSource routingDataSource = new AbstractRoutingDataSource() {
            @Override
            protected Object determineCurrentLookupKey() {
                return TransactionSynchronizationManager.isCurrentTransactionReadOnly() ? "slave" : "master";
            }
        };
        routingDataSource.setDefaultTargetDataSource(masterDataSource);
        routingDataSource.setTargetDataSources(targetDataSources);
        return routingDataSource;
    }
}