如何解决PHP应用中慢速的API调用？使用GuzzlePromises助你实现高性能异步编程

<pre class="brush:php;toolbar:false;">// 伪代码，模拟同步请求
$userData = fetchUserDataFromUserService(); // 等待用户服务响应
$orderData = fetchOrderDataFromOrderService(); // 等待订单服务响应
$recommendations = fetchRecommendationsFromRecommendationService(); // 等待推荐服务响应

// ... 合并并处理数据 ...

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

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

// 创建一个Promise对象
$promise = new Promise(function () use (&$promise) {
    // 这个匿名函数被称为“等待函数” (waitFn)，
    // 它定义了Promise如何被解决（resolve）或拒绝（reject）。
    // 在实际应用中，这里会发起一个真正的异步操作，
    // 例如一个非阻塞的网络请求或文件读取。
    echo "异步操作已启动...\n";
    // 模拟一个2秒的耗时操作
    // 注意：这里的 sleep() 仍然是阻塞的，仅为演示Promise的最终解决。
    // 真正的异步I/O会是非阻塞的。
    // usleep(2000000); // 真实的异步操作不会阻塞当前线程

    // 假设异步操作成功完成，并返回数据
    $promise->resolve('这是异步操作的结果！');
    // 如果操作失败，则调用 $promise->reject('失败原因');
});

echo "主程序继续执行，无需等待异步操作立即完成。\n";

// 此时 $promise 处于 pending 状态。
// 如果需要立即获取结果（会阻塞），可以使用 wait() 方法。
// 但通常我们更倾向于使用 then() 注册回调。
// try {
//     $result = $promise->wait(); // 这会阻塞，直到Promise解决
//     echo "通过 wait() 获取到结果： " . $result . "\n";
// } catch (\Exception $e) {
//     echo "通过 wait() 捕获到错误： " . $e->getMessage() . "\n";
// }

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

$asyncTask = new Promise();

$asyncTask->then(
    function ($value) {
        echo "成功回调：异步操作完成，得到数据： " . $value . "\n";
        return "数据已处理：" . $value; // 返回值会传递给下一个 then
    },
    function ($reason) {
        echo "失败回调：异步操作失败，原因： " . $reason . "\n";
        throw new \RuntimeException("处理失败：" . $reason); // 抛出异常会使链条进入拒绝状态
    }
);

// 模拟异步操作成功完成
$asyncTask->resolve('用户数据加载完成');
// 或者模拟异步操作失败
// $asyncTask->reject('数据库连接失败');

// 在纯异步环境中，这些回调会在事件循环中被触发。
// 为了让上面的 resolve/reject 立即触发 then()，
// 我们可以使用 GuzzleHttp\Promise\Utils::queue()->run();
// 但在简单的脚本中，手动 resolve/reject 即可观察效果。

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

$initialDataPromise = new Promise();

$initialDataPromise
    ->then(function ($data) {
        echo "第一步：获取到原始数据 - " . $data . "\n";
        // 假设这里发起第二个异步操作（例如，根据用户ID获取订单）
        $orderPromise = new Promise();
        // 模拟订单获取成功
        $orderPromise->resolve("用户ID: {$data} 的订单列表");
        return $orderPromise; // 返回一个新Promise，链条会等待它解决
    })
    ->then(function ($orders) {
        echo "第二步：获取到订单数据 - " . $orders . "\n";
        // 假设这里发起第三个异步操作（例如，根据订单获取推荐商品）
        $recommendationPromise = new Promise();
        // 模拟推荐获取成功
        $recommendationPromise->resolve("基于订单 {$orders} 的推荐商品");
        return $recommendationPromise;
    })
    ->then(function ($recommendations) {
        echo "第三步：获取到推荐数据 - " . $recommendations . "\n";
        echo "所有异步操作链式完成！\n";
    })
    ->otherwise(function ($reason) { // 使用 otherwise() 统一处理链中任何环节的拒绝
        echo "操作链中途失败： " . $reason . "\n";
    });

// 启动第一个Promise，模拟用户数据加载完成
$initialDataPromise->resolve('user_123');

// 如果在事件循环中运行，需要调用队列来处理回调
// GuzzleHttp\Promise\Utils::queue()->run();

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

$errorPronePromise = new Promise();

$errorPronePromise
    ->then(function ($value) {
        echo "成功： " . $value . "\n";
        // 即使在成功回调中，也可以返回一个 RejectedPromise 来中断链条并进入错误处理
        return new RejectedPromise('在成功处理中发现逻辑错误！');
    })
    ->otherwise(function ($reason) { // 捕获上一个 then 或原始 Promise 的拒绝
        echo "捕获到错误1： " . $reason . "\n";
        // 如果这里不抛出异常或返回 RejectedPromise，链条会恢复到成功状态
        return "错误已被处理，继续执行...";
    })
    ->then(function ($value) {
        echo "错误处理后继续成功： " . $value . "\n";
    }, function ($reason) {
        echo "捕获到错误2： " . $reason . "\n";
    });

// 模拟原始Promise被拒绝
// $errorPronePromise->reject('原始API请求失败');

// 模拟原始Promise成功，但后续处理中出现错误
$errorPronePromise->resolve('原始数据');

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Utils;
// 假设你有一个事件循环 $loop (例如 React\EventLoop\LoopInterface)
// $loop->addPeriodicTimer(0.001, [Utils::queue(), 'run']);
// 这会确保 Promise 的内部任务队列在事件循环中持续运行，处理所有待定的回调。