如何解决PHP异步操作导致代码混乱和效率低下？GuzzlePromises助你优雅地处理并发请求！

composer require guzzlehttp/promises

use GuzzleHttp\Promise\Promise;

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

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

// 模拟异步操作完成，解决Promise
$promise->resolve('数据已获取'); // 这将触发 $onFulfilled 回调
// $promise->reject('网络错误'); // 这将触发 $onRejected 回调

use GuzzleHttp\Promise\Promise;

$initialPromise = new Promise();

$initialPromise
    ->then(function ($value) {
        echo "第一步：处理初始值 " . $value . PHP_EOL;
        // 返回一个新值，传递给下一个 then
        return $value + 10;
    })
    ->then(function ($newValue) {
        echo "第二步：处理新值 " . $newValue . PHP_EOL;
        // 可以在这里返回另一个 Promise，实现异步操作的串联
        $anotherPromise = new Promise();
        // 模拟异步操作
        // sleep(1); // 实际中这里是异步IO操作
        $anotherPromise->resolve("最终数据 " . ($newValue * 2));
        return $anotherPromise; // 返回一个 Promise
    })
    ->then(function ($finalResult) {
        echo "第三步：获得最终结果 " . $finalResult . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的错误
        echo "操作链中出现错误: " . $reason . PHP_EOL;
    });

// 解决初始 Promise，启动整个链条
$initialPromise->resolve(5);

// 注意：在实际的异步场景中，你可能需要一个事件循环来驱动 Promise 的解析。
// 对于 HTTP 请求等，Guzzle HTTP 客户端会自动处理。
// 如果是独立使用 Guzzle Promises，需要手动运行任务队列，例如：
// GuzzleHttp\Promise\Utils::queue()->run();

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，然后解决Promise
    sleep(1);
    $promise->resolve('我等到了！');
});

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 脚本会在这里阻塞，直到 Promise 被解决或拒绝
echo "等待结束，结果是: " . $result . PHP_EOL;

use GuzzleHttp\Client;
use GuzzleHttp\Promise\Utils; // 用于 all() 等方法

$client = new Client();

// 同时发起三个异步请求
$promises = [
    'weather' => $client->getAsync('https://api.example.com/weather'),
    'stock' => $client->getAsync('https://api.example.com/stock'),
    'news' => $client->getAsync('https://api.example.com/news'),
];

// 等待所有 Promise 完成
// Utils::all() 会返回一个新的 Promise，当所有子 Promise 都成功时才成功
$resultsPromise = Utils::all($promises);

$resultsPromise->then(
    function ($responses) {
        // 所有请求都成功完成
        echo "所有数据都已获取！" . PHP_EOL;
        echo "天气数据: " . $responses['weather']->getBody() . PHP_EOL;
        echo "股票数据: " . $responses['stock']->getBody() . PHP_EOL;
        echo "新闻数据: " . $responses['news']->getBody() . PHP_EOL;
    },
    function ($reason) {
        // 任何一个请求失败，都会触发这里
        echo "部分或全部请求失败: " . $reason->getMessage() . PHP_EOL;
    }
)->wait(); // 使用 wait() 阻塞主线程，直到所有异步请求完成