如何使用Composer解决PHP异步操作的痛点，用GuzzlePromises提升应用响应速度

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

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

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于同步等待所有Promise完成

echo "开始执行异步操作...\n";

// 创建一个Promise，模拟一个耗时2秒的操作
$promise = new Promise(function () use (&$promise) {
    echo "模拟API请求中...\n";
    sleep(2); // 模拟耗时操作
    $promise->resolve('API数据已获取！'); // 操作成功，解决Promise
});

// 注册Promise成功时的回调
$promise->then(function ($value) {
    echo "Promise 成功回调: " . $value . "\n";
}, function ($reason) {
    echo "Promise 失败回调: " . $reason . "\n";
});

echo "异步操作已启动，程序继续执行其他任务...\n";

// 在实际应用中，你可能不会立即调用wait()，而是让事件循环处理
// 但为了演示，我们在这里同步等待Promise完成
// Utils::queue()->run(); // 如果在事件循环中，需要运行队列
$promise->wait(); // 强制同步等待Promise完成

echo "所有操作完成。\n";

?>

<pre class="brush:php;toolbar:false;">开始执行异步操作...
异步操作已启动，程序继续执行其他任务...
模拟API请求中...
Promise 成功回调: API数据已获取！
所有操作完成。

“异步操作已启动，程序继续执行其他任务...”

$promise->wait()

guzzlehttp/promises

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 模拟第一个异步操作：获取用户ID
$getUserPromise = new Promise(function ($resolve) {
    echo "正在获取用户ID...\n";
    sleep(1);
    $resolve(123); // 假设用户ID是123
});

// 模拟第二个异步操作：根据用户ID获取订单列表
$getOrdersPromise = $getUserPromise->then(function ($userId) {
    return new Promise(function ($resolve, $reject) use ($userId) {
        echo "根据用户ID {$userId} 获取订单列表...\n";
        sleep(1.5);
        if ($userId === 123) {
            $resolve(['OrderA', 'OrderB', 'OrderC']);
        } else {
            $reject('用户ID无效');
        }
    });
});

// 模拟第三个异步操作：处理订单列表并返回摘要
$processOrdersPromise = $getOrdersPromise->then(function ($orders) {
    echo "正在处理订单列表...\n";
    sleep(0.5);
    return "用户共有 " . count($orders) . " 笔订单。";
});

// 最终处理结果或捕获错误
$processOrdersPromise->then(function ($summary) {
    echo "最终结果: " . $summary . "\n";
}, function ($reason) {
    echo "操作失败: " . $reason . "\n";
});

echo "所有Promise已启动，等待结果...\n";

// 运行队列以确保所有Promise被处理
GuzzleHttp\Promise\Utils::queue()->run();

echo "程序执行完毕。\n";

?>

then()

then()

guzzlehttp/promises