如何解决PHP异步编程的“回调地狱”和性能瓶颈？使用Composer和GuzzlePromises优化你的应用！

guzzlehttp/promises

guzzlehttp/promises

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

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

then()

then()

$onFulfilled

$onRejected

then()

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：接收到值 - " . $value . "\n";
        // 返回一个新值，传递给下一个 then
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        echo "第二步：处理新值 - " . $value . "\n";
        // 再次返回一个 Promise，后续的 then 将等待这个 Promise 完成
        $anotherPromise = new Promise();
        // 模拟异步操作
        // $anotherPromise->resolve('World!'); // 稍后会 resolve
        return $anotherPromise;
    })
    ->then(function ($value) {
        echo "第三步：最终结果 - " . $value . "\n";
    }, function ($reason) {
        echo "操作失败： " . $reason . "\n";
    });

// 触发第一个 Promise 的解决
$promise->resolve('reader');

// 假设第二个 Promise 在某个时刻被解决了
// 可以在其他地方或者通过 Event Loop 来触发
// 为了演示，这里手动触发
// $anotherPromise->resolve('World!'); // 如果在第二个 then 内部返回了 $anotherPromise，则需要外部来 resolve 它
// 注意：在实际异步场景中，第二个 then 返回的 Promise 会由其异步操作自动解决
// 在这里，为了演示，我们假设 $anotherPromise 最终会被解决
// 如果上面的 $anotherPromise 被返回，且没有被 resolve，那么第三个 then 不会执行。
// 为了代码可运行，我们直接在第一个 then 内部返回一个值，或者让第二个 then 返回的 Promise 立即解决
// 修正示例，让链式调用更直观：
$promise2 = new Promise();
$promise2
    ->then(function ($value) {
        echo "第一步：接收到值 - " . $value . "\n";
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        echo "第二步：处理新值 - " . $value . "\n";
        // 返回一个新的 Promise，后续的 then 会等待它解决
        $nextPromise = new Promise();
        // 模拟一个异步操作，比如2秒后解决
        // 这里只是为了演示，实际中可能是网络请求等
        // 在一个真实的异步环境中，你可能会用一个调度器来延迟 resolve
        // 例如：$loop->addTimer(2, function() use ($nextPromise) { $nextPromise->resolve('World!'); });
        $nextPromise->resolve('World!'); // 立即解决，方便演示
        return $nextPromise;
    })
    ->then(function ($value) {
        echo "第三步：最终结果 - " . $value . "\n"; // 输出：第三步：最终结果 - World!
    })
    ->otherwise(function ($reason) { // 使用 otherwise 捕获链中任何拒绝
        echo "链中发生错误： " . $reason . "\n";
    });

echo "\n--- 触发 Promise 链 ---\n";
$promise2->resolve('reader'); // 启动整个链
// 期望输出：
// --- 触发 Promise 链 ---
// 第一步：接收到值 - reader
// 第二步：处理新值 - Hello, reader
// 第三步：最终结果 - World!

guzzlehttp/promises

guzzlehttp/promises

wait()

cancel()

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

$promiseWithWait = new Promise(function () use (&$promiseWithWait) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1); // 暂停1秒
    $promiseWithWait->resolve('Data fetched successfully!');
});

echo "开始等待 Promise...\n";
$result = $promiseWithWait->wait(); // 会阻塞1秒
echo "Promise 完成，结果是：" . $result . "\n"; // 输出：Data fetched successfully!

// 演示取消
$cancelablePromise = new Promise(
    function () use (&$cancelablePromise) {
        // 这个函数在 wait() 被调用时执行
        // 模拟一个长时间运行的任务，但这里我们不调用 resolve 或 reject
        // 这样它会保持 pending 状态，直到被取消或超时
        // 实际中这里可能是一个网络请求，等待响应
    },
    function () {
        echo "Promise 被取消了！\n";
        // 在这里执行清理操作，例如关闭连接
    }
);

// 尝试在 Promise 完成前取消它
$cancelablePromise->cancel();
// 如果没有调用 wait()，cancel() 可能会立即触发取消回调
// 如果调用了 wait()，且 waitFn 中没有 resolve/reject，cancel() 也会生效
// 实际中，cancel() 通常用于中断正在进行的异步操作

guzzlehttp/promises

guzzlehttp/promises