如何解决PHP异步操作的复杂性与性能瓶颈？GuzzlePromises助你优雅掌控！

<code class="bash">composer require guzzlehttp/promises</code>

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

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

// 注册成功和失败的回调函数
$promise->then(
    // $onFulfilled：当 Promise 成功完成时调用
    function ($value) {
        echo "Promise 成功完成，值是: " . $value . PHP_EOL;
    },
    // $onRejected：当 Promise 失败时调用
    function ($reason) {
        echo "Promise 失败了，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成并解析 Promise
// 你可以在某个耗时操作完成后，根据结果调用 resolve 或 reject
$promise->resolve('Hello Guzzle Promises!'); // 成功兑现
// $promise->reject('API 调用失败，请检查网络！'); // 拒绝 Promise</code>

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：接收原始数据 - " . $value . PHP_EOL;
        // 返回一个新的值，这个值会传递给下一个 then
        return "处理后的 " . $value . " (来自第一步)";
    })
    ->then(function ($newValue) {
        echo "第二步：接收处理后的数据 - " . $newValue . PHP_EOL;
        // 也可以返回一个新的 Promise，下一个 then 会等待这个新 Promise 完成
        return new Promise(function ($resolve) use ($newValue) {
            echo "模拟第二步中的异步操作..." . PHP_EOL;
            sleep(1); // 模拟耗时操作
            $resolve($newValue . " (来自第二步的异步处理)");
        });
    })
    ->then(function ($finalValue) {
        echo "第三步：接收最终数据 - " . $finalValue . PHP_EOL;
    })
    ->then(null, function ($reason) { // 链式捕获错误
        echo "链中某个环节发生错误: " . $reason . PHP_EOL;
    });

// 触发整个 Promise 链的执行
$promise->resolve('原始数据');

// 注意：在传统的同步PHP环境中，你需要手动运行任务队列或等待Promise完成
// Guzzle Promises 在 Promise 构造函数中提供了 waitFn，或者你可以显式调用 wait()
// 如果没有事件循环（如ReactPHP），通常会用到 wait()
// $promise->wait(); // 如果你需要同步等待链式调用的最终结果</code>

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectionException;

$asyncOperation = new Promise(function () use (&$asyncOperation) {
    // 模拟一个耗时操作，例如一个网络请求
    echo "正在执行异步操作..." . PHP_EOL;
    sleep(2); // 假设这里是网络请求或复杂计算
    // $asyncOperation->resolve('数据已成功获取！');
    $asyncOperation->reject('网络请求超时！'); // 模拟失败
});

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

try {
    // 同步等待并获取结果，如果 Promise 被拒绝，这里会抛出异常
    $result = $asyncOperation->wait();
    echo "异步操作结果: " . $result . PHP_EOL;
} catch (RejectionException $e) {
    echo "异步操作失败: " . $e->getReason() . PHP_EOL;
} catch (\Exception $e) {
    echo "捕获到其他异常: " . $e->getMessage() . PHP_EOL;
}

echo "所有操作完成。" . PHP_EOL;</code>