PHP实现MySQL读写分离需先搭建主从复制,再通过五种方案自动路由:一、PDO封装代理类按SQL类型分发;二、MaxScale中间件透明转发;三、Laravel扩展DB组件;四、Atlas中间件部署;五、Swoole协程手动路由。

如果您正在搭建一个高并发的PHP网站,数据库读写压力不均衡可能导致主库过载、从库闲置,此时需要在应用层实现MySQL主从库的自动读写分离。以下是通过PHP配置数据库中间件达成该目标的具体操作步骤:
一、使用PDO封装读写分离代理类
该方法通过自定义PDO扩展类,在执行SQL前依据语句类型(SELECT或非SELECT)自动路由至从库或主库,无需依赖外部中间件,轻量可控。
1、创建DbProxy类,构造函数中初始化主库与从库PDO连接实例,并将从库连接存入数组。
2、定义getSlavePdo()方法,采用随机或轮询策略从从库列表中选取一个可用连接。
立即学习“PHP免费学习笔记(深入)”;
3、重写query()和exec()方法:对传入SQL进行trim并转为小写,使用preg_match('/^\s*(select|show|describe|explain|desc)\b/i', $sql)判断是否为读操作。
4、若匹配读操作,则调用getSlavePdo()获取从库连接并执行;否则使用主库连接执行。
5、在业务代码中全局替换new PDO(...)为new DbProxy(...),确保所有数据库操作经由代理类分发。
二、集成MaxScale数据库代理中间件
该方法部署独立的MySQL协议代理服务,由MaxScale解析客户端请求并按规则转发至后端主从节点,PHP代码无需修改,仅需将数据库连接地址指向MaxScale监听端口。
1、在Linux服务器上安装MaxScale 22.x或更新版本,确保系统已安装libcurl、openssl等依赖库。
2、编辑/etc/maxscale.cnf,配置[server1]为MySQL主库IP及端口,[server2]为从库IP及端口,并设置[monitor]模块启用复制监控。
3、在[service]段中启用readwritesplit路由器,设置max_slave_connections=100,enable_root_user=true,并配置user和passwd字段指向MySQL授权用户。
4、在[listener]段绑定监听地址为0.0.0.0:4006,协议设为MySQLClient。
5、启动MaxScale服务:sudo maxscale --config=/etc/maxscale.cnf,验证状态为running且后端服务器状态为Running。
三、基于Laravel框架的DB组件扩展
该方法适用于Laravel项目,利用其数据库连接管理机制,在运行时动态切换连接,通过服务提供者注入读写分离逻辑,保持Eloquent语法透明性。
1、在config/database.php中新增'primary_replica'连接配置,type设为'mysql',hosts设为关联数组['write' => '192.168.1.10', 'read' => ['192.168.1.11', '192.168.1.12']]。
2、创建ReadReplicaConnectionResolver类,继承Illuminate\Database\Connectors\ConnectionFactory,重写createConnector()方法,根据当前查询类型返回对应PDO实例。
3、在AppServiceProvider的boot()中,使用DB::extend('primary_replica', function ($config, $database, $prefix, $name) { return new ReadReplicaConnectionResolver($config); });
4、在.env中设置DB_CONNECTION=primary_replica,确保默认连接使用该扩展驱动。
5、执行php artisan config:clear使配置生效,验证DB::connection()->getPdo()返回的实例IP符合预期读写路由。
四、使用Atlas数据库中间件部署方案
该方案采用奇虎360开源的Atlas中间件,专为MySQL设计,支持自动故障转移、读写分离及连接池管理,适合中小规模集群场景。
1、下载Atlas 2.2.1稳定版源码包,解压后进入src目录执行make编译,生成atlas可执行文件。
2、复制conf/test.cnf为my.cnf,修改proxy-backend-addresses为主库地址,proxy-read-only-backend-addresses为从库地址列表,格式为ip:port@weight。
3、设置log-level=1以启用详细日志,指定log-path=/usr/local/atlas/log/,确保目录存在且有写权限。
4、运行./atlas -c my.cnf -C启动服务,检查日志中出现“start to run proxy”及后端节点状态为online。
5、将PHP中PDO连接的host改为127.0.0.1,port改为Atlas监听端口(默认1234),用户名密码保持与后端MySQL一致。
五、基于Swoole协程MySQL客户端的手动路由
该方法适用于Swoole常驻内存环境,利用协程MySQL客户端的异步能力,在协程上下文中根据SQL类型实时选择连接句柄,避免阻塞并提升吞吐。
1、安装swoole扩展(v4.8+),确认启用mysql协程客户端支持。
2、定义全局连接池管理器,分别维护$masterPool与$slavePool两个Co\Channel,容量各设为32。
3、编写acquireMaster()与acquireSlave()方法,从对应Channel中pop连接,若为空则new Co\Mysql()并connect主库或任一从库。
4、在协程HTTP处理逻辑中,使用preg_match('/^\s*(select|show|describe|explain|desc)\b/i', $sql)识别读请求,调用acquireSlave()获取连接;其余情况调用acquireMaster()。
5、执行完毕后,将连接句柄push回对应Channel,确保连接复用,避免频繁创建销毁开销。



















