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

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

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 假设这是一个模拟的异步操作，比如从数据库获取数据
function fetchDataAsync($data) {
    // 创建一个 Promise 对象
    $promise = new Promise();

    // 在实际应用中，这里会启动一个非阻塞的操作（例如：HTTP请求、异步IO）
    // 并在操作完成后调用 $promise->resolve() 或 $promise->reject()

    // 为了演示，我们模拟一个延迟和成功解析
    // 实际的异步操作会由 Guzzle HTTP 客户端等驱动

    // 假设2秒后数据获取成功
    // 实际场景下，你需要结合事件循环（如 ReactPHP EventLoop）来真正实现非阻塞
    echo "开始模拟异步获取数据...\n";
    // 模拟异步操作完成
    // 通常这会在一个非阻塞的上下文中被调用
    // 为了简单演示，我们直接在当前执行流中 resolve
    // 在真实异步场景中，这会是一个回调函数
    $promise->resolve("数据：{$data} 已成功获取！");

    return $promise;
}

// 创建一个 Promise 实例
$dataPromise = fetchDataAsync('用户列表');

echo "异步操作已启动，脚本继续执行...\n";

// 使用 then() 方法注册成功和失败的回调
$dataPromise->then(
    function ($value) {
        echo "成功获取到数据： " . $value . "\n";
    },
    function ($reason) {
        echo "获取数据失败： " . $reason . "\n";
    }
);

// 当你需要同步等待结果时，可以使用 wait() 方法。
// 注意：这会阻塞当前执行流，直到 Promise 完成。
// 在真正的异步应用中，你应该尽量避免频繁使用 wait()，除非是程序的最后一步。
try {
    $result = $dataPromise->wait();
    echo "最终结果（通过 wait 获取）：" . $result . "\n";
} catch (Exception $e) {
    echo "等待过程中发生错误：" . $e->getMessage() . "\n";
}

echo "脚本执行完毕。\n";</code>

<code class="php"><?php

require 'vendor/autoload.php';

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

// 模拟获取用户基本信息
function getUserInfo($userId) {
    $promise = new Promise();
    echo "获取用户 {$userId} 信息...\n";
    // 模拟异步成功
    $promise->resolve(['id' => $userId, 'name' => 'Alice']);
    return $promise;
}

// 模拟获取用户订单历史
function getOrderHistory($userId) {
    $promise = new Promise();
    echo "获取用户 {$userId} 订单历史...\n";
    if ($userId === 999) { // 模拟某个用户没有订单
        $promise->reject("用户 {$userId} 没有订单记录");
    } else {
        // 模拟异步成功
        $promise->resolve(['order1', 'order2']);
    }
    return $promise;
}

// 模拟根据订单推荐商品
function getRecommendations($orders) {
    $promise = new Promise();
    echo "根据订单 [" . implode(', ', $orders) . "] 推荐商品...\n";
    // 模拟异步成功
    $promise->resolve(['itemA', 'itemB']);
    return $promise;
}

// 链式调用：优雅地处理依赖关系
getUserInfo(123)
    ->then(function ($userInfo) {
        echo "用户信息获取成功：{$userInfo['name']}\n";
        // 返回一个新的 Promise，继续链式调用
        return getOrderHistory($userInfo['id']);
    })
    ->then(function ($orders) {
        echo "订单历史获取成功：[" . implode(', ', $orders) . "]\n";
        // 返回一个新的 Promise，继续链式调用
        return getRecommendations($orders);
    })
    ->then(function ($recommendations) {
        echo "商品推荐成功：[" . implode(', ', $recommendations) . "]\n";
        echo "所有操作完成！\n";
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节的错误
        echo "操作失败：{$reason}\n";
    })
    ->wait(); // 最后同步等待所有 Promise 完成

echo "\n--- 尝试一个会失败的链式调用 ---\n";

getUserInfo(999) // 模拟一个没有订单的用户
    ->then(function ($userInfo) {
        echo "用户信息获取成功：{$userInfo['name']}\n";
        return getOrderHistory($userInfo['id']); // 这里会返回一个 RejectedPromise
    })
    ->then(function ($orders) {
        echo "订单历史获取成功：[" . implode(', ', $orders) . "]\n";
        return getRecommendations($orders);
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节的错误
        echo "操作失败：{$reason}\n";
    })
    ->wait();</code>