告别阻塞！如何使用Composer与GuzzlePromises优化PHP异步操作

可以通过一下地址学习composer：学习地址

告别阻塞：PHP异步操作的困境与Guzzle Promises的救赎

在现代web应用开发中，php作为后端语言，经常需要与各种外部服务（如第三方api、数据库、消息队列等）进行交互。想象一下，你的电商网站需要在用户下单后，同时调用支付接口、发送邮件通知、更新库存、并记录日志。如果这些操作都是同步执行的，那么用户将不得不漫长地等待所有步骤完成，才能看到“下单成功”的提示。这不仅大大降低了用户体验，也浪费了服务器资源，因为大部分时间都花在了“等待”上。

传统的PHP脚本是阻塞的，这意味着当一个函数（比如一个网络请求）被调用时，脚本会暂停执行，直到该函数返回结果。如果我们需要并行处理多个耗时任务，或者希望在等待某个操作完成的同时，能够继续执行其他逻辑，这种同步模式就显得力不从心，很容易陷入“回调地狱”或导致脚本超时。

难道就没有一种方法，可以让我们在等待一个操作完成的同时，去处理其他事情吗？或者，能否同时发起多个请求，然后等待它们全部完成呢？答案是肯定的，而

guzzlehttp/promises

Composer：引入异步能力的基石

要使用

guzzlehttp/promises

打开你的项目根目录，在命令行中执行以下命令：

立即学习“PHP免费学习笔记（深入）”；

composer require guzzlehttp/promises

这条命令会自动下载

guzzlehttp/promises

vendor/

composer.json

composer.lock

安装完成后，你就可以在代码中通过 Composer 的自动加载器来使用

guzzlehttp/promises

Guzzle Promises：异步操作的魔法

guzzlehttp/promises

fulfilled

rejected

一个 Promise 拥有三种状态：

• pending (待定)：初始状态，既不是成功也不是失败。
• fulfilled (已成功)：操作成功完成。
• rejected (已失败)：操作失败。

1. Promise 的基本使用：

then()

方法

与 Promise 交互的主要方式是通过其

then()

Figma Slides

Figma Slides 是 Figma 发布的PPT制作和演示文稿生成工具，可以帮助创建、设计、定制和分享演示文稿

下载

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise->then(
    // $onFulfilled: 操作成功时调用
    function ($value) {
        echo "操作成功，结果是: " . $value . PHP_EOL;
    },
    // $onRejected: 操作失败时调用
    function ($reason) {
        echo "操作失败，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成并成功
$promise->resolve('数据已获取'); // 输出: 操作成功，结果是: 数据已获取

// 模拟异步操作完成并失败
// $promise->reject('网络错误'); // 输出: 操作失败，原因是: 网络错误

通过

resolve($value)

reject($reason)

2. Promise 链式调用：告别回调地狱

Promise 的强大之处在于其链式调用能力。每个

then()

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：处理数据 " . $value . PHP_EOL;
        return $value . " 处理完成"; // 返回值会传递给下一个 then
    })
    ->then(function ($value) {
        echo "第二步：进一步处理 " . $value . PHP_EOL;
        // 可以在这里返回一个新的 Promise，实现更复杂的异步流程
        $anotherPromise = new Promise();
        $anotherPromise->resolve('最终结果');
        return $anotherPromise;
    })
    ->then(function ($value) {
        echo "第三步：获取到最终结果 " . $value . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中任何一个环节的错误
        echo "链中发生错误：" . $reason . PHP_EOL;
    });

$promise->resolve('原始数据');
// 输出：
// 第一步：处理数据 原始数据
// 第二步：进一步处理 原始数据 处理完成
// 第三步：获取到最终结果 最终结果

这里的

otherwise()

then(null, $onRejected)

3. 同步等待：

wait()

方法

尽管 Promise 旨在处理异步，但有时你可能需要强制一个 Promise 立即完成并获取其结果（即阻塞当前执行流直到结果可用）。

wait()

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1);
    $promise->resolve('等待结果');
});

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 脚本会在这里阻塞1秒
echo "等待结束，结果是: " . $result . PHP_EOL; // 输出：等待结束，结果是: 等待结果

如果 Promise 被拒绝，

wait()

try-catch

4. 高级应用：并行处理多个请求

guzzlehttp/promises

 $client->getAsync('https://www.google.com/'),
    'bing' => $client->getAsync('https://www.bing.com/'),
    'example' => $client->getAsync('https://www.example.com/'),
];

echo "开始并行发送请求..." . PHP_EOL;

// 使用 Utils::all() 等待所有 Promise 完成
// 这会返回一个新的 Promise，当所有子 Promise 都成功时，它才会成功
// 如果任何一个子 Promise 失败，它就会失败
$results = Utils::all($promises)->wait();

echo "所有请求完成！" . PHP_EOL;

foreach ($results as $key => $response) {
    echo "请求 {$key} 的状态码: " . $response->getStatusCode() . PHP_EOL;
}

// 也可以使用 Utils::some() 来等待指定数量的 Promise 完成
// Utils::some(2, $promises)->wait(); // 等待其中任意2个完成

通过

GuzzleHttp\Promise\Utils::all($promises)->wait()

值得一提的是，

guzzlehttp/promises

总结与展望

guzzlehttp/promises

1. 提升性能： 通过非阻塞和并行处理耗时操作，显著缩短脚本执行时间。
2. 优化代码结构： 链式调用告别“回调地狱”，使异步逻辑更加清晰、易读和易于维护。
3. 统一错误处理： 通过

   reject()

   和

   otherwise()

   提供了一致的错误捕获机制。
4. 增强用户体验： 减少用户的等待时间，提升应用的响应速度和流畅度。

虽然PHP的运行环境与Node.js等原生异步语言有所不同，但

guzzlehttp/promises

guzzlehttp/promises