数据分库是为了解决单个数据库性能瓶颈,提升系统扩展性和稳定性。1.水平分库通过哈希等规则将数据分散到多个数据库,优点是可扩展性强,但存在跨库事务和数据倾斜问题;2.垂直分库按业务模块拆分数据,优点是结构清晰便于维护,但可能仍存在单模块数据量过大的问题;3.读写分离通过主从复制将读写操作分离,提高读性能但存在延迟风险。实际应用中可根据业务需求选择合适方案或组合使用,并需关注数据一致性与迁移策略。

数据分库,简单来说,就是把原本放在一个数据库里的数据,拆分到多个数据库中。为什么要这么做?最直接的原因就是数据量太大,单个数据库扛不住了。更深层的原因,是为了提升性能、扩展性,让系统更稳定。

数据分库的核心目标是将数据分散存储,以减轻单个数据库的压力,提高整体的读写能力。下面介绍三种常见的数据分库架构方案,并附带一些PHP实现上的考量。

水平分库是最常见的分库方式。它按照某种规则(例如用户ID的哈希值),将数据分散到不同的数据库中。每个数据库存储的是一部分数据,所有数据库的数据加起来才是完整的数据集。
立即学习“PHP免费学习笔记(深入)”;

优点:
缺点:
DESTOON B2B网站管理系统是一套完善的B2B(电子商务)行业门户解决方案。系统基于PHP+MySQL开发,采用B/S架构,模板与程序分离,源码开放。模型化的开发思路,可扩展或删除任何功能;创新的缓存技术与数据库设计,可负载千万级别数据容量及访问。 DESTOON B2B网站管理系统是一套完善的B2B(电子商务)行业门户解决方案。系统基于PHP+MySQL开发,采用B/S架构,模板与程序分
648
PHP实现示例(简化版):
<?php
class ShardingDatabase
{
private $databases;
private $shardingKey;
public function __construct(array $databases, string $shardingKey)
{
$this->databases = $databases;
$this->shardingKey = $shardingKey;
}
private function getDatabase(int $shardingValue): PDO
{
$dbCount = count($this->databases);
$dbIndex = $shardingValue % $dbCount;
return $this->databases[$dbIndex]; // 假设 databases 数组存储的是 PDO 连接
}
public function query(string $sql, array $params, int $shardingValue)
{
$db = $this->getDatabase($shardingValue);
$stmt = $db->prepare($sql);
$stmt->execute($params);
return $stmt->fetchAll(PDO::FETCH_ASSOC);
}
public function insert(string $sql, array $params, int $shardingValue): bool
{
$db = $this->getDatabase($shardingValue);
$stmt = $db->prepare($sql);
return $stmt->execute($params);
}
}
// 示例用法
$databases = [
new PDO("mysql:host=db1;dbname=users", "user", "password"),
new PDO("mysql:host=db2;dbname=users", "user", "password"),
];
$shardingDb = new ShardingDatabase($databases, 'user_id');
// 插入数据,根据 user_id 分库
$userId = 123;
$sql = "INSERT INTO users (user_id, name) VALUES (:user_id, :name)";
$params = [':user_id' => $userId, ':name' => 'Alice'];
$shardingDb->insert($sql, $params, $userId);
// 查询数据,同样根据 user_id
$sql = "SELECT * FROM users WHERE user_id = :user_id";
$params = [':user_id' => $userId];
$result = $shardingDb->query($sql, $params, $userId);
print_r($result);
?>这个例子非常简化,实际应用中需要考虑连接池、错误处理、更复杂的路由规则等等。$shardingKey 定义了根据哪个字段进行分片,$shardingValue 则是该字段的具体值。
垂直分库是按照业务模块将数据分散到不同的数据库中。例如,可以将用户相关的表放在一个数据库,订单相关的表放在另一个数据库。
优点:
缺点:
PHP实现示例:
垂直分库在PHP代码层面,更多的是体现在配置和管理上。你可以创建多个数据库连接配置,每个配置对应一个业务数据库。
<?php
class DatabaseConfig
{
public static function getUserDbConfig(): array
{
return [
'host' => 'user_db_host',
'dbname' => 'user_db',
'user' => 'user',
'password' => 'password',
];
}
public static function getOrderDbConfig(): array
{
return [
'host' => 'order_db_host',
'dbname' => 'order_db',
'user' => 'user',
'password' => 'password',
];
}
}
class UserDatabase
{
private $db;
public function __construct()
{
$config = DatabaseConfig::getUserDbConfig();
$dsn = "mysql:host={$config['host']};dbname={$config['dbname']}";
$this->db = new PDO($dsn, $config['user'], $config['password']);
}
public function getUserById(int $userId): array
{
$stmt = $this->db->prepare("SELECT * FROM users WHERE id = :id");
$stmt->execute([':id' => $userId]);
return $stmt->fetch(PDO::FETCH_ASSOC);
}
}
class OrderDatabase
{
private $db;
public function __construct()
{
$config = DatabaseConfig::getOrderDbConfig();
$dsn = "mysql:host={$config['host']};dbname={$config['dbname']}";
$this->db = new PDO($dsn, $config['user'], $config['password']);
}
public function getOrdersByUserId(int $userId): array
{
$stmt = $this->db->prepare("SELECT * FROM orders WHERE user_id = :user_id");
$stmt->execute([':user_id' => $userId]);
return $stmt->fetchAll(PDO::FETCH_ASSOC);
}
}
// 示例用法
$userDb = new UserDatabase();
$orderDb = new OrderDatabase();
$user = $userDb->getUserById(1);
$orders = $orderDb->getOrdersByUserId(1);
print_r($user);
print_r($orders);
?>这个例子展示了如何通过不同的配置,连接到不同的业务数据库。
读写分离是将读操作和写操作分别路由到不同的数据库。通常情况下,写操作路由到主库,读操作路由到从库。主库负责数据的更新,从库负责数据的查询。数据通过主从复制同步。
优点:
缺点:
PHP实现示例:
<?php
class ReadWriteDatabase
{
private $masterDb;
private $slaveDbs;
public function __construct(PDO $masterDb, array $slaveDbs)
{
$this->masterDb = $masterDb;
$this->slaveDbs = $slaveDbs;
}
private function getSlaveDb(): PDO
{
$slaveCount = count($this->slaveDbs);
$slaveIndex = rand(0, $slaveCount - 1); // 随机选择一个从库
return $this->slaveDbs[$slaveIndex];
}
public function query(string $sql, array $params, bool $isWrite = false)
{
$db = $isWrite ? $this->masterDb : $this->getSlaveDb();
$stmt = $db->prepare($sql);
$stmt->execute($params);
return $stmt->fetchAll(PDO::FETCH_ASSOC);
}
public function insert(string $sql, array $params): bool
{
return $this->query($sql, $params, true); // 强制写主库
}
public function update(string $sql, array $params): bool
{
return $this->query($sql, $params, true); // 强制写主库
}
}
// 示例用法
$masterDb = new PDO("mysql:host=master_db;dbname=mydb", "user", "password");
$slaveDbs = [
new PDO("mysql:host=slave_db1;dbname=mydb", "user", "password"),
new PDO("mysql:host=slave_db2;dbname=mydb", "user", "password"),
];
$readWriteDb = new ReadWriteDatabase($masterDb, $slaveDbs);
// 插入数据,写主库
$sql = "INSERT INTO users (name) VALUES (:name)";
$params = [':name' => 'Bob'];
$readWriteDb->insert($sql, $params);
// 查询数据,读从库
$sql = "SELECT * FROM users WHERE name = :name";
$params = [':name' => 'Bob'];
$result = $readWriteDb->query($sql, $params);
print_r($result);
?>这个例子展示了如何将写操作路由到主库,读操作随机路由到从库。
选择哪种分库方案,取决于你的具体业务场景。如果数据量巨大,且对事务要求不高,可以考虑水平分库。如果业务模块清晰,可以考虑垂直分库。如果读操作远多于写操作,可以考虑读写分离。当然,也可以将多种方案结合使用。
数据一致性是分库后需要重点考虑的问题。可以使用分布式事务、最终一致性方案等来保证数据一致性。
数据迁移是一个复杂的过程,需要仔细规划。可以使用工具或者编写脚本来进行数据迁移。在迁移过程中,需要保证数据的完整性和可用性。
以上就是PHP怎么实现数据分库 数据分库的3种架构方案解析的详细内容,更多请关注php中文网其它相关文章!
PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号