如何解决PHP异步操作的复杂回调地狱与堆栈溢出？GuzzlePromises与Composer助你优雅驾驭异步编程

curl_multi

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

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

guzzlehttp/promises

guzzlehttp/promises

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

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

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

// 模拟异步操作完成，并解析Promise
$promise->resolve('数据已成功获取！');
// 输出: Promise 成功： 数据已成功获取！

// 也可以拒绝Promise
$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) {
    echo "另一个 Promise 失败： " . $reason . "\n";
});
$anotherPromise->reject('网络连接错误！');
// 输出: 另一个 Promise 失败： 网络连接错误！

then()

then()

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

$initialPromise = new Promise();

$initialPromise
    ->then(function ($data) {
        echo "第一步：处理数据 " . $data . "\n";
        // 返回一个新的值，传递给下一个 then
        return $data . " -> 进一步处理";
    })
    ->then(function ($processedData) {
        echo "第二步：再次处理 " . $processedData . "\n";
        // 假设这里又是一个异步操作，返回一个新的 Promise
        $nextStepPromise = new Promise();
        // 模拟1秒后完成
        \GuzzleHttp\Promise\Utils::queue()->add(function () use ($nextStepPromise) {
            $nextStepPromise->resolve($processedData . " -> 最终结果");
        }, 1);
        return $nextStepPromise; // 返回一个 Promise，后续链条会等待它完成
    })
    ->then(function ($finalResult) {
        echo "第三步：获取最终结果 " . $finalResult . "\n";
    })
    ->otherwise(function ($reason) { // 统一处理链条中任何环节的错误
        echo "操作失败： " . $reason . "\n";
    });

// 启动Promise链
$initialPromise->resolve('原始数据');

// 注意：在异步环境中，你可能需要运行事件循环来处理Promise队列
// 在Guzzle中，通常由Guzzle客户端内部管理，但如果独立使用，需要手动运行
\GuzzleHttp\Promise\Utils::queue()->run();

wait()

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

$networkCallPromise = new Promise(function () use (&$networkCallPromise) {
    // 模拟一个耗时2秒的网络请求
    sleep(2);
    $networkCallPromise->resolve('从远程API获取的数据');
});

echo "开始执行耗时操作...\n";
$result = $networkCallPromise->wait(); // 会阻塞直到Promise完成
echo "耗时操作完成，结果是：" . $result . "\n";

guzzlehttp/promises

guzzlehttp/promises