如何解决PHP异步操作的“阻塞”难题，使用GuzzlePromises提升应用性能与可维护性

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

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

use GuzzleHttp\Promise\Promise;

// 模拟一个异步获取用户 ID 的操作
function getUserIdAsync(): Promise
{
    $promise = new Promise();
    // 实际应用中这里可能是发起一个 HTTP 请求或数据库查询
    // 这里用 setTimeout 模拟异步，实际 PHP 异步需要事件循环配合
    echo "开始获取用户 ID...\n";
    // 假设 1 秒后返回用户 ID
    \GuzzleHttp\Promise\Utils::queue()->add(function() use ($promise) {
        sleep(1); // 模拟耗时操作
        $promise->resolve(123);
    });
    return $promise;
}

// 模拟一个异步获取用户详情的操作
function getUserDetailsAsync(int $userId): Promise
{
    $promise = new Promise();
    echo "根据用户 ID {$userId} 开始获取用户详情...\n";
    // 假设 2 秒后返回用户详情
    \GuzzleHttp\Promise\Utils::queue()->add(function() use ($promise, $userId) {
        sleep(2); // 模拟耗时操作
        $promise->resolve("用户 {$userId} 的详细信息：Alice");
    });
    return $promise;
}

echo "程序开始执行...\n";

getUserIdAsync()
    ->then(function ($userId) {
        echo "获取到用户 ID: {$userId}\n";
        return getUserDetailsAsync($userId); // 返回一个新的 Promise，实现链式调用
    })
    ->then(function ($userDetails) {
        echo "最终获取到: {$userDetails}\n";
    })
    ->otherwise(function ($reason) {
        echo "操作失败: {$reason}\n";
    });

// 运行 Promise 队列，处理异步回调
\GuzzleHttp\Promise\Utils::queue()->run();

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

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

use GuzzleHttp\Promise\Promise;

function riskyOperationAsync(): Promise
{
    $promise = new Promise();
    \GuzzleHttp\Promise\Utils::queue()->add(function() use ($promise) {
        // 模拟一个随机失败的操作
        if (rand(0, 1)) {
            $promise->resolve('操作成功！');
        } else {
            $promise->reject('操作失败，随机错误！');
        }
    });
    return $promise;
}

riskyOperationAsync()
    ->then(function ($value) {
        echo "成功回调: " . $value . "\n";
        // 如果这里抛出异常，也会被后续的 otherwise 捕获
        // throw new Exception("二次处理失败");
    })
    ->otherwise(function ($reason) {
        echo "捕获到错误: " . $reason . "\n";
        // 可以在这里进行错误日志记录、回滚等操作
        return '已恢复到默认值'; // 错误处理后可以返回一个值，让后续的 then 继续执行
    })
    ->then(function ($value) {
        echo "错误处理后继续执行: " . $value . "\n";
    });

\GuzzleHttp\Promise\Utils::queue()->run();
?>

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

use GuzzleHttp\Promise\Promise;

$longRunningTask = new Promise(function () use (&$longRunningTask) {
    echo "长任务开始执行...\n";
    sleep(3); // 模拟一个耗时 3 秒的任务
    $longRunningTask->resolve('长任务完成！');
}, function () {
    echo "长任务被取消了！\n";
    // 这里可以放置清理资源的代码
});

echo "主程序：发起长任务...\n";
// 在实际应用中，你可能不会立即等待，而是在需要结果时才调用 wait()
// 比如，一个 HTTP 请求的最后，需要返回所有异步操作的结果
echo "主程序：等待长任务完成...\n";
try {
    echo $longRunningTask->wait() . "\n"; // 这会阻塞程序 3 秒
} catch (Exception $e) {
    echo "等待过程中出现异常：" . $e->getMessage() . "\n";
}

echo "主程序：所有任务完成。\n";
?>