如何解决PHP异步操作的“回调地狱”？GuzzlePromises与Composer助你构建优雅的并发流

<code class="bash">composer require guzzlehttp/promises</code>

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

$promise = new Promise();

// 假设这是一个异步操作...
// 模拟成功
$promise->resolve('操作成功！');

// 模拟失败
// $promise->reject(new \Exception('操作失败！'));

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

$promise = new Promise();

$promise
    ->then(
        function ($value) {
            echo "第一步成功: " . $value . "\n";
            // 返回一个新值，会传递给下一个 then
            return "处理后的值：" . $value;
        },
        function ($reason) {
            echo "第一步失败: " . $reason->getMessage() . "\n";
            // 抛出异常或返回 RejectedPromise 会使链条中断或转为拒绝状态
            throw $reason;
        }
    )
    ->then(
        function ($value) {
            echo "第二步成功: " . $value . "\n";
            // 可以在这里返回另一个 Promise，实现 Promise 转发
            // return someOtherAsyncOperation();
        },
        function ($reason) {
            echo "第二步失败: " . $reason->getMessage() . "\n";
        }
    );

// 解决 Promise，触发链式调用
$promise->resolve('原始数据');
// 输出:
// 第一步成功: 原始数据
// 第二步成功: 处理后的值：原始数据

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

$promiseA = new Promise();
$promiseB = new Promise();

$promiseA
    ->then(function ($value) use ($promiseB) {
        echo "Promise A 完成: " . $value . "\n";
        // 返回 Promise B，后续链条会等待 Promise B 完成
        return $promiseB;
    })
    ->then(function ($value) {
        echo "Promise B 完成并被接收: " . $value . "\n";
    });

$promiseA->resolve('来自 A 的数据'); // 触发 promiseA 的第一个 then
// 此时，promiseB 尚未解决，第二个 then 不会执行

$promiseB->resolve('来自 B 的数据'); // 解决 promiseB，触发 promiseA 的第二个 then
// 输出:
// Promise A 完成: 来自 A 的数据
// Promise B 完成并被接收: 来自 B 的数据

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "操作成功: " . $value . "\n";
    })
    ->otherwise(function (\Throwable $reason) { // 捕获任何异常或拒绝原因
        echo "操作失败: " . $reason->getMessage() . "\n";
    });

$promise->reject(new \Exception('网络连接超时'));
// 输出: 操作失败: 网络连接超时

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

$promise = new Promise(function (callable $resolve) {
    echo "模拟耗时操作...\n";
    sleep(1); // 模拟阻塞 1 秒
    $resolve('耗时操作完成！');
});

echo "等待 Promise 完成...\n";
$result = $promise->wait(); // 会阻塞当前线程直到 Promise 完成
echo "Promise 结果: " . $result . "\n";
// 输出:
// 等待 Promise 完成...
// 模拟耗时操作...
// Promise 结果: 耗时操作完成！

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于 all() 等聚合方法

// 模拟一个返回 Promise 的异步 HTTP 请求
function simulateHttpRequest(string $serviceName, int $delayMs, bool $shouldSucceed = true): Promise
{
    return new Promise(function (callable $resolve, callable $reject) use ($serviceName, $delayMs, $shouldSucceed) {
        // 在真实场景中，这里会是 GuzzleHttp\Client 发起的请求，它本身就返回 Promise
        echo "[{$serviceName}] 正在发起请求... (模拟延迟 {$delayMs}ms)\n";

        // 模拟网络延迟和结果
        // 注意：这里的 usleep 是阻塞的，真正的非阻塞异步需要结合事件循环库（如 ReactPHP, AmPHP）
        // 但这里主要是为了演示 Promise 的链式和聚合处理
        usleep($delayMs * 1000); 

        if ($shouldSucceed) {
            $resolve("{$serviceName} 数据获取成功！");
        } else {
            $reject(new \Exception("{$serviceName} 请求失败！"));
        }
    });
}

echo "--- 开始模拟并发 HTTP 请求 ---\n";

$request1 = simulateHttpRequest('服务 A', 800, true);
$request2 = simulateHttpRequest('服务 B', 500, false); // 模拟失败
$request3 = simulateHttpRequest('服务 C', 1200, true);

// 使用 GuzzleHttp\Promise\Utils::all() 等待所有 Promise 完成
// all() 会返回一个新的 Promise，当所有子 Promise 都成功时，它才成功；
// 只要有一个子 Promise 失败，它就失败。
$allRequestsPromise = Utils::all([$request1, $request2, $request3]);

$allRequestsPromise
    ->then(function (array $results) {
        echo "\n--- 所有请求均成功！---\n";
        foreach ($results as $index => $result) {
            echo "请求 " . ($index + 1) . " 结果: " . $result . "\n";
        }
        return "所有数据已处理完毕。";
    })
    ->otherwise(function (\Throwable $reason) {
        echo "\n--- 至少一个请求失败！---\n";
        echo "失败原因: " . $reason->getMessage() . "\n";
        return "部分请求失败，但流程继续。"; // 错误处理后可以返回一个值，使后续链条继续
    })
    ->then(function ($finalStatus) {
        echo "\n最终状态: " . $finalStatus . "\n";
    });

// 重要的步骤：运行任务队列，确保 Promise 能够被解析
// 对于上述模拟，由于 usleep 是阻塞的，wait() 会自动运行任务队列
// 但在真正的异步环境（如事件循环）中，你需要手动调用 Utils::queue()->run()
// 这里为了演示，我们等待最终的 Promise 完成
$allRequestsPromise->wait(); 

echo "--- 模拟并发 HTTP 请求结束 ---\n";