php层实现读写分离的核心在于根据sql语句类型（select或非select）动态切换数据库连接，通常通过封装一个数据库代理类或中间件来拦截查询请求。对于写后立即读的场景，强制走主库的最佳实践是引入事务隔离级别控制或显式的主库路由标记，确保在写入操作未完成或未提交前，后续的读取请求被重定向到主库以获取最新数据，从而避免从库延迟导致的数据不一致问题。
如何根据SQL类型自动切换主从库
通过重写PDO或MySQLi的连接逻辑，可以在执行查询前解析SQL关键字。如果语句以SELECT开头，则使用从库连接；否则使用主库连接。这种机制要求开发者无需关心底层连接对象，只需调用统一的查询方法即可。
<?php class ReadWriteSplit {
private $master;
private $slaves = [];
public function __construct() {
// 初始化主库连接
$this->master = new PDO('mysql:host=master_ip;dbname=test', 'user', 'pass');
// 初始化从库连接池
$this->slaves[] = new PDO('mysql:host=slave1_ip;dbname=test', 'user', 'pass');
$this->slaves[] = new PDO('mysql:host=slave2_ip;dbname=test', 'user', 'pass');
}
public function query($sql) {
$sql = trim($sql);
// 判断是否为查询语句
if (stripos($sql, 'SELECT') === 0) {
// 轮询选择从库
$slave = $this->slaves[array_rand($this->slaves)];
return $slave->query($sql);
} else {
// 非查询语句走主库
return $this->master->exec($sql);
}
}
}
$db = new ReadWriteSplit();
$db->query("INSERT INTO users (name) VALUES ('test')");
$result = $db->query("SELECT * FROM users WHERE name='test'");
?>
上述代码展示了基本的读写分离逻辑。`query`方法首先去除SQL首尾空格，然后检查是否以`SELECT`开头。如果是，则从`$slaves`数组中随机选择一个连接执行查询，实现负载均衡。如果不是，则默认使用`$master`连接执行写入操作。这种方式简单有效，但需要确保所有数据库操作都通过该类的`query`方法进行，否则可能绕过分离逻辑。
写后如何强制立即读主库
为了解决主从复制延迟导致的“写后读”不一致问题，可以在写入操作后设置一个标志位，或者将后续读取强制路由到主库。一种常见做法是使用事务或会话变量来标记当前请求的上下文，确保在同一请求周期内，写入后的读取操作始终指向主库。
<?php class ForcedMasterRead {
private $master;
private $slaves = [];
private $forceMaster = false;
public function __construct() {
$this->master = new PDO('mysql:host=master_ip;dbname=test', 'user', 'pass');
$this->slaves[] = new PDO('mysql:host=slave1_ip;dbname=test', 'user', 'pass');
}
public function write($sql) {
$result = $this->master->exec($sql);
// 写入成功后，标记下一次读取强制走主库
$this->forceMaster = true;
return $result;
}
public function read($sql) {
if ($this->forceMaster) {
$this->forceMaster = false; // 重置标志
return $this->master->query($sql);
}
$slave = $this->slaves[0];
return $slave->query($sql);
}
}
$db = new ForcedMasterRead();
$db->write("UPDATE users SET status=1 WHERE id=1");
// 此时即使SQL是SELECT，也会走主库
$result = $db->read("SELECT * FROM users WHERE id=1");
?>
在这个增强版示例中，`write`方法在执行写入后，将`$forceMaster`标志设置为`true`。当调用`read`方法时，程序会检查该标志。如果为`true`，则强制使用`$master`连接执行读取，并将标志重置为`false`。这确保了在一次写入操作后，紧接着的读取操作能获取到最新数据。这种方法适用于大多数Web请求场景，因为每个请求通常是独立的，标志位不会跨请求持久化。
基于事务隔离级别的强一致性方案
除了上述标志位方法，更严谨的做法是利用数据库事务和隔离级别。在写入操作中开启事务，并在同一事务中进行读取，可以确保读到的是自己写入的数据。这需要应用层支持事务管理，并且数据库连接需要在事务期间保持绑定到主库。
<?php class TransactionalRead {
private $master;
public function __construct() {
$this->master = new PDO('mysql:host=master_ip;dbname=test', 'user', 'pass');
$this->master->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
}
public function executeInTransaction(callable $callback) {
$this->master->beginTransaction();
try {
$result = $callback($this->master);
$this->master->commit();
return $result;
} catch (Exception $e) {
$this->master->rollBack();
throw $e;
}
}
}
$db = new TransactionalRead();
$db->executeInTransaction(function($pdo) {
$pdo->exec("UPDATE users SET balance=balance-100 WHERE id=1");
$pdo->exec("UPDATE users SET balance=balance+100 WHERE id=2");
// 在同一事务中读取，保证一致性
$stmt = $pdo->query("SELECT balance FROM users WHERE id=1");
return $stmt->fetch();
});
?>
此方案通过`executeInTransaction`方法封装了事务逻辑。回调函数中的数据库操作都在同一个主库连接上进行，因此天然保证了强一致性。虽然性能略低于简单的读写分离，但在对数据一致性要求极高的场景下（如金融交易），这是最可靠的选择。开发者需确保回调函数中的所有查询都通过传入的`$pdo`对象执行，以避免意外切换到从库。
php免费学习视频：立即使用
踏上前端学习之旅，开启通往精通之路！从前端基础到项目实战，循序渐进，一步一个脚印，迈向巅峰！
