如何解决PHP异步操作的回调地狱？GuzzlePromises助你构建优雅的异步流程

<pre class="brush:php;toolbar:false;">getUserID(function ($userId) {     getUserDetails($userId, function ($userDetails) {         getOrders($userDetails['id'], function ($orders) use ($userDetails) {             $productDetails = [];             foreach ($orders as $order) {                 getProductDetails($order['productId'], function ($product) use (&$productDetails) {                     $productDetails[] = $product;                     // 如果这里是最后一个商品，才继续处理...                 });             }             // 嵌套到这里，代码已经很难看了，错误处理更是灾难             renderPage($userDetails, $orders, $productDetails);         });     }); }); // 错误处理？每个回调函数里都得写一遍吗？

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

$onFulfilled

$onRejected

GPTAgent

一个无代码创建AI应用程序的工具

47

查看详情

<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise;  $promise = new Promise();  $promise->then(     function ($value) {         echo '操作成功，得到值: ' . $value . "n";     },     function ($reason) {         echo '操作失败，原因: ' . $reason . "n";     } );  // 模拟异步操作成功 $promise->resolve('这是成功的结果'); // 输出：操作成功，得到值: 这是成功的结果  // 模拟异步操作失败 // $promise->reject('发生了一个错误'); // 输出：操作失败，原因: 发生了一个错误

<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise;  $promise = new Promise();  $promise     ->then(function ($value) {         echo "第一步：处理了 " . $value . "n";         return $value . "，并进入第二步"; // 返回的值会传递给下一个 then     })     ->then(function ($newValue) {         echo "第二步：处理了 " . $newValue . "n";         // 如果这里返回一个 Promise，下一个 then 会等待这个 Promise 完成         return new Promise(function ($resolve) use ($newValue) {             echo "模拟异步操作，延迟1秒...n";             sleep(1); // 模拟耗时操作             $resolve($newValue . "，最终完成！");         });     })     ->then(function ($finalValue) {         echo "第三步：最终结果是 " . $finalValue . "n";     })     ->otherwise(function ($reason) { // 统一处理链中任何环节的错误         echo "在任何一步发生错误: " . $reason . "n";     });  // 启动 Promise 链 $promise->resolve('初始数据');  // 注意：在非事件循环环境中，需要手动运行任务队列来处理 Promise // GuzzleHttpPromiseUtils::queue()->run();

reject

onFulfilled

onRejected

<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise; use GuzzleHttpPromiseRejectedPromise;  $promise = new Promise();  $promise     ->then(function ($value) {         echo "尝试处理: " . $value . "n";         // 模拟一个错误发生         if ($value === '错误数据') {             return new RejectedPromise('数据校验失败'); // 主动拒绝         }         return "处理成功: " . $value;     })     ->then(function ($successValue) {         echo "下一步处理成功数据: " . $successValue . "n";     })     ->otherwise(function ($reason) { // 捕获链中任何环节的错误         echo "捕获到错误: " . $reason . "n";     });  $promise->resolve('错误数据'); // 触发错误路径 // GuzzleHttpPromiseUtils::queue()->run(); // 如果在非事件循环环境

<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise;  $promise = new Promise(function () use (&$promise) {     echo "正在等待 Promise 完成...n";     sleep(2); // 模拟耗时     $promise->resolve('等待结束，获取到结果'); });  try {     $result = $promise->wait(); // 会阻塞直到 Promise 完成     echo "同步获取到结果: " . $result . "n"; } catch (Exception $e) {     echo "同步等待时发生错误: " . $e->getMessage() . "n"; }

<pre class="brush:php;toolbar:false;"><?php  require 'vendor/autoload.php';  use GuzzleHttpPromisePromise; use GuzzleHttpPromiseRejectedPromise; use GuzzleHttpPromiseUtils;  // 模拟异步函数，返回 Promise function fetchUserIdAsync(): Promise {     return new Promise(function ($resolve) {         echo "-> 正在获取用户ID...n";         sleep(1); // 模拟网络延迟         $resolve(123); // 假设获取到用户ID     }); }  function fetchUserDetailsAsync(int $userId): Promise {     return new Promise(function ($resolve, $reject) {         echo "-> 正在获取用户详情 (ID: {$userId})...n";         sleep(1); // 模拟网络延迟         if ($userId === 123) {             $resolve(['id' => $userId, 'name' => '张三', 'email' => 'zhangsan@example.com']);         } else {             $reject("用户ID {$userId} 不存在。");         }     }); }  function fetchOrdersAsync(int $userId): Promise {     return new Promise(function ($resolve) {         echo "-> 正在获取订单列表 (用户ID: {$userId})...n";         sleep(1); // 模拟网络延迟         $resolve([             ['orderId' => 'ORD001', 'productId' => 'PROD001', 'amount' => 100],             ['orderId' => 'ORD002', 'productId' => 'PROD002', 'amount' => 200],         ]);     }); }  function fetchProductDetailsAsync(string $productId): Promise {     return new Promise(function ($resolve) {         echo "-> 正在获取商品详情 (ID: {$productId})...n";         sleep(0.5); // 模拟网络延迟         $products = [             'PROD001' => ['name' => '商品A', 'price' => 100],             'PROD002' => ['name' => '商品B', 'price' => 200],         ];         $resolve($products[$productId] ?? null);     }); }  echo "开始处理用户页面数据...n";  fetchUserIdAsync()     ->then(function ($userId) {         return fetchUserDetailsAsync($userId); // 链式调用，返回下一个 Promise     })     ->then(function (array $userDetails) {         echo "用户详情获取成功: " . $userDetails['name'] . "n";         // 同时获取订单和处理商品详情，这里可以并发处理         return Utils::all([ // Utils::all 可以等待多个 Promise 完成             'userDetails' => $userDetails,             'orders' => fetchOrdersAsync($userDetails['id'])                 ->then(function (array $orders) {                     $productPromises = [];                     foreach ($orders as $order) {                         $productPromises[] = fetchProductDetailsAsync($order['productId'])                             ->then(function ($productDetail) use ($order) {                                 return array_merge($order, ['productDetail' => $productDetail]);                             });                     }                     return Utils::all($productPromises); // 等待所有商品详情获取完成                 })         ]);     })     ->then(function (array $data) {         $userDetails = $data['userDetails'];         $ordersWithProducts = $data['orders'];          echo "所有数据获取完成，开始渲染页面。n";         echo "用户: " . $userDetails['name'] . " (" . $userDetails['email'] . ")n";         echo "订单:n";         foreach ($ordersWithProducts as $order) {             echo "  - 订单号: {$order['orderId']}, 商品: {$order['productDetail']['name']}, 金额: {$order['amount']}n";         }     })     ->otherwise(function ($reason) {         echo "处理过程中发生错误: " . $reason . "n";     });  // 在非事件循环环境中，需要运行任务队列来确保 Promise 被处理 Utils::queue()->run();  echo "程序执行完毕。n";