如何优雅地处理PHP异步操作：使用Composer和GuzzlePromises告别“等待”

<pre class="brush:php;toolbar:false;">// 伪代码
$userInfo = getUserInfoFromApi($userId); // 等待完成
$latestOrder = getLatestOrderFromApi($userId); // 等待完成
$recommendations = getRecommendationsFromApi($userInfo); // 等待完成

// 渲染页面

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

guzzlehttp/promises

vendor/autoload.php

<pre class="brush:php;toolbar:false;">require 'vendor/autoload.php';
// 现在你可以使用 Guzzle Promises 了

guzzlehttp/promises

fulfilled

rejected

guzzlehttp/promises

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;
use GuzzleHttp\Promise\Utils; // 用于处理多个Promise

/**
 * 模拟一个异步任务，例如一个耗时的API调用。
 * 在真实世界中，这通常会封装一个非阻塞的I/O操作。
 *
 * @param string $taskName 任务名称
 * @param bool $shouldFail 是否模拟任务失败
 * @return Promise
 */
function simulateAsyncTask(string $taskName, bool $shouldFail = false): Promise
{
    // Promise 构造函数接收一个可选的执行器函数
    // 这个函数会在 Promise 被创建时立即执行（但其内部逻辑可以是异步的）
    $promise = new Promise(function () use (&$promise, $taskName, $shouldFail) {
        // 在真实应用中，这里会是发起一个异步HTTP请求（如 Guzzle HTTP 客户端的 sendAsync()）
        // 或者一个异步数据库查询等。这些操作会立即返回一个 Promise。
        // 当底层I/O操作完成后，通过 $promise->resolve() 或 $promise->reject() 来通知 Promise 结果。

        echo "【开始】任务 '{$taskName}'...\n";
        // 模拟一个随机延迟来体现异步耗时
        usleep(rand(100000, 500000)); // 100ms 到 500ms

        if ($shouldFail) {
            // 模拟任务失败
            $promise->reject(new \Exception("任务 '{$taskName}' 失败了！"));
        } else {
            // 模拟任务成功，并返回结果
            $promise->resolve("任务 '{$taskName}' 完成，结果：[数据_{$taskName}]");
        }
    });
    return $promise;
}

echo "--- 场景：同时发起多个API请求并管理其结果 ---\n";

// 假设我们需要同时从三个不同的服务获取数据
$apiCall1 = simulateAsyncTask('获取用户信息');
$apiCall2 = simulateAsyncTask('获取订单详情', true); // 模拟一个失败的API
$apiCall3 = simulateAsyncTask('获取推荐列表');

// 使用 GuzzleHttp\Promise\Utils::all() 等待所有Promise完成。
// Utils::all() 会返回一个新的Promise，当所有输入的Promise都成功时，它才成功；
// 只要有一个输入的Promise失败，它就会立即失败。
$combinedPromise = Utils::all([$apiCall1, $apiCall2, $apiCall3]);

// 定义成功和失败的回调
$combinedPromise
    ->then(function (array $results) {
        echo "\n【成功】所有API请求成功完成！\n";
        foreach ($results as $index => $result) {
            echo "API " . ($index + 1) . " 结果: " . $result . "\n";
        }
        return "所有关键数据已获取并成功处理。";
    })
    ->otherwise(function (\Throwable $reason) {
        echo "\n【失败】部分API请求失败！错误信息: " . $reason->getMessage() . "\n";
        // 即使失败，我们也可以选择返回一个值让链条继续，或者再次拒绝
        // 这里我们选择再次拒绝，以表明整个操作链因关键错误而中断
        return new RejectedPromise("由于关键API失败，无法继续后续处理。");
    })
    ->then(function ($finalMessage) {
        // 这个 then 只有在前面的 otherwise 返回一个非 RejectedPromise 时才会执行
        echo "【最终处理】结果: " . $finalMessage . "\n";
    })
    ->otherwise(function (\Throwable $reason) {
        // 这个 otherwise 会捕获前面链条中所有未处理的拒绝（包括我们手动 RejectedPromise）
        echo "【最终错误捕获】整个异步流程最终失败，原因: " . $reason->getMessage() . "\n";
    });


echo "--- 异步请求已安排，程序继续执行其他不依赖结果的逻辑... ---\n";
// 在这里，你可以执行其他不依赖于上述API结果的同步代码
// ... 比如日志记录、缓存预热等，这些操作可以与API请求并行（概念上）进行。
echo "--- 其他同步逻辑正在执行中 ---\n";


// 当我们需要最终结果时，同步等待
try {
    // wait() 会阻塞，直到 Promise 解决或拒绝。
    // 如果 combinedPromise 最终被拒绝，wait() 会抛出异常。
    $combinedPromise->wait();
} catch (\Throwable $e) {
    // 如果 Promise 链中没有完全处理拒绝，这里的 wait() 就会捕获到异常
    echo "【主程序捕获】最终异常： " . $e->getMessage() . "\n";
}

echo "--- 所有异步操作处理完毕，程序结束 ---\n";

echo "\n--- 简单的 Promise 链式调用示例 ---\n";
$singlePromise = new Promise();
$singlePromise
    ->then(function ($value) {
        echo "第一步：处理值 '{$value}'\n";
        return strtoupper($value); // 返回新值传递给下一个 then
    })
    ->then(function ($value) {
        echo "第二步：处理值 '{$value}'\n";
        if ($value === 'FAIL') {
            throw new \Exception("故意制造的链式错误！"); // 抛出异常，会被后续的 otherwise 捕获
        }
        return "最终处理完成: " . $value;
    })
    ->otherwise(function (\Throwable $e) {
        echo "链中捕获到错误: " . $e->getMessage() . "\n";
        return "错误已处理，链条继续..."; // 错误处理后返回一个值，链条可以继续
    })
    ->then(function ($finalResult) {
        echo "链条最终结果: " . $finalResult . "\n";
    });

$singlePromise->resolve('test'); // 触发链式调用
// 尝试触发错误路径，将上一行改为：$singlePromise->resolve('fail');

$singlePromise->wait(false); // 确保所有回调执行，但不抛出异常

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises