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

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

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 创建一个新的 Promise
$promise = new Promise();

// 注册成功和失败的回调
$promise->then(
    function ($value) {
        echo "Promise 成功兑现，值是: " . $value . PHP_EOL;
    },
    function ($reason) {
        echo "Promise 被拒绝，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成，并兑现 Promise
$promise->resolve('Hello, Guzzle Promises!');

// 输出: Promise 成功兑现，值是: Hello, Guzzle Promises!</code>

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$initialPromise = new Promise();

$initialPromise
    ->then(function ($value) {
        echo "第一步：接收到 " . $value . PHP_EOL;
        // 返回一个新值，这个值会传递给下一个 then
        return $value . ' World';
    })
    ->then(function ($value) {
        echo "第二步：处理后得到 " . $value . PHP_EOL;
        // 返回一个新的 Promise，下一个 then 会等待这个 Promise 完成
        $newPromise = new Promise();
        // 模拟一个异步延迟
        // sleep(1); // 在实际应用中，这里会是真正的异步操作
        $newPromise->resolve(' and beyond!');
        return $newPromise;
    })
    ->then(function ($value) {
        echo "第三步：最终结果 " . $value . PHP_EOL;
    });

// 启动 Promise 链
$initialPromise->resolve('Hello');

// 注意：如果不在事件循环中运行或同步等待，这里可能不会立即输出所有内容
// 在实际异步环境中，你需要运行任务队列，如 GuzzleHttp\Promise\Utils::queue()->run();</code>

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;

$promiseWithError = new Promise();

$promiseWithError
    ->then(function ($value) {
        echo "成功回调：不应该执行到这里" . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 相当于 then(null, $onRejected)
        echo "错误处理：捕获到错误 - " . $reason . PHP_EOL;
        // 也可以在这里返回一个新的 Promise 或值，改变后续链条的状态
        // return new FulfilledPromise('错误已恢复');
        // 或者继续抛出错误
        // throw new Exception('新的错误');
    })
    ->then(function ($value) {
        echo "后续处理：如果错误被恢复，这里会执行，值是：" . $value . PHP_EOL;
    }, function ($reason) {
        echo "最终错误处理：如果错误未被恢复，这里会执行，原因是：" . $reason . PHP_EOL;
    });

$promiseWithError->reject('API 调用失败');

// 输出: 错误处理：捕获到错误 - API 调用失败
// 如果错误被恢复，会继续输出“后续处理”</code>

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$dataPromise = new Promise(function () use (&$dataPromise) {
    // 模拟一个耗时操作，最终会 resolve
    // sleep(2);
    $dataPromise->resolve('从数据库获取的数据');
});

echo "等待数据中..." . PHP_EOL;
$result = $dataPromise->wait(); // 脚本会在这里阻塞，直到 Promise 完成
echo "数据已获取: " . $result . PHP_EOL;

// 输出:
// 等待数据中...
// 数据已获取: 从数据库获取的数据</code>