实现mysql读写分离的方法

基础概念

MySQL读写分离是一种常见的数据库架构优化方案，其核心思想是将数据库的读操作和写操作分别分配到不同的服务器上，以提高系统的性能和可用性。读写分离可以有效地减轻主数据库的压力，提高查询效率，并增强系统的扩展性和容错能力。

类型

基于程序代码实现：在应用程序代码中显式地编写读写分离逻辑。
基于中间件实现：使用数据库中间件（如MySQL Proxy、MaxScale等）来自动处理读写分离。
基于数据库自身特性实现：利用MySQL的主从复制特性，结合一些配置和策略来实现读写分离。

应用场景

高并发读取场景：当系统中有大量的读操作时，读写分离可以显著提高读取性能。
数据备份与恢复：通过主从复制，可以实现数据的实时备份和快速恢复。
业务隔离：不同的业务模块可以配置不同的数据库实例，实现业务之间的隔离。

实现方法

以下是一个基于程序代码实现的简单示例：

数据库配置

假设我们有一个主数据库（Master）和一个从数据库（Slave），它们的配置如下：

master:
  host: 192.168.1.1
  port: 3306
  username: root
  password: root

slave:
  host: 192.168.1.2
  port: 3306
  username: root
  password: root

读写分离逻辑

我们可以编写一个简单的读写分离代理类来处理数据库连接：

import mysql.connector

class DBProxy:
    def __init__(self, master_config, slave_config):
        self.master_conn = mysql.connector.connect(**master_config)
        self.slave_conn = mysql.connector.connect(**slave_config)

    def execute(self, query, params=None, read_only=False):
        conn = self.slave_conn if read_only else self.master_conn
        cursor = conn.cursor()
        cursor.execute(query, params)
        result = cursor.fetchall()
        cursor.close()
        return result

    def close(self):
        self.master_conn.close()
        self.slave_conn.close()

# 配置数据库连接
master_config = {
    'host': '192.168.1.1',
    'port': 3306,
    'username': 'root',
    'password': 'root'
}

slave_config = {
    'host': '192.168.1.2',
    'port': 3306,
    'username': 'root',
    'password': 'root'
}

# 创建代理实例
db_proxy = DBProxy(master_config, slave_config)

# 执行读操作
result = db_proxy.execute("SELECT * FROM users WHERE id = %s", (1,), read_only=True)
print(result)

# 执行写操作
db_proxy.execute("UPDATE users SET name = %s WHERE id = %s", ('Alice', 1))

# 关闭连接
db_proxy.close()