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

// 伪代码：一个典型的回调地狱场景
fetchWeatherData(function($weatherData) {
    processWeatherData($weatherData, function($processedWeather) {
        fetchNewsData(function($newsData) use ($processedWeather) {
            processNewsData($newsData, function($processedNews) use ($processedWeather) {
                fetchStockData(function($stockData) use ($processedWeather, $processedNews) {
                    renderDashboard($processedWeather, $processedNews, $stockData);
                });
            });
        });
    });
});

composer require guzzlehttp/promises

<?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

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

// 注册成功和失败的回调
$promise->then(
    // $onFulfilled: 成功时执行
    function ($value) {
        echo "操作成功，结果是: " . $value . PHP_EOL;
    },
    // $onRejected: 失败时执行
    function ($reason) {
        echo "操作失败，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成：这里我们立即解析 Promise
// 在实际应用中，这通常在某个耗时操作（如网络请求）完成后调用
$promise->resolve('数据已成功获取');

// 模拟异步操作失败
// $promise->reject('API访问超时，请稍后再试');

<?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 模拟第一个异步操作：获取用户ID
$fetchUserIdPromise = new Promise();

// 模拟第二个异步操作：根据用户ID获取用户数据
$fetchUserDataPromise = new Promise();

// 模拟第三个异步操作：处理用户数据
$processUserDataPromise = new Promise();

$fetchUserIdPromise
    ->then(function ($userId) use ($fetchUserDataPromise) {
        echo "第一步：获取到用户ID: " . $userId . PHP_EOL;
        // 模拟根据ID获取用户数据的耗时操作
        // 实际中可能是一个HTTP请求
        if ($userId === 123) {
            $fetchUserDataPromise->resolve(['id' => $userId, 'name' => '张三', 'email' => 'zhangsan@example.com']);
        } else {
            $fetchUserDataPromise->reject('用户ID无效');
        }
        return $fetchUserDataPromise; // 返回一个新的 Promise，链式传递
    })
    ->then(function ($userData) use ($processUserDataPromise) {
        echo "第二步：获取到用户数据: " . json_encode($userData) . PHP_EOL;
        // 模拟处理用户数据
        $processedData = array_merge($userData, ['status' => 'active', 'last_login' => date('Y-m-d H:i:s')]);
        $processUserDataPromise->resolve($processedData);
        return $processUserDataPromise; // 继续链式传递
    })
    ->then(function ($finalData) {
        echo "第三步：用户数据处理完成: " . json_encode($finalData) . PHP_EOL;
        echo "所有操作已成功完成！" . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的错误
        echo "操作链中发生错误: " . $reason . PHP_EOL;
    });

// 启动第一个 Promise
$fetchUserIdPromise->resolve(123); // 尝试使用有效ID
// $fetchUserIdPromise->resolve(456); // 尝试使用无效ID来测试错误处理

<?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$dataPromise = new Promise(function () use (&$dataPromise) {
    // 模拟一个耗时操作，最终解析 Promise
    sleep(2); // 暂停2秒
    $dataPromise->resolve('这是异步获取到的重要数据');
});

echo "开始等待 Promise..." . PHP_EOL;
// 调用 wait() 会阻塞当前进程，直到 $dataPromise 被解析（成功或失败）
$result = $dataPromise->wait();
echo "Promise 完成，结果是: " . $result . PHP_EOL;
echo "所有操作已完成。" . PHP_EOL;

<?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$riskyPromise = new Promise();

$riskyPromise
    ->then(function ($value) {
        echo "成功处理: " . $value . PHP_EOL;
        // 模拟一个可能失败的操作
        throw new Exception("在第二步中发生了意外错误！");
    })
    ->then(function ($value) {
        echo "这一步不会被执行，因为上一步抛出了异常。" . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中的任何拒绝或异常
        echo "捕获到错误: " . $reason . PHP_EOL;
    });

$riskyPromise->resolve('初始数据');