告别异步操作的噩梦：如何使用Composer和GuzzlePromises优雅地处理并发请求

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

<code class="php">use GuzzleHttp\Promise\Promise;

// 创建一个Promise实例
$promise = new Promise();

// 注册成功和失败的回调函数
$promise->then(
    // $onFulfilled: 当Promise成功时执行
    function ($value) {
        echo '操作成功，结果是: ' . $value . "\n";
    },
    // $onRejected: 当Promise失败时执行
    function ($reason) {
        echo '操作失败，原因: ' . $reason . "\n";
    }
);

// 模拟一个异步操作在某个时刻完成
// resolve() 方法用于将Promise标记为成功，并传递结果
$promise->resolve('数据已从API获取');

// 如果操作失败，则使用 reject()
// $promise->reject('API调用失败，请检查网络');

// 输出: 操作成功，结果是: 数据已从API获取</code>

<code class="php">use GuzzleHttp\Promise\Promise;

// 模拟第一个异步操作：获取用户ID
$getUserIDPromise = new Promise();

// 模拟第二个异步操作：根据用户ID获取订单列表
$getOrdersPromise = new Promise();

$getUserIDPromise
    ->then(function ($userID) use ($getOrdersPromise) {
        echo "第一步：获取到用户ID: " . $userID . "\n";
        // 返回另一个Promise，链式调用会等待这个Promise完成
        return $getOrdersPromise;
    })
    ->then(function ($orders) {
        echo "第二步：获取到订单列表: " . json_encode($orders) . "\n";
        return "所有数据处理完毕";
    })
    ->then(function ($message) {
        echo "第三步：最终结果: " . $message . "\n";
    });

// 模拟异步操作完成
$getUserIDPromise->resolve(123); // 触发第一个then
// 稍后，另一个异步操作完成
$getOrdersPromise->resolve(['OrderA', 'OrderB']); // 触发第二个then

// 输出:
// 第一步：获取到用户ID: 123
// 第二步：获取到订单列表: ["OrderA","OrderB"]
// 第三步：最终结果: 所有数据处理完毕</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();
$promise
    ->then(function ($value) {
        echo "成功处理: " . $value . "\n";
        // 模拟一个后续操作中出现错误
        throw new \Exception("处理订单时发生内部错误");
    })
    ->then(null, function ($reason) { // 这里的null表示不处理成功回调，只处理拒绝回调
        echo "捕获到错误: " . $reason->getMessage() . "\n";
        return "错误已处理，返回默认值"; // 返回一个值，会使下一个then的onFulfilled被调用
    })
    ->then(function ($value) {
        echo "链条继续，得到恢复值: " . $value . "\n";
    });

$promise->resolve('原始数据');

// 输出:
// 成功处理: 原始数据
// 捕获到错误: 处理订单时发生内部错误
// 链条继续，得到恢复值: 错误已处理，返回默认值</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，例如数据库查询或外部API调用
    sleep(2); // 暂停2秒
    $promise->resolve('这是等待2秒后得到的结果');
});

echo "开始等待Promise完成...\n";
$result = $promise->wait(); // 会阻塞当前进程，直到Promise完成
echo "Promise已完成，结果是: " . $result . "\n";
echo "程序继续执行。\n";</code>