PHP异步编程的利器：如何使用GuzzlePromises解决高并发与性能瓶颈

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;

// 模拟一个异步操作，比如调用一个外部 API
function simulateAsyncOperation(string $name, int $delayMs): Promise
{
    $promise = new Promise();

    // 在实际应用中，这里会启动一个非阻塞的 I/O 操作
    // 为了演示，我们用一个微小的延迟来模拟
    // 实际的异步通常会依赖事件循环或非阻塞 I/O 驱动
    \React\EventLoop\Factory::create()->addTimer($delayMs / 1000, function () use ($promise, $name) {
        if (rand(0, 1)) { // 随机成功或失败
            $promise->resolve("Hello from {$name}!");
        } else {
            $promise->reject(new Exception("Error from {$name}!"));
        }
    });

    return $promise;
}

// 创建一个 Promise 实例
$myPromise = new Promise();

// 注册成功和失败的回调
$myPromise->then(
    // $onFulfilled: 成功时执行
    function ($value) {
        echo "Promise 成功：{$value}\n";
        return "Processed: " . $value; // 返回值会传递给下一个 then
    },
    // $onRejected: 失败时执行
    function ($reason) {
        echo "Promise 失败：{$reason->getMessage()}\n";
        // 可以在这里处理错误，或者重新抛出
        throw $reason;
    }
)->then(
    // 链式调用：上一个 then 的返回值会作为当前 then 的输入
    function ($processedValue) {
        echo "再次处理：{$processedValue}\n";
    },
    function ($reason) {
        echo "链式调用中捕获到错误：{$reason->getMessage()}\n";
    }
);

// 模拟异步操作完成，解决 Promise
echo "开始模拟异步操作...\n";
$myPromise->resolve('reader.'); // 这会触发 $onFulfilled 回调

echo "---------------------------------\n";

// 另一个例子：Promise 链式调用和转发
$promiseA = new Promise();
$promiseB = new Promise();

$promiseA
    ->then(function ($value) use ($promiseB) {
        echo "Promise A 成功：{$value}\n";
        return $promiseB; // 返回另一个 Promise，链式调用会等待 promiseB 完成
    })
    ->then(function ($value) {
        echo "Promise B 成功（通过 A 转发）：{$value}\n";
    });

echo "解决 Promise A...\n";
$promiseA->resolve('Data from A');
echo "解决 Promise B...\n";
$promiseB->resolve('Data from B'); // 这会触发第二个 then

echo "---------------------------------\n";

// 拒绝 Promise
$errorPromise = new Promise();
$errorPromise->then(null, function ($reason) {
    echo "捕获到拒绝：{$reason}\n";
});
$errorPromise->reject('Something went wrong!'); // 触发 $onRejected 回调

// 同步等待 (wait)
// 尽管 Promise 主要是为了异步，但有时你需要强制等待结果
$waitPromise = new Promise(function () use (&$waitPromise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1);
    $waitPromise->resolve('Data from wait function');
});

echo "同步等待 Promise...\n";
echo "结果: " . $waitPromise->wait() . "\n"; // 这会阻塞直到 Promise 解决

// 你也可以通过 Utils::all() 等方法同时等待多个 Promise
// GuzzleHttp\Promise\Utils::all([
//     simulateAsyncOperation('API 1', 100),
//     simulateAsyncOperation('API 2', 150),
// ])->then(function ($results) {
//     echo "所有 API 调用都成功了！\n";
//     print_r($results);
// }, function ($reason) {
//     echo "至少一个 API 调用失败了：{$reason->getMessage()}\n";
// })->wait(); // 在主进程结束前等待所有 Promise 完成

guzzlehttp/promises

guzzlehttp/promises