如何解决PHP异步操作中的“回调地狱”？GuzzlePromises让你的代码更优雅高效

<code class="php">// 伪代码，展示“回调地狱”
fetchUser(function ($user) use ($orderService, $logisticsService) {
    if ($user) {
        fetchOrders($user->id, function ($orders) use ($logisticsService) {
            if ($orders) {
                processLogistics($orders, function ($result) {
                    if ($result) {
                        echo "所有操作完成！\n";
                    } else {
                        echo "物流处理失败。\n";
                    }
                }, function ($error) {
                    echo "物流服务错误：{$error}\n";
                });
            } else {
                echo "订单获取失败。\n";
            }
        }, function ($error) {
            echo "订单服务错误：{$error}\n";
        });
    } else {
        echo "用户获取失败。\n";
    }
}, function ($error) {
    echo "用户服务错误：{$error}\n";
});</code>

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

<code class="php"><?php

require 'vendor/autoload.php';

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

/**
 * 模拟获取用户数据的异步操作
 * @param string $userId
 * @return Promise
 */
function fetchUserAsync(string $userId): Promise
{
    return new Promise(function ($resolve, $reject) use ($userId) {
        // 模拟网络延迟或数据库查询
        echo "正在异步获取用户 {$userId} 的数据...\n";
        // 假设这里是异步调用，结果稍后返回
        if ($userId === 'user123') {
            // 模拟成功
            $resolve(['id' => $userId, 'name' => '张三', 'email' => 'zhangsan@example.com']);
        } else {
            // 模拟失败
            $reject(new \Exception("用户 {$userId} 不存在。"));
        }
    });
}

/**
 * 模拟获取订单数据的异步操作
 * @param array $userData
 * @return Promise
 */
function fetchOrdersAsync(array $userData): Promise
{
    return new Promise(function ($resolve, $reject) use ($userData) {
        echo "正在异步获取用户 {$userData['name']} 的订单...\n";
        if ($userData['id'] === 'user123') {
            // 模拟成功
            $resolve(['user_id' => $userData['id'], 'order_list' => ['ORD001', 'ORD002']]);
        } else {
            // 模拟失败
            $reject(new \Exception("无法获取用户 {$userData['name']} 的订单。"));
        }
    });
}

/**
 * 模拟处理物流的异步操作
 * @param array $orderData
 * @return Promise
 */
function processLogisticsAsync(array $orderData): Promise
{
    return new Promise(function ($resolve, $reject) use ($orderData) {
        echo "正在异步处理订单 {$orderData['order_list'][0]} 的物流...\n";
        if (!empty($orderData['order_list'])) {
            // 模拟成功
            $resolve(['order_id' => $orderData['order_list'][0], 'status' => '物流已安排']);
        } else {
            // 模拟失败
            $reject(new \Exception("没有订单需要处理物流。"));
        }
    });
}

// 使用 Promise 链式调用
echo "--- 开始执行 Promise 链式调用 ---\n";
fetchUserAsync('user123') // 第一个Promise
    ->then(function ($userData) {
        echo "用户数据获取成功: " . $userData['name'] . "\n";
        return fetchOrdersAsync($userData); // 返回一个新的Promise，继续链式调用
    })
    ->then(function ($orderData) {
        echo "订单数据获取成功: " . implode(', ', $orderData['order_list']) . "\n";
        return processLogisticsAsync($orderData); // 返回一个新的Promise
    })
    ->then(function ($logisticsResult) {
        echo "物流处理成功: " . $logisticsResult['status'] . "\n";
        return "所有业务流程顺利完成！"; // 最终成功的结果
    })
    ->otherwise(function (\Exception $reason) { // 统一处理链中任何环节的错误
        echo "业务流程中发生错误: " . $reason->getMessage() . "\n";
        return new RejectedPromise("业务流程中断！"); // 也可以返回一个 RejectedPromise 传播错误
    })
    ->then(function ($finalResult) {
        // 只有当整个链成功时才会执行
        echo "最终结果: " . $finalResult . "\n";
    }, function ($finalReason) {
        // 当整个链最终被拒绝时执行
        echo "流程最终被拒绝: " . $finalReason . "\n";
    })
    ->wait(); // 在非事件循环环境下，同步等待所有Promise完成

echo "--- Promise 链式调用执行完毕 ---\n";

echo "\n--- 模拟失败场景 ---\n";
fetchUserAsync('user_non_existent') // 模拟一个不存在的用户
    ->then(function ($userData) {
        echo "用户数据获取成功: " . $userData['name'] . "\n";
        return fetchOrdersAsync($userData);
    })
    ->then(function ($orderData) {
        echo "订单数据获取成功: " . implode(', ', $orderData['order_list']) . "\n";
        return processLogisticsAsync($orderData);
    })
    ->then(function ($logisticsResult) {
        echo "物流处理成功: " . $logisticsResult['status'] . "\n";
        return "所有业务流程顺利完成！";
    })
    ->otherwise(function (\Exception $reason) {
        echo "业务流程中发生错误: " . $reason->getMessage() . "\n";
        // 这里返回的不是RejectedPromise，所以后续的then会被触发
        return "错误已处理，但流程未完全中断。";
    })
    ->then(function ($finalResult) {
        echo "最终结果: " . $finalResult . "\n";
    }, function ($finalReason) {
        echo "流程最终被拒绝: " . $finalReason . "\n";
    })
    ->wait();

echo "--- 失败场景执行完毕 ---\n";</code>