告别PHP阻塞等待：GuzzlePromises如何优雅处理异步操作

composer require guzzlehttp/promises

use GuzzleHttp\Promise\Promise;

// 创建一个新的Promise
$promise = new Promise();

// 注册回调函数：当Promise被兑现时执行onFulfilled，被拒绝时执行onRejected
$promise->then(
    // $onFulfilled 回调：接收兑现的值
    function ($value) {
        echo "操作成功： " . $value . "\n";
    },
    // $onRejected 回调：接收拒绝的原因
    function ($reason) {
        echo "操作失败： " . $reason . "\n";
    }
);

// 模拟异步操作完成并兑现Promise
// 假设这里是某个耗时操作完成后，我们得到了一个结果
echo "异步操作开始...\n";
// 可以在某个条件满足时调用 resolve 或 reject
if (rand(0, 1)) {
    $promise->resolve('数据已成功获取！');
} else {
    $promise->reject('网络连接超时！');
}

// 注意：在没有事件循环的情况下，需要手动运行任务队列来确保回调被执行
// 对于简单的同步测试，Guzzle Promise会自动在wait()时运行队列
// 但在真正的异步场景下（如结合ReactPHP），需要周期性运行
GuzzleHttp\Promise\Utils::queue()->run();

use GuzzleHttp\Promise\Promise;

$firstPromise = new Promise();

$firstPromise
    ->then(function ($initialValue) {
        echo "第一步：处理初始值 - " . $initialValue . "\n";
        // 返回一个新的值，这个值将作为下一个then的输入
        return $initialValue . " -> 经过处理";
    })
    ->then(function ($processedValue) {
        echo "第二步：处理中间值 - " . $processedValue . "\n";
        // 你也可以在这里返回一个新的Promise，后续的then会等待这个新Promise完成
        $anotherPromise = new Promise();
        $anotherPromise->resolve('最终数据');
        return $anotherPromise;
    })
    ->then(function ($finalValue) {
        echo "第三步：得到最终结果 - " . $finalValue . "\n";
    })
    ->otherwise(function ($reason) { // 使用otherwise()更清晰地处理拒绝
        echo "链中发生错误：" . $reason . "\n";
    });

// 模拟异步操作的开始
$firstPromise->resolve('原始数据');

// 确保所有回调执行
GuzzleHttp\Promise\Utils::queue()->run();

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

$apiCallPromise = new Promise();

$apiCallPromise
    ->then(function ($response) {
        if ($response['status'] !== 200) {
            // 如果响应状态码不是200，则拒绝这个Promise
            throw new \Exception("API返回错误码: " . $response['status']);
        }
        echo "API调用成功，处理数据...\n";
        return $response['data'];
    })
    ->then(function ($data) {
        // 进一步处理数据
        echo "数据处理完成: " . $data . "\n";
    })
    ->otherwise(function (\Throwable $e) { // 捕获链中的任何异常或拒绝
        echo "发生错误： " . $e->getMessage() . "\n";
        // 可以在这里进行错误日志记录、回滚操作等
        // 如果这里不返回任何东西，链会继续向下传递拒绝状态
        // 如果返回一个普通值，后续的then会接收这个值（从错误中恢复）
        // 如果返回一个RejectedPromise，则继续传递拒绝
        return new RejectedPromise("错误已处理，但仍拒绝: " . $e->getMessage());
    })
    ->then(null, function ($finalReason) { // 捕获上一个otherwise返回的拒绝
        echo "最终错误处理：" . $finalReason . "\n";
    });

// 模拟API调用失败
$apiCallPromise->resolve(['status' => 500, 'message' => 'Internal Server Error']);

// 确保所有回调执行
GuzzleHttp\Promise\Utils::queue()->run();

use GuzzleHttp\Client;
use GuzzleHttp\Promise\Utils;

$client = new Client();

// 同时发起多个异步请求
$promises = [
    'users' => $client->getAsync('https://api.example.com/users'),
    'products' => $client->getAsync('https://api.example.com/products'),
    'orders' => $client->getAsync('https://api.example.com/orders'),
];

// 等待所有Promise完成
$results = Utils::settle($promises)->wait();

foreach ($results as $key => $result) {
    if ($result['state'] === 'fulfilled') {
        echo "{$key} 数据获取成功: " . $result['value']->getBody() . "\n";
    } else {
        echo "{$key} 数据获取失败: " . $result['reason']->getMessage() . "\n";
    }
}