告别回调地狱：GuzzlePromises如何优雅处理PHP异步操作

<pre class="brush:php;toolbar:false;">$data1 = callServiceA(); // 等待服务A响应
$data2 = callServiceB(); // 等待服务B响应
$data3 = callServiceC(); // 等待服务C响应

// 处理并组合数据
processData($data1, $data2, $data3);

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;

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

// 使用 then() 方法注册回调函数
// 第一个参数是成功时的回调 (onFulfilled)
// 第二个参数是失败时的回调 (onRejected)
$promise->then(
    function ($value) {
        // 当 Promise 成功时执行
        echo 'Promise 已成功，值为: ' . $value . PHP_EOL;
        return "Hello, " . $value; // 返回一个新值，传递给链中的下一个 then
    },
    function ($reason) {
        // 当 Promise 失败时执行
        echo 'Promise 已失败，原因为: ' . $reason . PHP_EOL;
    }
)
->then(function ($value) {
    // 这个 then 会接收到上一个 then 的返回值
    echo "链式调用成功，新值为: " . $value . PHP_EOL;
});

// 模拟异步操作完成，并成功解决 Promise
echo "正在解决 Promise..." . PHP_EOL;
$promise->resolve('reader.'); // 这会触发 onFulfilled 回调

echo "-------------------" . PHP_EOL;

// 另一个 Promise 示例，演示拒绝
$rejectedPromise = new Promise();
$rejectedPromise->then(
    null, // 不处理成功情况
    function ($reason) {
        echo '被拒绝的 Promise 已失败，原因为: ' . $reason . PHP_EOL;
    }
);

echo "正在拒绝 Promise..." . PHP_EOL;
$rejectedPromise->reject('Something went wrong!'); // 这会触发 onRejected 回调

// 同步等待 Promise 完成 (在实际异步场景中，通常与事件循环结合使用)
// $promise->wait();
// $rejectedPromise->wait(); // 如果不捕获异常，这里会抛出 RejectionException

<pre class="brush:php;toolbar:false;">正在解决 Promise...
Promise 已成功，值为: reader.
链式调用成功，新值为: Hello, reader.
-------------------
正在拒绝 Promise...
被拒绝的 Promise 已失败，原因为: Something went wrong!

guzzlehttp/promises

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

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 提供了 all(), settle() 等辅助函数

// 模拟异步函数，返回一个 Promise
function fetchServiceData(string $serviceName, int $delay, bool $shouldFail = false): Promise
{
    $promise = new Promise();
    // 实际项目中，这里会是发起 cURL 请求或数据库查询等异步操作
    // 简单模拟延迟和成功/失败
    echo "开始请求 {$serviceName}..." . PHP_EOL;

    // 在实际的异步场景中，你需要一个事件循环来驱动这些 Promise
    // 这里我们只是模拟，并最终通过 resolve/reject 来完成 Promise
    // 假设在 $delay 秒后完成操作
    if ($shouldFail) {
        // 模拟失败
        $promise->reject(new \Exception("{$serviceName} 请求失败！"));
    } else {
        // 模拟成功
        $promise->resolve("{$serviceName} 的数据");
    }

    return $promise;
}

// 同时发起三个模拟请求
$promise1 = fetchServiceData('服务A', 2);
$promise2 = fetchServiceData('服务B', 1, true); // 模拟服务B失败
$promise3 = fetchServiceData('服务C', 3);

// 使用 Utils::all() 等待所有 Promise 完成
// all() 会在所有 Promise 都成功时才成功，只要有一个失败，它就失败
$allPromises = Utils::all([$promise1, $promise2, $promise3]);

$allPromises->then(
    function (array $results) {
        echo "所有服务数据获取成功！" . PHP_EOL;
        print_r($results);
    },
    function ($reason) {
        echo "有服务请求失败！原因：" . $reason->getMessage() . PHP_EOL;
    }
);

// 由于 PHP 默认是同步的，为了让 Promise 的回调被触发，
// 你需要运行任务队列或者同步等待 Promise 完成。
// 在实际的事件循环环境中 (如 ReactPHP, Amphp)，这通常由事件循环自动处理。
// 这里我们使用 wait() 强制同步等待，这会阻塞程序直到 Promise 完成。
try {
    $allPromises->wait();
} catch (\Exception $e) {
    // wait() 会抛出异常，所以需要捕获
    echo "Wait 过程中捕获到异常: " . $e->getMessage() . PHP_EOL;
}

echo "程序执行完毕。" . PHP_EOL;

Utils::all()

guzzlehttp/promises

guzzlehttp/promises