解决PHP异步操作的性能瓶颈：GuzzlePromises让你的应用飞起来！

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

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

$promise = new Promise();

$promise->then(
    function ($value) {
        echo "Promise 成功兑现，值是: " . $value . "\n";
    },
    function ($reason) {
        echo "Promise 被拒绝，原因是: " . $reason . "\n";
    }
);

// 模拟异步操作完成，并兑现 Promise
$promise->resolve('用户数据'); // 这会触发 onFulfilled 回调，输出 "Promise 成功兑现，值是: 用户数据"

// 如果是失败
// $promise->reject('API 调用失败'); // 这会触发 onRejected 回调

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于 all() 方法

// 模拟异步函数，返回一个 Promise
function fetchUserDataAsync(): Promise
{
    $promise = new Promise();
    // 模拟网络延迟
    // 实际应用中这里会是 GuzzleHttp\Client::getAsync() 等
    Utils::queue()->add(function () use ($promise) {
        usleep(500000); // 500ms
        $promise->resolve('获取到用户数据');
    });
    return $promise;
}

function fetchOrderDataAsync(): Promise
{
    $promise = new Promise();
    Utils::queue()->add(function () use ($promise) {
        usleep(800000); // 800ms
        $promise->resolve('获取到订单数据');
    });
    return $promise;
}

function fetchRecommendationDataAsync(): Promise
{
    $promise = new Promise();
    Utils::queue()->add(function () use ($promise) {
        usleep(600000); // 600ms
        $promise->resolve('获取到推荐数据');
    });
    return $promise;
}

$start = microtime(true);

$promises = [
    'user' => fetchUserDataAsync(),
    'order' => fetchOrderDataAsync(),
    'recommendation' => fetchRecommendationDataAsync(),
];

// 使用 Utils::all() 等待所有 Promise 完成
Utils::all($promises)->then(
    function (array $results) use ($start) {
        echo "所有数据获取完成！\n";
        echo "用户数据: " . $results['user'] . "\n";
        echo "订单数据: " . $results['order'] . "\n";
        echo "推荐数据: " . $results['recommendation'] . "\n";
        echo "总耗时: " . (microtime(true) - $start) . " 秒\n";
    },
    function ($reason) use ($start) {
        echo "有 Promise 被拒绝，原因是: " . $reason . "\n";
        echo "总耗时: " . (microtime(true) - $start) . " 秒\n";
    }
)->wait(); // 重要的：在非事件循环环境下，需要调用 wait() 来强制 Promise 完成并执行回调

// 注意：在实际的事件循环（如 ReactPHP）环境中，你会在事件循环的每个tick中运行任务队列：
// $loop = React\EventLoop\Factory::create();
// $loop->addPeriodicTimer(0, [GuzzleHttp\Promise\Utils::queue(), 'run']);
// 然后就不需要手动调用 wait() 了

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步成功: " . $value . "\n";
        // 模拟一个失败的操作
        return new RejectedPromise('第一步失败了！');
    })
    ->then(function ($value) {
        echo "第二步成功: " . $value . "\n"; // 这不会被执行
        return '第二步结果';
    })
    ->otherwise(function ($reason) { // 捕获链中的任何拒绝
        echo "捕获到错误: " . $reason . "\n";
        return '错误已处理，返回一个默认值'; // 错误处理后，链条可以恢复成功状态
    })
    ->then(function ($value) {
        echo "第三步成功 (错误已恢复): " . $value . "\n";
    })
    ->wait();

$promise->resolve('初始值'); // 启动 Promise 链