如何高效处理PHP中的异步操作？GuzzlePromises助你实现非阻塞并发！

<code class="php">// 伪代码：顺序执行的API调用
$userData = fetchUserDataFromApi(); // 等待完成
$productData = fetchProductDataFromApi(); // 等待完成
$orderHistory = fetchOrderHistoryFromApi(); // 等待完成

// 处理数据...</code>

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

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise->then(
    // $onFulfilled：当Promise成功时执行
    function ($value) {
        echo '操作成功，结果是：' . $value . PHP_EOL;
    },
    // $onRejected：当Promise失败时执行
    function ($reason) {
        echo '操作失败，原因是：' . $reason . PHP_EOL;
    }
);

// 模拟异步操作成功
$promise->resolve('这是异步操作的结果！');
// 输出：操作成功，结果是：这是异步操作的结果！

// 模拟异步操作失败
// $promise->reject('出错了，无法完成操作！');
// 输出：操作失败，原因是：出错了，无法完成操作！</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();
$promise
    ->then(function ($value) {
        // 第一个then接收初始值
        echo "第一步：处理初始值 - " . $value . PHP_EOL;
        // 返回一个新值，传递给下一个then
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        // 第二个then接收上一个then的返回值
        echo "第二步：处理中间值 - " . $value . PHP_EOL;
        // 继续返回，或者返回一个Promise
        return $value . " World!";
    })
    ->then(function ($value) {
        // 第三个then接收最终值
        echo "第三步：最终结果 - " . $value . PHP_EOL;
    });

// 触发Promise链
$promise->resolve('reader.');
/*
输出：
第一步：处理初始值 - reader.
第二步：处理中间值 - Hello, reader.
第三步：最终结果 - Hello, reader. World!
*/</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决Promise
    sleep(1);
    $promise->resolve('数据已就绪');
});

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 会阻塞当前代码，直到Promise解决
echo "等待结束，结果是：" . $result . PHP_EOL;
// 输出：
// 开始等待...
// (等待1秒)
// 等待结束，结果是：数据已就绪</code>

<code class="php">use GuzzleHttp\Promise\Utils;
use React\EventLoop\Factory;

$loop = Factory::create();
// 获取全局任务队列
$queue = Utils::queue();

// 每隔0秒（即每个tick）运行任务队列
$loop->addPeriodicTimer(0, [$queue, 'run']);

// 你的异步代码...
// $loop->run(); // 启动事件循环</code>

<code class="php">use GuzzleHttp\Promise\Utils;
use GuzzleHttp\Client; // 通常与Guzzle Promises配合使用

$client = new Client();

$promises = [
    'user' => $client->getAsync('https://api.example.com/user/123'),
    'products' => $client->getAsync('https://api.example.com/products/top'),
    'orders' => $client->getAsync('https://api.example.com/user/123/orders'),
];

// 等待所有Promise完成
$results = Utils::settle($promises)->wait();

$userData = json_decode($results['user']['value']->getBody(), true);
$productData = json_decode($results['products']['value']->getBody(), true);
$orderHistory = json_decode($results['orders']['value']->getBody(), true);

// 现在你可以同时处理所有数据了！
echo "用户数据：" . json_encode($userData) . PHP_EOL;
echo "产品数据：" . json_encode($productData) . PHP_EOL;
echo "订单历史：" . json_encode($orderHistory) . PHP_EOL;</code>