告别漫长等待：如何使用Composer和GuzzlePromises优化PHP异步操作，让你的应用飞起来！

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

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 创建一个Promise对象
$promise = new Promise();

echo "1. 程序开始执行...\n";

// 模拟一个异步操作，比如网络请求或文件读写
// 实际场景中，这里不会立即 resolve/reject，而是等到异步操作完成后
// 比如在HTTP请求的回调中，或者定时器中
$delay = 2; // 模拟2秒的延迟
echo "2. 模拟耗时操作，等待 {$delay} 秒...\n";
// 在真实世界中，这部分会是非阻塞的，例如使用ReactPHP或Swoole的协程
// 这里为了演示Promise概念，我们用sleep来模拟耗时，但请注意sleep是阻塞的
// 真正的异步场景下，主程序不会被sleep阻塞
\Swoole\Coroutine::create(function() use ($promise, $delay) {
    \Co::sleep($delay); // 协程非阻塞睡眠
    // 假设操作成功，解决 Promise
    $promise->resolve('异步操作成功完成！');
});


// 注册 Promise 的成功和失败回调
$promise->then(
    function ($value) {
        echo "4. Promise 成功回调被触发，结果是: " . $value . "\n";
    },
    function ($reason) {
        echo "4. Promise 失败回调被触发，原因是: " . $reason . "\n";
    }
);

echo "3. 主程序继续执行其他任务，不等待异步操作...\n";

// 强制等待 Promise 完成，并运行任务队列
// 在异步框架（如ReactPHP、Swoole）中，你通常不需要手动调用 wait()，
// 而是通过事件循环来处理 Promise 的解决。
// 这里是为了演示在同步环境下的效果。
// $promise->wait(); // 这一行在协程环境下可能不需要，取决于具体框架集成

// 如果在非协程环境下，我们需要手动运行 Promise 任务队列来确保回调被执行
// GuzzleHttp\Promise\Utils::queue()->run();

// 由于我们使用了 Swoole 协程，Promise 的 resolve 会在协程结束后触发
// 如果主程序在此处结束，可能看不到回调。
// 我们可以通过一个简单的阻塞确保主程序等待
// 但更好的做法是让整个应用运行在协程或事件循环中
// 例如，在一个简单的脚本中，我们可以模拟一个短暂的等待
\Co::sleep(3); // 确保有足够时间让协程完成并触发回调

echo "5. 程序执行完毕。\n";

<pre class="brush:php;toolbar:false;">1. 程序开始执行...
2. 模拟耗时操作，等待 2 秒...
3. 主程序继续执行其他任务，不等待异步操作...
// (等待2秒后)
4. Promise 成功回调被触发，结果是: 异步操作成功完成！
5. 程序执行完毕。

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

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

function asyncOperation(string $taskName, int $delay, bool $shouldFail = false): Promise
{
    $promise = new Promise();
    \Swoole\Coroutine::create(function() use ($promise, $taskName, $delay, $shouldFail) {
        echo "[{$taskName}] 任务开始，等待 {$delay} 秒...\n";
        \Co::sleep($delay);
        if ($shouldFail) {
            echo "[{$taskName}] 任务失败！\n";
            $promise->reject(new \Exception("任务 {$taskName} 失败！"));
        } else {
            echo "[{$taskName}] 任务完成！\n";
            $promise->resolve("{$taskName} 的结果");
        }
    });
    return $promise;
}

echo "主程序开始...\n";

// 链式调用：任务1 -> 任务2 -> 任务3
asyncOperation('任务A', 1)
    ->then(function ($resultA) {
        echo "处理 {$resultA}...\n";
        // 返回一个新的Promise，继续下一个异步操作
        return asyncOperation('任务B', 2);
    })
    ->then(function ($resultB) {
        echo "处理 {$resultB}...\n";
        // 返回一个普通的php值，会被包装成已解决的Promise
        return "最终结果：{$resultB} + 额外处理";
    })
    ->then(function ($finalResult) {
        echo "所有任务完成，最终结果是: {$finalResult}\n";
    })
    ->otherwise(function (\Throwable $e) { // 捕获链中任何环节的错误
        echo "链中发生错误: " . $e->getMessage() . "\n";
    });

echo "主程序继续执行其他事情，不等待异步链...\n";

// 确保主程序等待足够长的时间让所有协程完成
\Co::sleep(5); 

echo "主程序结束。\n";

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    echo "Wait函数被调用，开始异步计算...\n";
    \Co::sleep(1); // 模拟耗时
    $promise->resolve('通过 wait 获取的值');
});

echo "主程序：发起异步操作。\n";
echo "主程序：执行其他任务...\n";

// 假设在这里我必须拿到异步操作的结果才能继续
echo "主程序：现在我必须等待异步操作完成...\n";
$value = $promise->wait(); // 会阻塞当前进程直到Promise解决
echo "主程序：成功获取到值: " . $value . "\n";

echo "主程序：继续执行。\n";