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

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('数据已加载！'); // 输出：Promise 成功：数据已加载！
// 或者 $promise->reject('加载失败！'); // 会触发 $onRejected 回调

use GuzzleHttp\Promise\Promise;

$initialPromise = new Promise();

$initialPromise
    ->then(function ($value) {
        // 第一个操作成功后，返回一个新的值，传递给下一个 then
        echo "第一步完成，接收到: " . $value . PHP_EOL;
        return "处理后的 " . $value;
    })
    ->then(function ($newValue) {
        // 第二个操作，接收到上一个 then 返回的值
        echo "第二步完成，接收到: " . $newValue . PHP_EOL;
        // 如果这里返回一个 Promise，后续的 then 会等待这个 Promise 完成
        $anotherPromise = new Promise();
        $anotherPromise->resolve("最终数据");
        return $anotherPromise;
    })
    ->then(function ($finalValue) {
        // 最终的 then，接收到链中最后一个 Promise 的结果
        echo "所有步骤完成，最终结果: " . $finalValue . PHP_EOL;
    });

// 启动 Promise 链
$initialPromise->resolve('原始数据');

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 假设这里发生了错误，我们主动拒绝 Promise
        throw new \Exception('操作失败，抛出异常！');
    })
    ->otherwise(function (\Exception $e) {
        // 捕获上一个 then 中抛出的异常
        echo "捕获到错误: " . $e->getMessage() . PHP_EOL;
        // 可以在这里返回一个值，使链条恢复正常
        return "错误已处理，继续执行";
    })
    ->then(function ($value) {
        echo "链条继续，接收到: " . $value . PHP_EOL;
    });

$promise->resolve('开始');

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作
    sleep(1);
    $promise->resolve('数据已准备好！');
});

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 脚本会在这里阻塞，直到 Promise 完成
echo "等待结束，结果是: " . $result . PHP_EOL;

use GuzzleHttp\Promise\Utils;
use React\EventLoop\Factory;

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

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

// 在这里创建并使用你的 Guzzle Promises
// ...

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