如何解决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()

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

Promise

fulfilled

rejected

pending

<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise;  // 创建一个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 GuzzleHttpPromisePromise;  $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('原始数据'); // 输出： // 第一步：接收到 原始数据 // 第二步：接收到 原始数据，处理完成。 // 最终结果：原始数据，处理完成。

<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise;  $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 完成，结果是: 数据已准备好！

try-catch

reject()

onFulfilled

onRejected

<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise; use GuzzleHttpPromiseRejectedPromise;  $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/guzzle

GuzzleHttpPromiseUtils::all()

<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise; use GuzzleHttpPromiseUtils;  // 模拟三个异步操作，每个返回一个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;