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

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

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;
use GuzzleHttp\Promise\Utils; // 用于运行任务队列

// 步骤1: 模拟一个异步操作，例如从外部API获取用户ID
function getUserIdAsync(bool $shouldSucceed = true): Promise
{
    $promise = new Promise();
    // 在真实场景中，这里会发起一个非阻塞的I/O请求
    // 为了演示，我们用一个简单的延迟和随机成功/失败来模拟
    echo "【开始】获取用户ID...\n";
    if ($shouldSucceed) {
        // 模拟成功，几毫秒后解决Promise
        // 在实际应用中，这可能是HTTP请求成功的回调
        Utils::queue()->add(function () use ($promise) {
            echo "【完成】用户ID获取成功: 123\n";
            $promise->resolve(123);
        });
    } else {
        // 模拟失败
        Utils::queue()->add(function () use ($promise) {
            echo "【失败】用户ID获取失败: 网络错误\n";
            $promise->reject("网络连接失败");
        });
    }
    return $promise;
}

// 步骤2: 模拟获取用户详情
function getUserDetailsAsync(int $userId): Promise
{
    $promise = new Promise();
    echo "【开始】获取用户ID {$userId} 的详情...\n";
    if ($userId === 123) {
        Utils::queue()->add(function () use ($promise, $userId) {
            echo "【完成】用户ID {$userId} 详情获取成功\n";
            $promise->resolve("用户{$userId}的详细信息：姓名-张三，邮箱-zhangsan@example.com");
        });
    } else {
        Utils::queue()->add(function () use ($promise, $userId) {
            echo "【失败】用户ID {$userId} 详情获取失败: 用户不存在\n";
            $promise->reject("用户ID {$userId} 不存在");
        });
    }
    return $promise;
}

// 步骤3: 模拟处理用户详情
function processUserDetailsAsync(string $userDetails): Promise
{
    $promise = new Promise();
    echo "【开始】处理用户详情...\n";
    Utils::queue()->add(function () use ($promise, $userDetails) {
        echo "【完成】用户详情处理成功\n";
        $promise->resolve("最终处理结果：{$userDetails} 已录入系统。");
    });
    return $promise;
}

// 构建Promise链
$mainPromise = getUserIdAsync(true) // 尝试 true 或 false 模拟不同结果
    ->then(function ($userId) {
        return getUserDetailsAsync($userId); // 返回一个新的Promise，实现链式异步
    })
    ->then(function ($userDetails) {
        return processUserDetailsAsync($userDetails); // 继续链式调用
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的拒绝
        echo "【错误】整个流程中发生错误: " . $reason . "\n";
        // 可以在这里进行错误恢复或返回一个默认值
        return "流程中断，返回默认失败消息。";
    });

// 在CLI脚本中，我们需要手动运行任务队列来确保所有then回调被执行
// 在GuzzleHttp\Client等库的异步请求中，通常会集成事件循环或在wait()时自动运行
Utils::queue()->run();

// 最终，我们可以同步等待整个Promise链的结果
// 注意：wait()会阻塞，但在Web请求生命周期结束前，这通常是必要的
try {
    $finalResult = $mainPromise->wait();
    echo "【最终结果】流程结束: " . $finalResult . "\n";
} catch (Exception $e) {
    echo "【致命错误】流程最终失败: " . $e->getMessage() . "\n";
}
</code>