告别回调地狱：如何使用Composer和GuzzlePromises优雅地处理PHP异步操作

// 想象一下，这只是一个简化的“回调地狱”片段
getDataFromApi(function ($data) use ($userId) {
    processData($data, function ($processedData) use ($userId) {
        saveToDatabase($userId, $processedData, function ($result) {
            sendNotification($result, function () {
                echo "All done!";
            });
        });
    });
});

composer require guzzlehttp/promises

use GuzzleHttp\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!

// 模拟异步操作失败并拒绝 Promise
$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) {
    echo "另一个 Promise 被拒绝，原因为: " . $reason . PHP_EOL;
});
$anotherPromise->reject('Something went wrong!');
// 输出: 另一个 Promise 被拒绝，原因为: Something went wrong!

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步: " . $value . PHP_EOL;
        // 返回一个新值，这个值会传递给下一个 then
        return $value . " World!";
    })
    ->then(function ($value) {
        echo "第二步: " . $value . PHP_EOL;
        // 也可以返回一个新的 Promise，下一个 then 会等待这个新 Promise 完成
        $nestedPromise = new Promise();
        echo "正在等待嵌套 Promise..." . PHP_EOL;
        // 模拟一个异步操作，1秒后兑现
        // 在实际的异步应用中，你会在这里启动一个非阻塞的操作，例如一个异步HTTP请求
        \GuzzleHttp\Promise\Utils::queue()->add(function() use ($nestedPromise) {
            // 注意：sleep() 是阻塞的，仅为演示目的
            // 实际异步操作会是非阻塞的，例如基于事件循环的网络请求
            sleep(1);
            $nestedPromise->resolve(' And Guzzle!');
        });
        return $nestedPromise;
    })
    ->then(function ($value) {
        echo "第三步: " . $value . PHP_EOL;
        // 如果这里抛出异常，会被下一个 then 的 onRejected 捕获
        // throw new \Exception("Oh no!");
        return "全部完成！";
    })
    ->otherwise(function (\Throwable $reason) { // 捕获链中任何地方的拒绝或异常
        echo "Promise 链中发生错误: " . $reason->getMessage() . PHP_EOL;
    })
    ->then(function ($finalResult) {
        echo "最终结果: " . $finalResult . PHP_EOL;
    });

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

// 注意：在纯异步场景中，你需要一个事件循环来驱动 Promise 的解决
// Guzzle Promises 内部有一个任务队列，可以在同步等待时自动运行
// 但在没有同步等待的纯异步环境中（例如与 ReactPHP 结合），你需要手动运行它
// \GuzzleHttp\Promise\Utils::queue()->run(); // 如果没有同步等待，需要手动运行队列

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，然后兑现 Promise
    sleep(2); // 实际应用中避免在主线程使用 sleep，这会阻塞
    $promise->resolve('Data from a long operation');
});

echo "开始等待 Promise..." . PHP_EOL;
$result = $promise->wait(); // 会阻塞当前执行，直到 Promise 完成
echo "Promise 结果: " . $result . PHP_EOL;
// 输出:
// 开始等待 Promise...
// Promise 结果: Data from a long operation

use GuzzleHttp\Promise\Promise;

$promise = new Promise(
    function () use (&$promise) {
        // 这个函数会在 wait() 被调用时执行，用于解决 Promise
        // 但如果 promise 在此之前被取消，则不会执行
        echo "Promise 的 wait 函数被调用..." . PHP_EOL;
        $promise->resolve('Operation completed.');
    },
    function () {
        // 这是取消函数，当 promise->cancel() 被调用时执行
        echo "Promise 已被取消！" . PHP_EOL;
        // 在这里执行清理操作，例如关闭连接，停止计算
    }
);

// 模拟在 Promise 完成前取消
echo "尝试取消 Promise..." . PHP_EOL;
$promise->cancel();

// 尝试等待已取消的 Promise 会抛出异常
try {
    $promise->wait();
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "等待已取消的 Promise 抛出异常: " . $e->getMessage() . PHP_EOL;
}
// 输出:
// 尝试取消 Promise...
// Promise 已被取消！
// 等待已取消的 Promise 抛出异常: The promise was rejected with value: The promise was cancelled