PHP应用不再卡顿：如何使用GuzzlePromises优雅地处理异步操作？

composer require guzzlehttp/promises

<?php

require 'vendor/autoload.php';

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

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

// 2. 注册成功（onFulfilled）和失败（onRejected）回调函数
// then() 方法会返回一个新的 Promise，这使得链式调用成为可能
$promise
    ->then(
        // 成功回调：当 Promise 被 resolve 时执行
        function ($value) {
            echo "Promise 成功兑现，得到值: " . $value . "\n";
            // 返回的值会作为下一个 then() 的输入
            return "处理后的值: " . strtoupper($value);
        },
        // 失败回调：当 Promise 被 reject 时执行
        function ($reason) {
            echo "Promise 被拒绝，原因: " . $reason . "\n";
            // 如果这里不抛出异常或返回 RejectedPromise，则下一个 then() 的成功回调会被触发
            // 抛出异常会使得链条向下传递拒绝状态
            throw new \Exception("第一次处理失败: " . $reason);
        }
    )
    ->then(
        // 第二个 then() 接收上一个 then() 返回的值（如果上一个成功）
        function ($processedValue) {
            echo "第二个 then 收到处理后的值: " . $processedValue . "\n";
            // 模拟另一个异步操作，返回一个新的 Promise
            return new Promise(function ($resolve) use ($processedValue) {
                echo "模拟第二个异步操作...\n";
                // 实际中可能是一个API调用，这里延迟模拟
                sleep(1); // 阻塞1秒，仅为演示，实际异步不会阻塞主线程
                $resolve($processedValue . " - 完成");
            });
        },
        // 捕获上一个 then() 抛出的异常
        function (\Exception $e) {
            echo "第二个 then 捕获到异常: " . $e->getMessage() . "\n";
            // 也可以返回一个 RejectedPromise 继续传递拒绝状态
            return new RejectedPromise("二次处理失败: " . $e->getMessage());
        }
    )
    ->then(
        function ($finalValue) {
            echo "最终成功： " . $finalValue . "\n";
        },
        function ($finalReason) {
            echo "最终失败： " . $finalReason . "\n";
        }
    );

echo "主程序继续执行，不会阻塞，等待 Promise 被兑现或拒绝...\n";

// 3. 模拟异步操作完成，并兑现 Promise
// 实际应用中，这通常发生在耗时操作（如网络请求、数据库查询）完成后
// $promise->resolve('Hello Guzzle Promises!'); // 尝试成功路径

// 模拟异步操作失败，并拒绝 Promise
$promise->reject('网络连接失败'); // 尝试失败路径

// 注意：在没有事件循环（如ReactPHP、Swoole）驱动的情况下，
// Promise 的回调不会自动执行。为了让这个例子能看到效果，
// 我们通常需要手动触发 Promise 的等待机制，或者集成到一个事件循环中。
// wait() 方法会强制等待 Promise 完成，并在 Promise 被拒绝时抛出异常。
try {
    $promise->wait();
} catch (\Exception $e) {
    // wait() 在 Promise 被拒绝时会抛出 RejectionException 或原始异常
    echo "等待过程中捕获到异常: " . $e->getMessage() . "\n";
}

echo "所有操作完成。\n";