告别PHP阻塞等待：GuzzlePromises助你实现高效异步编程，优化复杂任务处理

<pre class="brush:php;toolbar:false;">// 伪代码
$userData = fetchUserDataFromApi(); // 耗时 500ms
$orderData = fetchOrderDataFromApi(); // 耗时 800ms
$stockData = fetchThirdPartyStockApi(); // 耗时 1200ms
$shippingData = fetchShippingStatusApi(); // 耗时 700ms

// 总耗时：500 + 800 + 1200 + 700 = 3200ms (3.2秒！)
// 然后处理数据并返回...

guzzlehttp/promises

guzzlehttp/promises

Promise

fulfilled

rejected

pending

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

guzzlehttp/promises

Promise

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

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

// 在某个异步操作完成后（这里我们用一个模拟的延迟来表示）
// 可以通过 resolve() 或 reject() 来改变 Promise 的状态
// 实际应用中，这会是网络请求完成后的回调
$someAsyncOperationFinished = function ($value) use ($promise) {
    // 模拟异步操作完成
    sleep(1); // 假设这里是网络请求耗时
    $promise->resolve("数据：" . $value);
};

// 立即触发异步操作（在实际应用中，这可能是发起一个非阻塞的HTTP请求）
$someAsyncOperationFinished('用户A');

echo "异步操作已启动，我不会被阻塞！\n";

then()

Promise

then()

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

$promise = new Promise();

$promise->then(
    function ($value) {
        echo "Promise 成功了！值是：{$value}\n";
        return $value . " (已处理)"; // 返回值会传递给下一个 then
    },
    function ($reason) {
        echo "Promise 失败了！原因是：{$reason}\n";
        // 可以在这里处理错误，或者重新抛出异常
        throw new \Exception("处理失败: " . $reason);
    }
)->then(
    function ($processedValue) {
        echo "链式调用：处理后的值是：{$processedValue}\n";
    },
    function (\Exception $e) {
        echo "链式调用中捕获到异常：{$e->getMessage()}\n";
    }
);

// 模拟异步操作成功
$promise->resolve('原始数据');
// 模拟异步操作失败
// $promise->reject('网络连接超时');

then()

GuzzleHttp\Promise\Utils::all()

guzzlehttp/promises

GuzzleHttp\Promise\Utils::all()

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

// 假设这些是 Guzzle HTTP 客户端发起的异步请求，它们会返回 Promise
// 这里我们用手动创建的 Promise 来模拟
$promiseUserData = new Promise(function () use (&$promiseUserData) {
    // 模拟 500ms 延迟获取用户数据
    usleep(500000);
    $promiseUserData->resolve(['id' => 1, 'name' => '张三']);
});

$promiseOrderData = new Promise(function () use (&$promiseOrderData) {
    // 模拟 800ms 延迟获取订单数据
    usleep(800000);
    $promiseOrderData->resolve(['orderId' => 'A123', 'amount' => 199.99]);
});

$promiseStockData = new Promise(function () use (&$promiseStockData) {
    // 模拟 1200ms 延迟获取库存数据
    usleep(1200000);
    // 假设这里模拟一个失败情况
    // $promiseStockData->reject('库存服务不可用');
    $promiseStockData->resolve(['productId' => 'P001', 'stock' => 100]);
});

$promiseShippingData = new Promise(function () use (&$promiseShippingData) {
    // 模拟 700ms 延迟获取物流数据
    usleep(700000);
    $promiseShippingData->resolve(['status' => '已发货', 'tracking' => 'SF12345']);
});

echo "所有异步请求已并行启动...\n";
$startTime = microtime(true);

// 使用 Promise\Utils::all() 等待所有 Promise 完成
Promise\Utils::all([
    'user' => $promiseUserData,
    'order' => $promiseOrderData,
    'stock' => $promiseStockData,
    'shipping' => $promiseShippingData,
])->then(
    function (array $results) use ($startTime) {
        $endTime = microtime(true);
        echo "所有数据已获取，总耗时：" . round($endTime - $startTime, 3) . " 秒\n";
        echo "用户数据: " . json_encode($results['user']) . "\n";
        echo "订单数据: " . json_encode($results['order']) . "\n";
        echo "库存数据: " . json_encode($results['stock']) . "\n";
        echo "物流数据: " . json_encode($results['shipping']) . "\n";
        // 在这里可以处理聚合数据，生成报告
    },
    function ($reason) use ($startTime) {
        $endTime = microtime(true);
        echo "某个Promise失败了！耗时：" . round($endTime - $startTime, 3) . " 秒\n";
        echo "失败原因：" . (string) $reason . "\n";
    }
)->wait(); // wait() 会阻塞当前进程，直到 Promise 完成。在Web应用中通常在最后调用。

echo "脚本执行完毕。\n";

wait()

wait()

wait()

guzzlehttp/promises

GuzzleHttp\Promise\Utils::queue()->run()

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises