如何解决PHP异步操作的回调地狱？GuzzlePromises助你构建优雅的异步流程

guzzlehttp/promises

getUserID(function ($userId) {
    getUserDetails($userId, function ($userDetails) {
        getOrders($userDetails['id'], function ($orders) use ($userDetails) {
            $productDetails = [];
            foreach ($orders as $order) {
                getProductDetails($order['productId'], function ($product) use (&$productDetails) {
                    $productDetails[] = $product;
                    // 如果这里是最后一个商品，才继续处理...
                });
            }
            // 嵌套到这里，代码已经很难看了，错误处理更是灾难
            renderPage($userDetails, $orders, $productDetails);
        });
    });
});
// 错误处理？每个回调函数里都得写一遍吗？

guzzlehttp/promises

composer require guzzlehttp/promises

then()

then()

$onFulfilled

$onRejected

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise->then(
    function ($value) {
        echo '操作成功，得到值: ' . $value . "\n";
    },
    function ($reason) {
        echo '操作失败，原因: ' . $reason . "\n";
    }
);

// 模拟异步操作成功
$promise->resolve('这是成功的结果');
// 输出：操作成功，得到值: 这是成功的结果

// 模拟异步操作失败
// $promise->reject('发生了一个错误');
// 输出：操作失败，原因: 发生了一个错误

then()

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：处理了 " . $value . "\n";
        return $value . "，并进入第二步"; // 返回的值会传递给下一个 then
    })
    ->then(function ($newValue) {
        echo "第二步：处理了 " . $newValue . "\n";
        // 如果这里返回一个 Promise，下一个 then 会等待这个 Promise 完成
        return new Promise(function ($resolve) use ($newValue) {
            echo "模拟异步操作，延迟1秒...\n";
            sleep(1); // 模拟耗时操作
            $resolve($newValue . "，最终完成！");
        });
    })
    ->then(function ($finalValue) {
        echo "第三步：最终结果是 " . $finalValue . "\n";
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节的错误
        echo "在任何一步发生错误: " . $reason . "\n";
    });

// 启动 Promise 链
$promise->resolve('初始数据');

// 注意：在非事件循环环境中，需要手动运行任务队列来处理 Promise
// GuzzleHttp\Promise\Utils::queue()->run();

then

reject

onFulfilled

onRejected

otherwise()

then(null, $onRejected)

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "尝试处理: " . $value . "\n";
        // 模拟一个错误发生
        if ($value === '错误数据') {
            return new RejectedPromise('数据校验失败'); // 主动拒绝
        }
        return "处理成功: " . $value;
    })
    ->then(function ($successValue) {
        echo "下一步处理成功数据: " . $successValue . "\n";
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的错误
        echo "捕获到错误: " . $reason . "\n";
    });

$promise->resolve('错误数据'); // 触发错误路径
// GuzzleHttp\Promise\Utils::queue()->run(); // 如果在非事件循环环境

wait()

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    echo "正在等待 Promise 完成...\n";
    sleep(2); // 模拟耗时
    $promise->resolve('等待结束，获取到结果');
});

try {
    $result = $promise->wait(); // 会阻塞直到 Promise 完成
    echo "同步获取到结果: " . $result . "\n";
} catch (\Exception $e) {
    echo "同步等待时发生错误: " . $e->getMessage() . "\n";
}

<?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;
use GuzzleHttp\Promise\Utils;

// 模拟异步函数，返回 Promise
function fetchUserIdAsync(): Promise
{
    return new Promise(function ($resolve) {
        echo "-> 正在获取用户ID...\n";
        sleep(1); // 模拟网络延迟
        $resolve(123); // 假设获取到用户ID
    });
}

function fetchUserDetailsAsync(int $userId): Promise
{
    return new Promise(function ($resolve, $reject) {
        echo "-> 正在获取用户详情 (ID: {$userId})...\n";
        sleep(1); // 模拟网络延迟
        if ($userId === 123) {
            $resolve(['id' => $userId, 'name' => '张三', 'email' => 'zhangsan@example.com']);
        } else {
            $reject("用户ID {$userId} 不存在。");
        }
    });
}

function fetchOrdersAsync(int $userId): Promise
{
    return new Promise(function ($resolve) {
        echo "-> 正在获取订单列表 (用户ID: {$userId})...\n";
        sleep(1); // 模拟网络延迟
        $resolve([
            ['orderId' => 'ORD001', 'productId' => 'PROD001', 'amount' => 100],
            ['orderId' => 'ORD002', 'productId' => 'PROD002', 'amount' => 200],
        ]);
    });
}

function fetchProductDetailsAsync(string $productId): Promise
{
    return new Promise(function ($resolve) {
        echo "-> 正在获取商品详情 (ID: {$productId})...\n";
        sleep(0.5); // 模拟网络延迟
        $products = [
            'PROD001' => ['name' => '商品A', 'price' => 100],
            'PROD002' => ['name' => '商品B', 'price' => 200],
        ];
        $resolve($products[$productId] ?? null);
    });
}

echo "开始处理用户页面数据...\n";

fetchUserIdAsync()
    ->then(function ($userId) {
        return fetchUserDetailsAsync($userId); // 链式调用，返回下一个 Promise
    })
    ->then(function (array $userDetails) {
        echo "用户详情获取成功: " . $userDetails['name'] . "\n";
        // 同时获取订单和处理商品详情，这里可以并发处理
        return Utils::all([ // Utils::all 可以等待多个 Promise 完成
            'userDetails' => $userDetails,
            'orders' => fetchOrdersAsync($userDetails['id'])
                ->then(function (array $orders) {
                    $productPromises = [];
                    foreach ($orders as $order) {
                        $productPromises[] = fetchProductDetailsAsync($order['productId'])
                            ->then(function ($productDetail) use ($order) {
                                return array_merge($order, ['productDetail' => $productDetail]);
                            });
                    }
                    return Utils::all($productPromises); // 等待所有商品详情获取完成
                })
        ]);
    })
    ->then(function (array $data) {
        $userDetails = $data['userDetails'];
        $ordersWithProducts = $data['orders'];

        echo "所有数据获取完成，开始渲染页面。\n";
        echo "用户: " . $userDetails['name'] . " (" . $userDetails['email'] . ")\n";
        echo "订单:\n";
        foreach ($ordersWithProducts as $order) {
            echo "  - 订单号: {$order['orderId']}, 商品: {$order['productDetail']['name']}, 金额: {$order['amount']}\n";
        }
    })
    ->otherwise(function ($reason) {
        echo "处理过程中发生错误: " . $reason . "\n";
    });

// 在非事件循环环境中，需要运行任务队列来确保 Promise 被处理
Utils::queue()->run();

echo "程序执行完毕。\n";

then

Utils::all()

guzzlehttp/promises