Hyperf微服务内部调用多数据库连接封装代码-php教程-PHP中文网

hyperf微服务内部调用应通过connectionfactory封装多库连接，按业务域配置语义化数据库连接（user_db/order_db/log_db），显式声明driver与pool参数并合理设置max_connections，rpc服务中构造注入connectionfactory实现协程安全、可维护的跨库查询，事务严格限定单库。

hyperf微服务内部调用多数据库连接封装代码

Hyperf 微服务内部调用需兼顾多库隔离、协程安全与业务可维护性。不建议在 RPC 方法里硬编码连接名或重复写 Db::connection(...)，应通过分层封装解耦数据源逻辑。

按业务域划分数据库连接

在 config/autoload/databases.php 中为不同模块定义语义化连接名，例如：

user_db：用户中心主库（MySQL 8.0，含密码插件适配）
order_db：订单分片库（MySQL 5.7，启用预处理模拟）
log_db：只读日志库（独立 PostgreSQL 实例）

每个连接必须显式声明 driver、pool 参数，并按实例实际能力设置 max_connections（如 RDS MySQL 5.7 max_connections=200，则对应连接池设 ≤150）。

封装连接工厂类

新建 app/Database/ConnectionFactory.php，统一管理连接获取逻辑：

namespace App\Database;

use Hyperf\Database\Connection;
use Hyperf\Database\ConnectionInterface;
use Hyperf\Di\Annotation\Inject;

class ConnectionFactory
{
    public function getUserConnection(): ConnectionInterface
    {
        return \Hyperf\DbConnection\Db::connection('user_db');
    }

    public function getOrderConnection(): ConnectionInterface
    {
        return \Hyperf\DbConnection\Db::connection('order_db');
    }

    public function getLogConnection(): ConnectionInterface
    {
        return \Hyperf\DbConnection\Db::connection('log_db');
    }
}

该类可配合依赖注入使用，避免全局静态调用污染测试边界；也可根据上下文（如租户 ID、业务标签）动态返回连接，但需注意跨库 JOIN 不支持，关联查需拆成多次查询+内存拼接。

Hyperframes Creative

HyperFrames视频非动画创意指导，包括设计规范（frame.md/design.md）处理、配色、字体设计、旁白及节奏规划等。

下载

在 RPC 服务中安全使用

服务提供者（Provider）的业务方法内，优先通过构造函数注入 ConnectionFactory：

class UserService implements UserInterface
{
    public function __construct(
        private ConnectionFactory $connectionFactory,
        private LoggerInterface $logger
    ) {}

    public function getUserWithOrders(int $uid): array
    {
        $user = $this->connectionFactory->getUserConnection()
            ->table('users')->where('id', $uid)->first();

        $orders = $this->connectionFactory->getOrderConnection()
            ->table('orders')->where('user_id', $uid)->get();

        return ['user' => $user, 'orders' => $orders];
    }
}

事务需严格限定在单库内，跨库操作不可加同一 transaction 包裹。若需最终一致性，改用本地消息表 + 定时补偿。