Yii2常驻脚本使用pcntl_fork后父进程数据库连接丢失的解决方法

这个问题在Yii2环境下其实挺常见的，核心原因是pcntl_fork()执行后，子进程会完整复制父进程的所有资源（包括数据库连接的句柄），但父子进程共用同一个连接实例会导致冲突——比如子进程退出时会自动关闭连接副本，父进程再尝试使用原来的连接就会报错。下面给你几个框架层面的解决方案，按推荐程度排序：

方案一：使用Yii2内置的Process组件（最推荐） #

原生pcntl_fork()并没有考虑Yii2框架的资源隔离逻辑，而官方提供的yii\base\Process组件封装了进程管理的细节，会自动帮你处理数据库连接这类资源的隔离问题，避免父子进程互相干扰。

你可以把task2的逻辑单独拆成脚本，或者直接用闭包执行：

方式1：调用独立脚本 #

use yii\base\Process;

switch ($command) {
    case 'task1':
        echo "hello";
        break;
    case 'task2':
        $process = new Process([
            'php', '/path/to/your/task-handler.php', 'task2', // 传递任务标识
            '--some-param', 'your-value' // 可选：传递任务参数
        ]);
        $process->start();
        
        // 可选：如果不需要等待子进程完成，父进程直接继续后续逻辑
        // 若需要等待，可调用 $process->wait();
        break;
}

在task-handler.php里，你可以正常初始化Yii应用并执行task2的逻辑，此时子进程会拥有独立的数据库连接。

方式2：使用闭包（PHP 7.4+支持） #

如果不想单独写脚本，也可以直接用闭包定义子进程逻辑：

use yii\base\Process;

switch ($command) {
    // ...其他case
    case 'task2':
        $process = new Process(function () {
            // 子进程的独立逻辑
            // 这里可以安全使用Yii的数据库组件，框架会自动创建新连接
            $user = \app\models\User::findOne(1);
            echo "Processed user: {$user->username}\n";
            
            // 执行你的任务逻辑...
        });
        $process->start();
        break;
}

这种方式下，子进程的上下文完全独立，父进程的数据库连接不会受到任何影响。

方案二：fork后父进程重新初始化数据库连接 #

如果必须使用原生pcntl_fork()，可以在fork完成后，父进程主动关闭并重新打开数据库连接，以此获得独立的连接实例：

switch ($command) {
    // ...其他case
    case 'task2':
        if (($pid = pcntl_fork()) == -1)
            throw new Exception("fork failed");
        if ($pid == 0) {
            // 子进程逻辑：如果子进程需要数据库操作，建议也重新初始化连接
            Yii::$app->db->close();
            Yii::$app->db->open();
            
            // 执行task2任务...
            exit(0);
        } else {
            // 父进程：重新建立数据库连接
            Yii::$app->db->close();
            Yii::$app->db->open();
        }
        break;
}

原理是：子进程复制的连接副本会在子进程退出时被关闭，但父进程已经重新创建了新的连接，所以后续操作不受影响。

方案三：子进程主动隔离资源 #

另一种思路是让子进程主动关闭从父进程复制来的连接，再重新初始化自己的连接，避免父进程的连接被意外关闭：

switch ($command) {
    // ...其他case
    case 'task2':
        if (($pid = pcntl_fork()) == -1)
            throw new Exception("fork failed");
        if ($pid == 0) {
            // 子进程：关闭父进程的连接副本
            Yii::$app->db->close();
            // 初始化自己的连接
            Yii::$app->db->open();
            
            // 执行task2任务...
            exit(0);
        }
        // 父进程无需修改，继续使用原来的连接
        break;
}

这个方案适合不需要修改父进程逻辑，但要确保子进程操作不干扰父进程的场景。如果你的应用有多个数据库组件（比如db、db2），记得要逐个关闭并重新初始化。

内容的提问来源于stack exchange，提问作者WeSee