如何解决PHP异步操作中的“回调地狱”和复杂状态管理，GuzzleHttp/Promises助你构建高效并发应用

<code class="bash">composer require guzzlehttp/promises</code>

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步成功：接收到 '{$value}'\n";
        // 返回一个值，这个值会传递给下一个 then
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        echo "第二步成功：接收到 '{$value}'\n";
        // 返回一个新的 Promise，后续链会等待这个 Promise 完成
        $nextPromise = new Promise();
        echo "正在等待下一个 Promise...\n";
        return $nextPromise;
    })
    ->then(function ($value) {
        echo "第三步成功：接收到 '{$value}'\n";
    })
    ->otherwise(function ($reason) { // 专门处理拒绝的回调
        echo "操作失败：{$reason}\n";
    });

// 模拟异步操作完成
$promise->resolve('reader'); // 触发第一个 then
// 模拟第二个 Promise 完成
// 假设 $nextPromise 在某个异步操作完成后被 resolve
// 为了演示，我们手动 resolve 它
// 在实际应用中，这会是一个真实的异步操作结果
// $nextPromise->resolve('World!'); // 这一步在实际中会由异步任务完成
// 这里为了演示，我们直接在外部模拟 resolve，需要确保 $nextPromise 已经被返回并捕获
// 假设 $nextPromise 已经被上一个 then 返回并赋值给了某个变量
// 实际上，链式调用会自动处理 Promise 的转发
// 为了让例子完整，我们假设 $nextPromise 最终被 resolve
// 在实际应用中，如果你返回了一个 Promise，那么链中的下一个 then 会等待这个返回的 Promise 完成。
// 这里，为了让输出更清晰，我们直接让初始 promise 完成，并演示链式调用。
// 让我们修改一下，让 $nextPromise 真实地被 resolve
$p1 = new Promise();
$p2 = new Promise();

$p1->then(function ($value) use ($p2) {
    echo "第一步成功：接收到 '{$value}'\n";
    return $p2; // 返回第二个 Promise
})->then(function ($value) {
    echo "第二步成功：接收到 '{$value}'\n";
})->otherwise(function ($reason) {
    echo "操作失败：{$reason}\n";
});

$p1->resolve('开始'); // 触发第一个 then
$p2->resolve('结束！'); // 触发第二个 then
// 输出:
// 第一步成功：接收到 '开始'
// 第二步成功：接收到 '结束！'

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

$promise = new Promise();
$promise
    ->then(null, function ($reason) { // 第二个参数是拒绝回调
        echo "捕获到错误：{$reason}\n";
        throw new \Exception("进一步处理错误: " . $reason); // 抛出异常会传递给下一个拒绝回调
    })
    ->otherwise(function (\Exception $e) { // 使用 otherwise 捕获异常
        echo "最终错误处理：{$e->getMessage()}\n";
        return "错误已处理，返回一个默认值"; // 返回一个值，可以改变后续链的状态
    })
    ->then(function ($value) {
        echo "错误处理后继续：{$value}\n"; // 这里的 value 是 otherwise 返回的值
    });

$promise->reject('API请求失败');
// 输出:
// 捕获到错误：API请求失败
// 最终错误处理：进一步处理错误: API请求失败
// 错误处理后继续：错误已处理，返回一个默认值

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1);
    $promise->resolve('数据已加载');
});

echo "开始等待...\n";
$result = $promise->wait(); // 会阻塞直到 Promise 被解决或拒绝
echo "等待结束，结果是：{$result}\n";

// 如果 Promise 被拒绝，wait() 会抛出异常
$rejectedPromise = new Promise();
$rejectedPromise->reject('操作超时');
try {
    $rejectedPromise->wait();
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "等待时捕获到拒绝异常：{$e->getMessage()}\n";
}

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

$loop = Factory::create();
$queue = Utils::queue();

// 每隔一段时间运行一次 Guzzle 的任务队列
$loop->addPeriodicTimer(0.001, [$queue, 'run']);

// 在这里创建和使用你的 Promise
// ...

$loop->run(); // 启动事件循环