如何解决PHP应用中的异步操作难题，使用GuzzlePromises让你的代码更优雅高效

composer require guzzlehttp/promises

use GuzzleHttp\Promise\Promise;

// 1. 创建一个 Promise 对象
$promise = new Promise();

// 2. 注册成功和失败的回调
$promise->then(
    // $onFulfilled: 当 Promise 成功时执行
    function ($value) {
        echo "操作成功，结果是: " . $value . PHP_EOL;
    },
    // $onRejected: 当 Promise 失败时执行
    function ($reason) {
        echo "操作失败，原因: " . $reason . PHP_EOL;
    }
);

// 3. 模拟一个异步操作，并在某个时刻解决或拒绝 Promise
// 假设这里是你的耗时操作...
// 比如：一个 HTTP 请求完成，或者一个文件写入完成

// 模拟成功
$promise->resolve('数据已成功获取'); // 触发 $onFulfilled 回调

// 模拟失败（如果上面没有 resolve，可以尝试 reject）
// $promise->reject(new \Exception('网络连接超时')); // 触发 $onRejected 回调

use GuzzleHttp\Promise\Promise;

$firstPromise = new Promise();

$firstPromise
    ->then(function ($initialValue) {
        echo "第一步完成，收到: " . $initialValue . PHP_EOL;
        // 返回一个新的值，它会传递给下一个 then
        return $initialValue . ' -> 处理过的数据';
    })
    ->then(function ($processedValue) {
        echo "第二步完成，收到: " . $processedValue . PHP_EOL;
        // 也可以返回一个新的 Promise，实现更复杂的异步流程
        $anotherPromise = new Promise();
        // 模拟另一个异步操作
        // $anotherPromise->resolve('最终结果');
        return $anotherPromise; // 这个 Promise 会在它被 resolve 后，才触发后续的 then
    })
    ->then(function ($finalResult) {
        echo "所有步骤完成，最终结果: " . $finalResult . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的错误
        echo "链中发生错误: " . $reason->getMessage() . PHP_EOL;
    });

// 模拟触发第一个 Promise
$firstPromise->resolve('原始数据');

// 如果在第二个 then 中返回了 $anotherPromise，需要手动 resolve 它
// $anotherPromise->resolve('最终结果'); // 这样才会触发最后一个 then

use GuzzleHttp\Promise\Promise;

$dataPromise = new Promise(function () use (&$dataPromise) {
    // 模拟一个耗时操作，例如从数据库查询数据
    sleep(1); // 暂停 1 秒
    $dataPromise->resolve('从数据库获取到的数据');
});

echo "开始等待 Promise..." . PHP_EOL;
$result = $dataPromise->wait(); // 强制 Promise 完成并返回结果
echo "Promise 完成，结果是: " . $result . PHP_EOL;

// 如果 Promise 被拒绝，wait() 会抛出异常
$errorPromise = new Promise(function () use (&$errorPromise) {
    sleep(1);
    $errorPromise->reject(new \Exception('API 请求失败'));
});

try {
    $errorPromise->wait();
} catch (\Exception $e) {
    echo "捕获到 Promise 错误: " . $e->getMessage() . PHP_EOL;
}

use GuzzleHttp\Promise\Utils;
use React\EventLoop\Factory;

$loop = Factory::create();
$queue = Utils::queue();

// 注册一个周期性定时器，每隔 0 毫秒运行一次 Promise 任务队列
// 这确保了在事件循环运行时，Promise 的回调能够被处理
$loop->addPeriodicTimer(0, [$queue, 'run']);

// 创建一个 Promise，并在某个时刻 resolve
$asyncPromise = new Promise(function ($resolve, $reject) use ($loop) {
    $loop->addTimer(2, function () use ($resolve) {
        $resolve('2秒后异步完成');
    });
});

$asyncPromise->then(function ($value) {
    echo "异步操作成功: " . $value . PHP_EOL;
});

echo "程序继续执行，不阻塞..." . PHP_EOL;

$loop->run(); // 启动事件循环