Hyperf 2.x怎么在Task进程中使用数据库_注入TaskExecutor手动处理-php教程-PHP中文网

hyperf 2.x task 进程默认不初始化数据库连接池，导致 connectioninterface 注入失败；需在 task 中手动调用 connectionfactory::create() 并绑定到容器，或通过 ensuredb() 懒加载确保每次 execute 前可用。

hyperf 2.x怎么在task进程中使用数据库_注入taskexecutor手动处理

Hyperf 2.x 的 Task 进程默认不加载数据库组件，直接在 Task::execute() 中调用 $this->db 或注入 ConnectionInterface 会报 DI 找不到服务——这不是配置漏了，而是 Task 进程启动时没初始化数据库连接池。

为什么 Task 进程里 DB 注入失败？

Hyperf 2.x 的 Task Worker 是独立于 HTTP/WS Worker 的子进程，它只加载基础容器和显式注册的组件。数据库连接池（Hyperf\Database\ConnectionInterface）默认只在主协程上下文初始化，Task 进程启动时不触发 DatabaseFactory，所以即使你在 dependencies.php 里绑定了接口，实例也从未被创建。

现象：PHP Fatal error: Uncaught Hyperf\Di\Exception\NotFoundException: Class Hyperf\Database\ConnectionInterface does not exist
验证方式：在 Task 类的 __construct() 里 var_dump($this->container->has(ConnectionInterface::class))，结果为 false
注意：Hyperf 3.x 已修复此问题，默认启用全组件加载；2.x 必须手动补全

手动注入 `TaskExecutor` 并初始化 DB 连接池

核心思路是：在 Task 启动前，主动调用数据库工厂创建连接池实例，并绑定到容器。不能依赖注解自动注入，得自己“把轮子装上”。

Hyperframes Creative

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

下载

在 app/Task/YourTask.php 中，不要直接写 public function __construct(protected ConnectionInterface $db)
改用构造器内手动获取容器并初始化：

use Hyperf\Database\ConnectionInterface;
use Hyperf\Database\ConnectionFactory;

public function __construct()
{
    $container = $this->container;
    // 检查是否已存在，避免重复初始化
    if (! $container->has(ConnectionInterface::class)) {
        $factory = $container->get(ConnectionFactory::class);
        $connection = $factory->create('default'); // 'default' 对应 config/autoload/database.php 中的 default 配置
        $container->set(ConnectionInterface::class, $connection);
    }
}

后续在 execute() 中可安全使用 $this->container->get(ConnectionInterface::class)
若需多个库，对每个配置名（如 'log'）重复调用 $factory->create('log') 并单独绑定

更稳妥的做法：复用主进程已建好的连接池

Task 进程无法直接复用主进程的连接池对象（跨进程内存不共享），但可以复用配置 + 懒创建。推荐封装一个初始化方法，在每次 execute() 开头调用，避免构造器里初始化失败导致整个 Task 失效：

加一个私有方法：

private function ensureDb(): ConnectionInterface
{
    $container = $this->container;
    if ($container->has(ConnectionInterface::class)) {
        return $container->get(ConnectionInterface::class);
    }
    $factory = $container->get(ConnectionFactory::class);
    $connection = $factory->create('default');
    $container->set(ConnectionInterface::class, $connection);
    return $connection;
}