告别阻塞！如何使用Composer和GuzzlePromises优雅处理PHP异步操作

<code class="php">// 伪代码：同步调用多个API
$weatherData = call_weather_api(); // 阻塞，等待天气API响应
$stockData = call_stock_api();   // 阻塞，等待股票API响应
$userData = call_user_api();     // 阻塞，等待用户API响应

// 所有数据都到齐后才能处理和展示
process_and_display($weatherData, $stockData, $userData);</code>

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

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise->then(
    // $onFulfilled: 成功时执行
    function ($value) {
        echo "操作成功，得到值: " . $value . PHP_EOL;
    },
    // $onRejected: 失败时执行
    function ($reason) {
        echo "操作失败，原因: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作成功，解决 Promise
$promise->resolve('这是异步操作的结果');
// 输出: 操作成功，得到值: 这是异步操作的结果

// 模拟异步操作失败，拒绝 Promise
// $promise->reject('API 调用超时');
// 输出: 操作失败，原因: API 调用超时</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();
$promise
    ->then(function ($value) {
        // 第一个 then 接收初始值 'reader.'
        echo "第一步处理: " . $value . PHP_EOL;
        // 返回一个新值，传递给下一个 then
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        // 第二个 then 接收上一个 then 返回的值 "Hello, reader."
        echo "第二步处理: " . $value . PHP_EOL;
        // 返回一个新 Promise，后续链条会等待这个 Promise 解决
        $nextPromise = new Promise();
        // 模拟一个异步操作
        // $nextPromise->resolve('并完成了后续任务！');
        return $nextPromise;
    })
    ->then(function ($value) {
        // 只有当第二个 then 返回的 $nextPromise 解决后，这个 then 才会执行
        echo "最终结果: " . $value . PHP_EOL;
    });

// 解决初始 Promise，触发链式调用
$promise->resolve('reader.');

// 模拟第二个 then 中返回的 Promise 解决
// 假设这是某个异步任务完成的信号
// $nextPromise->resolve('并完成了后续任务！'); // 这行代码需要在第二个 then 的作用域内才能生效，这里仅作概念说明

// 为了演示链式传递，我们简化一下，不返回新的 Promise，直接返回普通值
$simplifiedPromise = new Promise();
$simplifiedPromise
    ->then(function ($value) {
        return "第一步处理: " . $value . " -> ";
    })
    ->then(function ($value) {
        return $value . "第二步处理: 完成!";
    })
    ->then(function ($value) {
        echo $value . PHP_EOL;
    });

$simplifiedPromise->resolve('初始数据');
// 输出: 第一步处理: 初始数据 -> 第二步处理: 完成!</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$asyncOperation = new Promise(function () use (&$asyncOperation) {
    // 模拟一个耗时操作，例如：从数据库读取数据
    sleep(1); // 暂停1秒
    $asyncOperation->resolve('数据库查询结果');
});

echo "开始等待异步操作..." . PHP_EOL;
$result = $asyncOperation->wait(); // 阻塞当前脚本直到 Promise 解决
echo "异步操作完成，结果是: " . $result . PHP_EOL;</code>