PHP异步编程痛点如何解决？GuzzlePromises助你优雅驾驭并发操作

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

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

// 注册成功回调和失败回调
$promise->then(
    function ($value) {
        echo '操作成功，得到值: ' . $value . PHP_EOL;
    },
    function ($reason) {
        echo '操作失败，原因: ' . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成后，解决Promise
// 假设这里是某个耗时操作的完成点
$promise->resolve('这是异步操作的结果');
// 输出: 操作成功，得到值: 这是异步操作的结果

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步完成，接收到: " . $value . PHP_EOL;
        // 返回一个新值，传递给下一个then
        return "处理后的 " . $value;
    })
    ->then(function ($newValue) {
        echo "第二步完成，接收到: " . $newValue . PHP_EOL;
        // 返回一个新的Promise，实现异步操作的串联
        $anotherPromise = new Promise();
        // 模拟另一个异步操作，稍后解决
        // 这里可以是一个数据库查询，一个API请求等
        // 假设1秒后解决
        \GuzzleHttp\Promise\Utils::queue()->add(function () use ($anotherPromise) {
            sleep(1); // 模拟耗时
            $anotherPromise->resolve('来自第二个异步操作的数据');
        });
        return $anotherPromise;
    })
    ->then(function ($finalValue) {
        echo "所有异步操作完成，最终结果: " . $finalValue . PHP_EOL;
    });

// 启动第一个Promise
$promise->resolve('原始数据');

// 注意：在异步环境中，需要运行任务队列来处理Promise
// 在Web请求结束或CLI脚本退出前，确保运行队列
// 对于简单的同步等待，可以不显式调用，但了解其原理很重要
\GuzzleHttp\Promise\Utils::queue()->run();

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "成功处理: " . $value . PHP_EOL;
        // 模拟一个错误发生，返回一个RejectedPromise
        return new RejectedPromise('第一步处理失败！');
    })
    ->then(null, function ($reason) { // 捕获上一步的拒绝
        echo "捕获到错误: " . $reason . PHP_EOL;
        // 可以在这里处理错误，或者继续抛出
        throw new \Exception("进一步处理错误: " . $reason);
    })
    ->otherwise(function (\Throwable $e) { // 类似catch，捕获所有拒绝
        echo "最终错误捕获: " . $e->getMessage() . PHP_EOL;
        return '错误已恢复，返回默认值'; // 错误恢复，链条可以继续
    })
    ->then(function ($value) {
        echo "错误恢复后继续: " . $value . PHP_EOL;
    });

$promise->resolve('初始值');
\GuzzleHttp\Promise\Utils::queue()->run();
// 输出:
// 成功处理: 初始值
// 捕获到错误: 第一步处理失败！
// 最终错误捕获: 进一步处理错误: 第一步处理失败！
// 错误恢复后继续: 错误已恢复，返回默认值

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作
    sleep(2);
    $promise->resolve('等待2秒后的结果');
});

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 阻塞，直到Promise解决
echo "等待结束，结果: " . $result . PHP_EOL;
// 输出:
// 开始等待...
// (等待2秒)
// 等待结束，结果: 等待2秒后的结果

<pre class="brush:php;toolbar:false;">// 伪代码，展示与ReactPHP事件循环的集成
// $loop = React\EventLoop\Factory::create();
// $queue = GuzzleHttp\Promise\Utils::queue();
// $loop->addPeriodicTimer(0, [$queue, 'run']);
// $loop->run();