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

// 伪代码，展示回调地狱的结构
fetchSocialMediaData(function($socialData) {
    processSocialData($socialData);
    fetchWeatherData(function($weatherData) {
        processWeatherData($weatherData);
        fetchNewsData(function($newsData) {
            processNewsData($newsData);
            // ... 更多嵌套
        }, function($error) { /* handle news error */ });
    }, function($error) { /* handle weather error */ });
}, function($error) { /* handle social error */ });

composer require guzzlehttp/promises

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

// 注册成功和失败的回调
$promise->then(
    function ($value) {
        echo "Promise 成功了，值是: " . $value . "\n";
    },
    function ($reason) {
        echo "Promise 失败了，原因是: " . $reason . "\n";
    }
);

// 模拟异步操作完成并成功
// $promise->resolve('Hello, World!'); // 输出：Promise 成功了，值是: Hello, World!

// 模拟异步操作完成并失败
$promise->reject('网络连接超时！'); // 输出：Promise 失败了，原因是: 网络连接超时！

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

// 模拟一个异步获取用户数据的函数
function getUserData(int $userId): Promise
{
    $promise = new Promise();
    // 假设这是一个耗时操作，例如HTTP请求或数据库查询
    Utils::queue()->add(function() use ($promise, $userId) {
        if ($userId === 1) {
            $promise->resolve(['id' => 1, 'name' => 'Alice']);
        } else {
            $promise->reject('用户不存在');
        }
    });
    return $promise;
}

// 模拟一个异步获取用户订单的函数
function getUserOrders(array $user): Promise
{
    $promise = new Promise();
    Utils::queue()->add(function() use ($promise, $user) {
        if ($user['id'] === 1) {
            $promise->resolve(['order_id' => 'ORD001', 'product' => 'Laptop']);
        } else {
            $promise->reject('无法获取订单');
        });
    });
    return $promise;
}

// 链式调用：获取用户 -> 获取订单 -> 处理结果
getUserData(1)
    ->then(function ($user) {
        echo "获取到用户: " . $user['name'] . "\n";
        // 返回一个新的Promise，将结果传递给下一个then
        return getUserOrders($user);
    })
    ->then(function ($order) {
        echo "获取到订单: " . $order['product'] . "\n";
        return "所有数据获取成功！"; // 最终结果
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节的错误
        echo "操作失败: " . $reason . "\n";
        return "操作中止。";
    })
    ->then(function ($finalMessage) {
        echo "最终状态: " . $finalMessage . "\n";
    });

// 运行任务队列，确保Promise被处理
Utils::queue()->run();

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终会 resolve
    sleep(1); // 阻塞1秒
    $promise->resolve('等待结束！');
});

echo "开始等待...\n";
$result = $promise->wait(); // 会阻塞当前执行，直到 Promise 完成
echo "等待结果: " . $result . "\n"; // 输出：等待结果: 等待结束！

// 假设你正在使用 ReactPHP 的事件循环
// $loop = React\EventLoop\Factory::create();
// $queue = GuzzleHttp\Promise\Utils::queue();
// $loop->addPeriodicTimer(0, [$queue, 'run']);
// $loop->run();