如何高效处理PHP中的异步操作？GuzzlePromises助你告别阻塞等待！

<pre class="brush:php;toolbar:false;"><?php
// 模拟耗时操作
function fetchUserData($userId) {
    echo "开始获取用户数据...\n";
    sleep(1); // 模拟网络延迟和处理时间
    echo "用户数据获取完成。\n";
    return ['id' => $userId, 'name' => 'John Doe'];
}

function fetchUserOrders($userId) {
    echo "开始获取用户订单...\n";
    sleep(1.5); // 模拟更长的延迟
    echo "用户订单获取完成。\n";
    return ['order1', 'order2'];
}

function fetchRecommendations($userId) {
    echo "开始获取商品推荐...\n";
    sleep(0.8); // 模拟较短的延迟
    echo "商品推荐获取完成。\n";
    return ['itemA', 'itemB'];
}

// 假设用户ID为123
$userId = 123;

$start = microtime(true);

$userData = fetchUserData($userId);
$userOrders = fetchUserOrders($userId);
$recommendations = fetchRecommendations($userId);

echo "所有数据已获取！\n";
printf("总耗时: %.2f 秒\n", microtime(true) - $start);

// 后续渲染页面...
?>

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

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

$promise = new Promise();

// 注册回调函数
$promise->then(
    function ($value) {
        echo "Promise成功兑现，值是: " . $value . "\n";
    },
    function ($reason) {
        echo "Promise破裂，原因是: " . $reason . "\n";
    }
);

// 模拟异步操作在某个时刻完成
// $promise->resolve('这是异步操作的结果！'); // 成功
$promise->reject('哦豁，异步操作失败了！'); // 失败
?>

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php'; // 引入Composer自动加载

use GuzzleHttp\Promise;
use GuzzleHttp\Promise\Promise as GuzzlePromise; // 避免与全局Promise函数冲突

// 模拟耗时操作，现在它们返回Promise
function getPromiseForUserData($userId): GuzzlePromise
{
    return new GuzzlePromise(function () use (&$promise, $userId) {
        echo "开始获取用户数据 (异步)...\n";
        usleep(1000000); // 1秒 = 1000000微秒
        echo "用户数据获取完成 (异步)。\n";
        $promise->resolve(['id' => $userId, 'name' => 'John Doe']);
    });
}

function getPromiseForUserOrders($userId): GuzzlePromise
{
    return new GuzzlePromise(function () use (&$promise, $userId) {
        echo "开始获取用户订单 (异步)...\n";
        usleep(1500000); // 1.5秒
        echo "用户订单获取完成 (异步)。\n";
        $promise->resolve(['order1', 'order2']);
    });
}

function getPromiseForRecommendations($userId): GuzzlePromise
{
    return new GuzzlePromise(function () use (&$promise, $userId) {
        echo "开始获取商品推荐 (异步)...\n";
        usleep(800000); // 0.8秒
        echo "商品推荐获取完成 (异步)。\n";
        $promise->resolve(['itemA', 'itemB']);
    });
}

$userId = 123;
$start = microtime(true);

// 同时发起所有异步操作，并获取它们的Promise
$promiseUserData = getPromiseForUserData($userId);
$promiseUserOrders = getPromiseForUserOrders($userId);
$promiseRecommendations = getPromiseForRecommendations($userId);

// 使用 Promise\Utils::all() 等待所有Promise完成
$allPromises = Promise\Utils::all([
    'userData' => $promiseUserData,
    'userOrders' => $promiseUserOrders,
    'recommendations' => $promiseRecommendations,
]);

try {
    // wait() 方法会阻塞，直到所有Promise完成。
    // 关键在于，它会并行等待，总耗时由最慢的Promise决定。
    $results = $allPromises->wait();

    echo "所有数据已获取！\n";
    printf("总耗时: %.2f 秒\n", microtime(true) - $start);

    echo "用户数据: " . json_encode($results['userData']) . "\n";
    echo "用户订单: " . json_encode($results['userOrders']) . "\n";
    echo "商品推荐: " . json_encode($results['recommendations']) . "\n";

} catch (\Exception $e) {
    echo "至少一个异步操作失败: " . $e->getMessage() . "\n";
}

// 注意：在实际的异步环境中（如ReactPHP事件循环），你不会直接调用 wait()
// 而是将这些 Promise 挂载到事件循环中，让其在后台执行。
// 如果你真的需要同步等待，wait() 是一个方便的工具。
?>

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

$failingPromise = new Promise(function () use (&$failingPromise) {
    echo "模拟一个失败的异步操作...\n";
    usleep(500000);
    $failingPromise->reject(new \Exception('API服务暂时不可用！'));
});

$failingPromise
    ->then(function ($value) {
        echo "成功获取到值: " . $value . "\n";
    })
    ->otherwise(function (\Exception $e) { // otherwise() 专门用于捕获拒绝
        echo "捕获到错误: " . $e->getMessage() . "\n";
        // 可以在这里进行错误恢复或日志记录
        return "默认数据"; // 返回一个值，使后续链条转为成功
    })
    ->then(function ($value) {
        echo "错误处理后，继续处理: " . $value . "\n";
    });

// 同步等待，以便看到输出
try {
    $failingPromise->wait();
} catch (\Exception $e) {
    // 如果 otherwise 没有捕获并返回，wait() 会抛出异常
    echo "wait() 捕获到未处理的异常: " . $e->getMessage() . "\n";
}
?>