如何优雅地处理PHP异步操作？GuzzlePromises助你告别“回调地狱”！

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

<pre class="brush:php;toolbar:false">use GuzzleHttpPromisePromise; use GuzzleHttpPromiseUtils; // 用于运行队列  $promise = new Promise();  $promise     ->then(function ($value) {         echo "第一步完成，获得值: " . $value . "n";         // 返回一个新的值，传递给下一个then         return "处理后的 " . $value;     })     ->then(function ($newValue) {         echo "第二步完成，获得新值: " . $newValue . "n";         // 也可以返回一个Promise，实现异步操作的串联         $anotherPromise = new Promise();         // 假设这里模拟一个耗时操作，例如网络请求，并在未来某个时刻解决它         // $anotherPromise->resolve('最终数据'); // 实际中会在异步操作完成后调用         return $anotherPromise; // 返回一个Promise     })     ->then(function ($finalData) {         echo "所有异步操作完成，最终数据: " . $finalData . "n";     })     ->otherwise(function ($reason) { // 捕获链中任何环节的错误         echo "操作失败: " . $reason . "n";     });  // 模拟异步操作开始 $promise->resolve('原始数据');  // 注意：在实际的异步环境中（例如使用ReactPHP事件循环）， // 你需要定期运行Guzzle Promises的任务队列，以便Promise能够被解决。 // 例如： // $loop = ReactEventLoopFactory::create(); // $loop->addPeriodicTimer(0, [Utils::queue(), 'run']); // $loop->run();  // 为了演示，我们在这里手动解决第二个Promise // 在实际应用中，这会由异步操作的完成触发 $promise->then(function($value) use ($promise) {     // 假设第二个then返回的Promise是这个$promise的内部状态     // 这里仅为演示，实际应由异步操作本身解决     if ($value === "处理后的 原始数据") {         // 找到由第二个then返回的那个Promise，并解决它         // 这部分逻辑在真实异步场景中由Promise的实际创建者处理         // 为了演示，我们假设它会被解决         // 实际应用中，你不会直接在这里控制链中的Promise         // 而是让异步操作本身去resolve它     } });  // 在同步上下文演示，需要手动触发队列运行，确保所有Promise被处理 // 否则，如果第二个Promise没有被resolve，最后一个then不会执行 // 在没有事件循环的情况下，wait()会自动运行队列 // $promise->wait(false); // 确保Promise被解决，但不强制获取值 // 如果第二个then返回的Promise没有被外部resolve，那么最终的then不会执行 // 这是一个Promise链的复杂性，需要理解其异步本质。

<pre class="brush:php;toolbar:false">use GuzzleHttpPromisePromise;  $promise = new Promise(function () use (&$promise) {     // 模拟一个耗时操作，最终解决Promise     sleep(1); // 暂停1秒     $promise->resolve('这是异步操作的结果'); });  echo "开始等待异步操作...n"; $result = $promise->wait(); // 会阻塞当前进程直到Promise被解决 echo "异步操作完成，结果是: " . $result . "n";

then

<pre class="brush:php;toolbar:false">use GuzzleHttpPromisePromise; use GuzzleHttpPromiseUtils;  $promise = new Promise();  $promise     ->then(function ($value) {         echo "第一步: " . $value . "n";         // 模拟一个错误发生         throw new Exception("第一步发生错误！");         return "成功"; // 这行不会执行     })     ->then(function ($value) {         echo "第二步: " . $value . "n"; // 这行不会执行     })     ->otherwise(function (Throwable $reason) {         echo "捕获到错误: " . $reason->getMessage() . "n";     });  $promise->resolve('初始数据'); // 在没有事件循环的情况下，需要运行队列来处理Promise的解析 Utils::queue()->run();