如何解决PHP异步操作的性能瓶颈？GuzzlePromises助你实现非阻塞编程！

<pre class="brush:php;toolbar:false;">// 伪代码示例，实际会更复杂
$stockResult = call_stock_api($order); // 等待库存API响应
$emailResult = send_confirmation_email($order); // 等待邮件发送服务响应
$logisticsResult = create_logistics_order($order); // 等待物流API响应

// ... 处理结果

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

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

// 创建一个Promise对象
$promise = new Promise();

// 注册回调函数：当Promise成功时执行$onFulfilled，失败时执行$onRejected
$promise->then(
    function ($value) {
        echo "Promise成功了，值是: " . $value . "\n";
    },
    function ($reason) {
        echo "Promise失败了，原因是: " . $reason . "\n";
    }
);

// 在某个时机，我们手动解决（fulfill）这个Promise
// 比如，一个耗时操作完成后，我们得到了结果
$promise->resolve('订单处理成功！');
// 输出: Promise成功了，值是: 订单处理成功！

// 如果操作失败
$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) {
    echo "另一个Promise失败了，原因是: " . $reason . "\n";
});
$anotherPromise->reject('库存不足！');
// 输出: 另一个Promise失败了，原因是: 库存不足！

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

$firstPromise = new Promise();

$firstPromise
    ->then(function ($orderId) {
        echo "1. 订单 {$orderId} 已创建，开始扣减库存...\n";
        // 假设扣减库存是另一个异步操作，这里返回一个新Promise
        return new Promise(function ($resolve) use ($orderId) {
            // 模拟异步操作
            sleep(1);
            $resolve("库存已扣减，订单ID: {$orderId}");
        });
    })
    ->then(function ($message) {
        echo "2. {$message}，开始发送确认邮件...\n";
        return new Promise(function ($resolve) use ($message) {
            sleep(0.5);
            $resolve("邮件已发送，基于: {$message}");
        });
    })
    ->then(function ($finalMessage) {
        echo "3. {$finalMessage}，所有操作完成！\n";
        return '最终结果：全部成功';
    })
    ->then(function ($result) {
        echo "最终回调接收到: " . $result . "\n";
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的错误
        echo "操作失败，原因: " . $reason . "\n";
    });

// 触发第一个Promise的解决
$firstPromise->resolve('ORD12345');

// 注意：在异步环境中，需要一个事件循环来驱动Promise的执行。
// 如果是同步脚本，你可以使用 `wait()` 方法强制等待结果。
// 但这里为了演示链式，我们假设在一个非阻塞环境中。
// 如果在命令行运行，你可能需要手动运行任务队列或使用 `wait()`
// GuzzleHttp\Promise\Utils::queue()->run();

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

$apiCallPromise = new Promise(function ($resolve, $reject) {
    // 模拟一个耗时的API调用，可能成功也可能失败
    if (rand(0, 1)) {
        sleep(2);
        $resolve('API数据加载成功！');
    } else {
        sleep(1);
        $reject('API请求超时或失败！');
    }
});

try {
    echo "开始等待API结果...\n";
    $result = $apiCallPromise->wait(); // 阻塞等待，直到Promise完成
    echo "同步等待结果: " . $result . "\n";
} catch (RejectionException $e) {
    echo "同步等待中捕获到错误: " . $e->getReason() . "\n";
} catch (\Exception $e) {
    echo "捕获到其他异常: " . $e->getMessage() . "\n";
}