如何解决PHP异步编程的“等待”困境，使用Composer和GuzzlePromises助你构建高性能应用！

<pre class="brush:php;toolbar:false;">// 伪代码，同步执行
$weatherData = call_weather_api(); // 等待天气API响应
$stockData = call_stock_api();   // 等待股票API响应
$newsData = call_news_api();     // 等待新闻API响应

// 处理并展示所有数据
display_data($weatherData, $stockData, $newsData);

call_xxx_api()

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

guzzlehttp/promises

Promise

fulfilled

rejected

pending

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

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

// 注册成功和失败的回调
$promise->then(
    // $onFulfilled: 当Promise成功时执行
    function ($value) {
        echo 'Promise 成功完成，值为: ' . $value . PHP_EOL;
    },
    // $onRejected: 当Promise失败时执行
    function ($reason) {
        echo 'Promise 失败，原因为: ' . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成并成功
$promise->resolve('Hello, World!'); // 输出：Promise 成功完成，值为: Hello, World!

// 模拟异步操作完成并失败
$promise2 = new Promise();
$promise2->then(null, function ($reason) {
    echo 'Promise 2 失败，原因为: ' . $reason . PHP_EOL;
});
$promise2->reject('Something went wrong!'); // 输出：Promise 2 失败，原因为: Something went wrong!

then()

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

$promise = new Promise();
$promise
    ->then(function ($value) {
        echo "第一步：接收到 " . $value . PHP_EOL;
        return $value . "，处理完成。"; // 返回值会传递给下一个then
    })
    ->then(function ($newValue) {
        echo "第二步：接收到 " . $newValue . PHP_EOL;
        return "最终结果：" . $newValue;
    })
    ->then(function ($finalResult) {
        echo $finalResult . PHP_EOL;
    });

// 解决Promise，触发链式调用
$promise->resolve('原始数据');
// 输出：
// 第一步：接收到 原始数据
// 第二步：接收到 原始数据，处理完成。
// 最终结果：原始数据，处理完成。

then

then

wait()

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

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

echo "开始等待Promise..." . PHP_EOL;
$result = $promise->wait(); // 会阻塞当前执行，直到Promise完成
echo "Promise 完成，结果是: " . $result . PHP_EOL;
// 输出：
// 开始等待Promise...
// Promise 完成，结果是: 数据已准备好！

wait()

try-catch

reject()

onFulfilled

onRejected

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

$promise = new Promise();
$promise
    ->then(function ($value) {
        echo "成功: " . $value . PHP_EOL;
        throw new \Exception("处理中发生错误！"); // 抛出异常
    })
    ->then(null, function ($reason) { // 捕获上一步的异常
        echo "捕获到错误: " . $reason->getMessage() . PHP_EOL;
        return new RejectedPromise("进一步的错误处理"); // 返回一个拒绝的Promise，继续向下传递拒绝状态
    })
    ->then(null, function ($finalReason) {
        echo "最终错误处理: " . $finalReason . PHP_EOL;
    });

$promise->resolve('初始值');
// 输出：
// 成功: 初始值
// 捕获到错误: 处理中发生错误！
// 最终错误处理: 进一步的错误处理

guzzlehttp/promises

guzzlehttp/guzzle

GuzzleHttp\Promise\Utils::all()

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

// 模拟三个异步操作，每个返回一个Promise
function fetchWeatherData() {
    return new Promise(function ($resolve) {
        echo "正在获取天气数据..." . PHP_EOL;
        sleep(2); // 模拟耗时
        $resolve('晴天，25度');
    });
}

function fetchStockData() {
    return new Promise(function ($resolve) {
        echo "正在获取股票数据..." . PHP_EOL;
        sleep(1); // 模拟耗时
        $resolve('AAPL: 180.50');
    });
}

function fetchNewsData() {
    return new Promise(function ($resolve) {
        echo "正在获取新闻数据..." . PHP_EOL;
        sleep(3); // 模拟耗时
        $resolve('科技头条：AI新突破');
    });
}

echo "所有异步任务开始..." . PHP_EOL;

// 创建Promise数组
$promises = [
    'weather' => fetchWeatherData(),
    'stock'   => fetchStockData(),
    'news'    => fetchNewsData(),
];

// 等待所有Promise完成
Utils::all($promises)
    ->then(function ($results) {
        echo "所有数据已获取！" . PHP_EOL;
        print_r($results);
    })
    ->otherwise(function ($reason) { // 捕获任何一个Promise的失败
        echo "有任务失败了: " . $reason . PHP_EOL;
    })
    ->wait(); // 阻塞主线程直到所有Promise完成

echo "程序执行完毕。" . PHP_EOL;

guzzlehttp/promises