如何告别PHP异步编程中的“回调地狱”，并使用GuzzlePromises构建高效应用

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

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 第一个异步操作成功，处理结果并返回一个新的值或Promise
        echo "第一步完成，收到值: " . $value . "\n";
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        // 第二个异步操作在第一个完成后执行，接收上一步的返回值
        echo "第二步完成，收到值: " . $value . "\n";
        // 这里可以返回另一个Promise，实现更复杂的链式
        return strtoupper($value);
    })
    ->then(function ($value) {
        echo "第三步完成，最终结果: " . $value . "\n";
    });

// 解决Promise，触发链式回调
$promise->resolve('reader.');
// 输出:
// 第一步完成，收到值: reader.
// 第二步完成，收到值: Hello, reader.
// 第三步完成，最终结果: HELLO, READER.

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "尝试执行...\n";
        throw new \Exception("Something went wrong!"); // 抛出异常
        return "Success: " . $value;
    })
    ->then(
        function ($value) {
            echo "这一步不会执行\n";
        },
        function ($reason) {
            // 捕获上一步抛出的异常
            echo "Promise 被拒绝了，原因: " . $reason->getMessage() . "\n";
            // 可以在这里返回一个值，使后续链条恢复正常
            return "Error handled gracefully.";
        }
    )
    ->then(function ($value) {
        echo "错误处理后，继续执行: " . $value . "\n";
    });

$promise->resolve('data');
// 输出:
// 尝试执行...
// Promise 被拒绝了，原因: Something went wrong!
// 错误处理后，继续执行: Error handled gracefully.

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作
    sleep(1);
    $promise->resolve('Data fetched!');
});

echo "开始等待...\n";
echo $promise->wait() . "\n"; // 会阻塞1秒，然后输出 "Data fetched!"
echo "等待结束。\n";

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Utils;
use React\EventLoop\Factory;

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

// 模拟一个异步操作
$promise = new Promise(function ($resolve) use ($loop) {
    $loop->addTimer(2, function () use ($resolve) {
        $resolve('Async task completed after 2 seconds!');
    });
});

$promise->then(function ($value) {
    echo $value . "\n";
    $loop->stop(); // 任务完成后停止事件循环
});

// 在事件循环的每个tick中运行Guzzle Promises的任务队列
$loop->addPeriodicTimer(0.01, [$queue, 'run']);

$loop->run();
echo "事件循环已停止。\n";