告别PHP阻塞与回调地狱：用Composer引入GuzzlePromises优雅处理异步操作

composer require guzzlehttp/promises

use GuzzleHttp\Promise\Promise;

// 创建一个 Promise 实例
$promise = new Promise();

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

// 假设某个异步操作完成，我们手动“解决”这个 Promise
// 这会触发 $onFulfilled 回调
$promise->resolve('数据已成功获取！');
// 输出: 操作成功，得到值: 数据已成功获取！

echo "--------------------" . PHP_EOL;

$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) {
    echo '操作被拒绝，原因: ' . $reason . PHP_EOL;
});

// 假设异步操作失败，我们手动“拒绝”这个 Promise
// 这会触发 $onRejected 回调
$anotherPromise->reject('API 调用失败，请检查网络。');
// 输出: 操作被拒绝，原因: API 调用失败，请检查网络。

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 第一个操作：对初始值进行处理
        echo "第一步：接收到 '" . $value . "'，进行转换..." . PHP_EOL;
        return "Hello, " . $value; // 返回的值会传递给下一个 then
    })
    ->then(function ($value) {
        // 第二个操作：接收上一步的结果
        echo "第二步：接收到 '" . $value . "'，进行加工..." . PHP_EOL;
        return strtoupper($value) . "!"; // 再次返回，传递给下一个 then
    })
    ->then(function ($value) {
        // 第三步：最终结果
        echo "第三步：最终结果是 '" . $value . "'" . PHP_EOL;
    });

// 解决初始 Promise，启动整个链式操作
$promise->resolve('reader');
/*
输出:
第一步：接收到 'reader'，进行转换...
第二步：接收到 'Hello, reader'，进行加工...
第三步：最终结果是 'HELLO, READER!'
*/

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 假设这里发生了一个错误，或者我们决定拒绝这个 Promise
        if ($value !== 'success') {
            throw new \Exception('第一步操作失败：值不符合预期！');
        }
        return "Processed: " . $value;
    })
    ->then(function ($value) {
        // 这一步不会执行，因为上一步抛出了异常
        echo "第二步：成功处理了 " . $value . PHP_EOL;
    })
    ->otherwise(function ($reason) { // otherwise() 是 then(null, $onRejected) 的语法糖
        echo "捕获到错误： " . $reason->getMessage() . PHP_EOL;
        // 你可以选择在这里返回一个值来恢复链，或者再次抛出异常继续传递错误
        return "错误已处理，链条恢复。";
    })
    ->then(function ($value) {
        echo "错误处理后，继续执行： " . $value . PHP_EOL;
    });

$promise->resolve('fail'); // 故意传入一个会失败的值
/*
输出:
捕获到错误： 第一步操作失败：值不符合预期！
错误处理后，继续执行： 错误已处理，链条恢复。
*/

use GuzzleHttp\Promise\Promise;

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

echo "开始等待 Promise 完成..." . PHP_EOL;
$result = $promise->wait(); // 会阻塞当前执行流，直到 Promise 解决
echo "Promise 完成，结果是: " . $result . PHP_EOL;
// 输出:
// 开始等待 Promise 完成...
// Promise 完成，结果是: 数据已就绪！