告别漫长等待：如何使用Composer和GuzzlePromises优雅地处理PHP异步操作

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

guzzlehttp/promises

then()

$onFulfilled

$onRejected

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

// 注册成功和失败的回调
$promise->then(
    function ($value) {
        echo "操作成功，结果是: " . $value . PHP_EOL;
    },
    function ($reason) {
        echo "操作失败，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成并成功
// 实际场景中，这可能是一个网络请求完成后的回调
$promise->resolve('数据已获取'); // 触发 $onFulfilled

// 模拟异步操作完成并失败
// $promise->reject('网络连接超时'); // 触发 $onRejected

then()

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

function simulateAsyncTask(string $taskName, int $delay, bool $shouldFail = false): Promise
{
    $promise = new Promise();
    // 模拟异步操作，例如网络请求
    echo "任务 [{$taskName}] 开始执行..." . PHP_EOL;
    // 实际应用中，这里会是异步I/O操作，例如 GuzzleHttp\Client->getAsync()
    // 这里我们用一个简单的计时器来模拟异步完成
    \React\EventLoop\Factory::create()->addTimer($delay / 1000, function() use ($promise, $taskName, $shouldFail) {
        if ($shouldFail) {
            $promise->reject(new \Exception("任务 [{$taskName}] 失败了！"));
        } else {
            $promise->resolve("任务 [{$taskName}] 完成，耗时 {$delay}ms。");
        }
    })->run(); // 注意：这里需要一个事件循环来驱动Promise的resolve/reject

    return $promise;
}

// 假设我们有一个事件循环（例如基于ReactPHP）
// 为了演示，我们直接创建一个并运行，实际应用中会整合到你的应用事件循环中
$loop = \React\EventLoop\Factory::create();
\GuzzleHttp\Promise\Utils::queue()->run(); // 确保Guzzle Promise的内部队列运行

$promiseA = new Promise(function () use (&$promiseA) {
    // 模拟第一个异步操作
    $loop->addTimer(0.1, function() use (&$promiseA) {
        echo "--- 任务 A 完成 ---" . PHP_EOL;
        $promiseA->resolve('Data from API A');
    });
});

$promiseB = $promiseA->then(function ($dataA) use (&$loop) {
    echo "接收到: {$dataA}, 准备执行任务 B..." . PHP_EOL;
    return new Promise(function () use (&$loop, &$promiseB) {
        // 模拟第二个异步操作，依赖于第一个结果
        $loop->addTimer(0.2, function() use (&$promiseB) {
            echo "--- 任务 B 完成 ---" . PHP_EOL;
            $promiseB->resolve('Data from API B based on A');
        });
    });
})->then(function ($dataB) {
    echo "接收到: {$dataB}, 所有任务完成！" . PHP_EOL;
    return "最终结果: " . $dataB;
}, function ($reason) {
    echo "某个任务失败了: " . $reason->getMessage() . PHP_EOL;
    throw $reason; // 继续向下传递失败
});

// 驱动事件循环，让Promise执行
$loop->run();

// 如果需要同步等待最终结果（不推荐在主Web请求中使用，但调试或CLI脚本有用）
// echo "最终同步等待结果: " . $promiseB->wait() . PHP_EOL;

guzzlehttp/promises

getAsync()

wait()

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作
    sleep(2);
    $promise->resolve('等待结束，获取到结果');
});

echo "开始等待 Promise 完成..." . PHP_EOL;
$result = $promise->wait(); // 会阻塞当前执行流，直到 Promise 完成
echo "Promise 完成，结果是: " . $result . PHP_EOL;

// 错误处理
$errorPromise = new Promise(function () use (&$errorPromise) {
    sleep(1);
    $errorPromise->reject(new \Exception('操作被拒绝了！'));
});

try {
    echo "尝试等待一个会失败的 Promise..." . PHP_EOL;
    $errorPromise->wait();
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "捕获到 Promise 拒绝异常: " . $e->getReason()->getMessage() . PHP_EOL;
}

guzzlehttp/promises