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

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

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 模拟一个耗时操作，例如从数据库获取数据
function fetchDataAsync(): Promise
{
    $promise = new Promise();

    // 假设2秒后数据准备好
    // 在实际应用中，这里会是异步I/O操作的触发
    // 例如：异步HTTP请求、非阻塞数据库查询
    \React\EventLoop\Factory::create()->addTimer(2, function () use ($promise) {
        $data = ['id' => 1, 'name' => 'Async User'];
        echo "数据已准备好。\n";
        $promise->resolve($data); // 成功时解析Promise
    })->run(); // 运行事件循环，确保定时器被执行

    return $promise;
}

echo "开始请求数据...\n";
$promise = fetchDataAsync();

$promise->then(
    function ($value) {
        echo "Promise 成功解析，得到数据: " . json_encode($value) . "\n";
    },
    function ($reason) {
        echo "Promise 被拒绝，原因: " . $reason . "\n";
    }
);

// 在异步场景下，你需要一个事件循环来驱动Promise的解析
// Guzzle Promises 在同步等待时会自动运行其内部任务队列
// 但在纯异步场景下，你需要手动运行队列，或者与一个事件循环集成
// 比如：GuzzleHttp\Promise\Utils::queue()->run();
// 为了演示，我们在这里模拟一个同步等待，但在实际异步应用中，你不会直接wait
$promise->wait(); // 同步等待Promise完成，这会阻塞直到Promise解析
echo "程序继续执行。\n";</code>

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 模拟第一个异步操作
function step1(): Promise
{
    $promise = new Promise();
    \React\EventLoop\Factory::create()->addTimer(1, function () use ($promise) {
        echo "步骤1完成。\n";
        $promise->resolve('数据A');
    })->run();
    return $promise;
}

// 模拟第二个异步操作，依赖于第一个操作的结果
function step2(string $input): Promise
{
    $promise = new Promise();
    \React\EventLoop\Factory::create()->addTimer(1.5, function () use ($promise, $input) {
        echo "步骤2完成，输入: " . $input . "\n";
        $promise->resolve($input . ' + 数据B');
    })->run();
    return $promise;
}

// 模拟第三个异步操作，可能失败
function step3(string $input): Promise
{
    $promise = new Promise();
    \React\EventLoop\Factory::create()->addTimer(0.5, function () use ($promise, $input) {
        if (rand(0, 1)) {
            echo "步骤3成功，输入: " . $input . "\n";
            $promise->resolve($input . ' + 数据C');
        } else {
            echo "步骤3失败。\n";
            $promise->reject('步骤3处理失败');
        }
    })->run();
    return $promise;
}

echo "开始执行链式异步操作...\n";

step1()
    ->then(function ($dataFromStep1) {
        echo "进入步骤2...\n";
        return step2($dataFromStep1); // 返回一个新的Promise，链条会等待它完成
    })
    ->then(function ($dataFromStep2) {
        echo "进入步骤3...\n";
        return step3($dataFromStep2);
    })
    ->then(function ($finalData) {
        echo "所有步骤成功完成，最终结果: " . $finalData . "\n";
    })
    ->otherwise(function ($reason) { // 统一捕获链中任何环节的错误
        echo "操作链中出现错误: " . $reason . "\n";
    })
    ->wait(); // 同步等待整个链条完成

echo "整个异步操作链已完成或失败。\n";</code>