ReactPHP中如何正确使用async awaitAll？异步脚本未执行数据库连接求解答

你的第三个脚本未执行数据库连接和循环迭代，核心原因是没有正确触发异步操作的执行逻辑，结合ReactPHP Async的并发机制，常见问题及修复方式如下：

1. Promise数组未正确生成 #

如果你的循环仅定义了Promise的生成函数，而非实际创建Promise实例，parallel()无法触发执行。比如错误写法：

// 错误：仅添加了函数，未生成Promise
$promises[] = fn() => $factory->createLazyConnection($config);

正确写法应直接生成Promise实例：

// 正确：生成并添加Promise到数组
$promises[] = $factory->createLazyConnection($config);

2. 未启动事件循环执行异步任务 #

ReactPHP的异步操作依赖事件循环，必须通过Async\await()来启动循环并等待所有Promise完成。如果你的脚本缺少这一步，所有异步任务都不会被执行：

// 必须调用await()来触发所有并发Promise的执行
Async\await(Async\parallel($promises));

3. 循环逻辑存在错误 #

检查循环的条件是否正确（比如是否确实循环了12次），以及是否在循环内将Promise正确添加到数组中，避免因循环未触发导致Promise数组为空。

正确的并发数据库连接示例 #

use React\Async;
use React\MySQL\Factory;

require __DIR__ . '/vendor/autoload.php';

$factory = new Factory();
$dbConfig = [
    'host' => '127.0.0.1',
    'user' => 'root',
    'password' => 'your_password',
    'dbname' => 'your_db'
];

$promises = [];
// 生成12个并发连接的Promise
for ($i = 0; $i < 12; $i++) {
    $promises[] = $factory->createLazyConnection($dbConfig)
        ->then(function ($connection) use ($i) {
            echo "连接 $i 已建立\n";
            return $connection->quit();
        })
        ->catch(function ($e) use ($i) {
            echo "连接 $i 失败: {$e->getMessage()}\n";
        });
}

// 启动事件循环，等待所有连接完成
Async\await(Async\parallel($promises));
echo "所有连接任务完成\n";

核心注意点 #

• 使用createLazyConnection()：该方法会在Promise被等待时才实际发起连接，确保并发触发。
• parallel()的作用：接收Promise数组，返回一个汇总Promise，当所有子Promise完成时才会resolve。
• 必须调用await()：这是启动ReactPHP事件循环的关键，没有它异步任务永远不会执行。

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