Hyperf3.2多个从库怎么用url数组轮询-php教程-PHP中文网

Hyperf 3.2 不支持通过 url 数组直接轮询多从库，需配置多个独立从库连接池，并结合轮询策略类（如 RoundRobinSlaveResolver）或手动选库（如 atomic_inc 计数）实现读请求分发，同时注意事务强制走主库、避免 read 配置为数组等限制。

hyperf3.2多个从库怎么用url数组轮询

Hyperf 3.2 中，若想对多个从库（slave）使用 URL 数组实现轮询读取，不能直接靠配置 `url` 为数组来自动轮询——Hyperf 的数据库组件（基于 `hyperf/database`）底层使用的是 `PDO` 或 `Swoole\Coroutine\MySQL`，不原生支持多 URL 轮询。但可以通过「自定义读写分离策略」+「手动管理从库连接池」来实现类似效果。

1. 配置多个从库连接池

在 config/autoload/databases.php 中，为每个从库单独定义一个连接池（推荐用不同名字区分），例如：

'slaves' => [
    'slave1' => [
        'driver' => 'mysql',
        'host' => '192.168.1.101',
        'port' => 3306,
        'database' => 'test_db',
        'username' => 'user',
        'password' => 'pass',
        // ... 其他参数
    ],
    'slave2' => [
        'driver' => 'mysql',
        'host' => '192.168.1.102',
        'port' => 3306,
        'database' => 'test_db',
        'username' => 'user',
        'password' => 'pass',
        // ... 其他参数
    ],
],

注意：不要把它们塞进同一个 `url` 字段里；Hyperf 不解析数组形式的 `url`，会报错或静默失败。

2. 实现轮询式读库选择器

继承 Hyperf\Database\ConnectionResolver 或更常用的是实现自定义 Hyperf\Database\Connectors\ConnectionFactory + 重写读连接获取逻辑。但更轻量的方式是：创建一个轮询策略类，在每次查询前动态切换读库。

示例（简单轮询计数器）：

hyperframes-超帧视频

HTML 驱动的视频合成——GSAP 动画、TTS 字幕、音频响应、着色器转场

下载

use Hyperf\Contract\StdoutLoggerInterface;
use Hyperf\Database\Connection;
use Hyperf\Database\ConnectionResolverInterface;
use Psr\Container\ContainerInterface;

class RoundRobinSlaveResolver implements ConnectionResolverInterface
{
    private array $slaveNames = ['slave1', 'slave2'];
    private int $index = 0;

    public function __construct(private ContainerInterface $container) {}

    public function connection($name = null): Connection
    {
        $name = $name ?: $this->getRoundRobinSlaveName();
        return $this->container->get('db')->connection($name);
    }

    private function getRoundRobinSlaveName(): string
    {
        $name = $this->slaveNames[$this->index];
        $this->index = ($this->index + 1) % count($this->slaveNames);
        return $name;
    }
}

然后在 config/autoload/db.php 中替换默认 resolver（需配合自定义 DbFactory）或通过 AOP/事件拦截读操作——但更推荐下面第 3 种方式。

3. 使用中间件或基类统一控制读库路由

Hyperf 默认通过 DB::connection('default') 获取连接，而 default 的读写分离由 read_write_ratio 和 read 配置决定。我们可以绕过它，改用显式指定从库名：

在模型中重写 getConnection()，根据上下文返回轮询的 slave 连接
封装一个 SlaveDB 工具类，提供 select()、table() 等方法，内部自动轮询
最实用做法：在 Service 层调用前手动选库，例如：

$slaveName = match (atomic_inc('slave_round_index') % 2) {
    0 => 'slave1',
    1 => 'slave2',
};
$result = DB::connection($slaveName)->table('users')->where('id', 1)->first();

⚠️ 注意：atomic_inc 是 Hyperf 提供的原子计数器（需启用 hyperf/atomic），保证协程安全；也可用 Swoole\Atomic 或 Redis 计数器替代。

4. 补充建议与避坑点

主从延迟敏感场景下，轮询不如按负载/响应时间/权重调度，可后续扩展为健康检查 + 权重路由
事务内务必强制走主库，避免 DB::transaction() 中混入从库查询
不要在 config/autoload/databases.php 中给 default 的 read 配置数组——Hyperf 3.2 不支持该写法，会报 Invalid argument supplied for foreach()
如需深度集成，可监听 Hyperf\Database\Events\QueryExecuted 事件统计各从库耗时，用于动态调整轮询顺序