如何解决PHP中的异步操作难题：使用Composer与GuzzlePromises提升代码效率与可维护性

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

$onFulfilled

$onRejected

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

$promise = new Promise();

$promise->then(
    // $onFulfilled: 异步操作成功时调用
    function ($value) {
        echo 'Promise 成功兑现，得到值: ' . $value . PHP_EOL;
    },
    // $onRejected: 异步操作失败时调用
    function ($reason) {
        echo 'Promise 被拒绝，原因: ' . $reason . PHP_EOL;
    }
);

// 模拟异步操作成功，兑现 Promise
$promise->resolve('这是API返回的数据'); // 输出: Promise 成功兑现，得到值: 这是API返回的数据

// 或者，模拟异步操作失败，拒绝 Promise
// $promise->reject('API请求超时'); // 输出: Promise 被拒绝，原因: API请求超时

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 第一个then，处理初始值并返回一个新的值
        echo "第一步处理: " . $value . PHP_EOL;
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        // 第二个then，接收上一个then的返回值
        echo "第二步处理: " . $value . PHP_EOL;
        return strtoupper($value); // 转换为大写
    })
    ->then(function ($value) {
        // 第三个then，最终输出
        echo "最终结果: " . $value . PHP_EOL;
    });

// 解决初始Promise，触发链式调用
$promise->resolve('reader.');
// 输出：
// 第一步处理: reader.
// 第二步处理: Hello, reader.
// 最终结果: HELLO, READER.

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

$promise = new Promise();
$nextPromise = new Promise(); // 假设这是另一个异步操作返回的Promise

$promise
    ->then(function ($value) use ($nextPromise) {
        echo "第一个Promise完成，值: " . $value . PHP_EOL;
        // 返回另一个Promise，后续链将等待它完成
        return $nextPromise;
    })
    ->then(function ($value) {
        // 这个then会在$nextPromise完成并兑现后才执行
        echo "第二个Promise完成，值: " . $value . PHP_EOL;
    });

// 解决第一个Promise
$promise->resolve('初始数据'); // 输出: 第一个Promise完成，值: 初始数据

// 稍后解决第二个Promise，触发后续链
$nextPromise->resolve('来自第二个异步操作的数据'); // 输出: 第二个Promise完成，值: 来自第二个异步操作的数据

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决Promise
    sleep(1); // 暂停1秒
    $promise->resolve('foo');
});

echo "开始等待..." . PHP_EOL;
$value = $promise->wait(); // 脚本会在这里暂停1秒，直到Promise解决
echo "等待结束，得到值: " . $value . PHP_EOL; // 输出 "等待结束，得到值: foo"

wait(false)

<pre class="brush:php;toolbar:false;">// 获取全局任务队列实例
$queue = GuzzleHttp\Promise\Utils::queue();

// 在你的事件循环中，你可能需要定期调用 run() 方法
// 例如，在 ReactPHP 中：
// $loop = React\EventLoop\Factory::create();
// $loop->addPeriodicTimer(0.001, [$queue, 'run']); // 每毫秒运行一次任务队列
// $loop->run();