告别PHP异步编程的“回调地狱”：使用Composer和GuzzlePromises优雅地处理异步操作

getUser(function ($user) {
    getOrders($user->id, function ($orders) {
        foreach ($orders as $order) {
            getProducts($order->id, function ($products) {
                // 处理商品信息
            });
        }
    });
});

composer require guzzlehttp/promises

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise->then(
    // $onFulfilled: 当 Promise 成功完成时调用
    function ($value) {
        echo "操作成功，结果是: " . $value . PHP_EOL;
    },
    // $onRejected: 当 Promise 失败时调用
    function ($reason) {
        echo "操作失败，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成并成功
$promise->resolve('这是未来的结果');
// 输出: 操作成功，结果是: 这是未来的结果

// 模拟异步操作失败
$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) {
    echo "另一个操作失败，原因是: " . $reason . PHP_EOL;
});
$anotherPromise->reject('发生了错误！');
// 输出: 另一个操作失败，原因是: 发生了错误！

use GuzzleHttp\Promise\Promise;

// 模拟第一个异步操作：获取用户ID
function fetchUserIdAsync() {
    $promise = new Promise();
    // 假设2秒后获取到用户ID
    // 实际项目中这里会是真正的异步操作，比如 HTTP 请求
    echo "开始获取用户ID..." . PHP_EOL;
    \GuzzleHttp\Promise\Utils::queue()->add(function() use ($promise) {
        sleep(2); // 模拟耗时
        $promise->resolve(123);
    });
    return $promise;
}

// 模拟第二个异步操作：根据用户ID获取订单列表
function fetchOrdersAsync($userId) {
    $promise = new Promise();
    echo "获取用户ID: {$userId} 的订单..." . PHP_EOL;
    \GuzzleHttp\Promise\Utils::queue()->add(function() use ($promise, $userId) {
        sleep(1); // 模拟耗时
        $orders = ["OrderA", "OrderB"]; // 假设获取到订单
        $promise->resolve($orders);
    });
    return $promise;
}

// 模拟第三个异步操作：处理订单
function processOrdersAsync($orders) {
    $promise = new Promise();
    echo "处理订单: " . implode(', ', $orders) . PHP_EOL;
    \GuzzleHttp\Promise\Utils::queue()->add(function() use ($promise, $orders) {
        sleep(0.5); // 模拟耗时
        $promise->resolve("所有订单处理完毕！");
    });
    return $promise;
}

// 链式调用
fetchUserIdAsync()
    ->then(function ($userId) {
        return fetchOrdersAsync($userId); // 返回一个新的 Promise，链条继续
    })
    ->then(function ($orders) {
        return processOrdersAsync($orders); // 继续返回 Promise
    })
    ->then(function ($message) {
        echo $message . PHP_EOL; // 最终结果
    })
    ->otherwise(function ($reason) { // 统一的错误处理
        echo "操作链中发生错误: " . $reason . PHP_EOL;
    });

// 在异步环境下，需要手动运行任务队列来驱动 Promise 的执行
// 如果在同步上下文中使用，Guzzle Promises 会在 wait() 时自动运行
\GuzzleHttp\Promise\Utils::queue()->run();

use GuzzleHttp\Promise\Promise;

$dataPromise = new Promise(function () use (&$dataPromise) {
    // 模拟从数据库获取数据
    sleep(1);
    $dataPromise->resolve(['id' => 1, 'name' => '示例数据']);
});

echo "等待数据中..." . PHP_EOL;
$result = $dataPromise->wait(); // 阻塞执行，直到 Promise 完成
echo "获取到数据: " . json_encode($result) . PHP_EOL;