告别PHP异步操作的烦恼：如何使用Composer和GuzzlePromises优雅地处理并发任务

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

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise->then(
    // $onFulfilled：当Promise成功时执行
    function ($value) {
        echo '操作成功，结果是: ' . $value . PHP_EOL;
    },
    // $onRejected：当Promise失败时执行
    function ($reason) {
        echo '操作失败，原因是: ' . $reason . PHP_EOL;
    }
);

// 假设某个异步操作完成，并成功返回了数据
$promise->resolve('这是异步操作的结果！');
// 输出：操作成功，结果是: 这是异步操作的结果！</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 第一个then，返回一个新值给下一个then
        echo '第一步：接收到 ' . $value . PHP_EOL;
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        // 第二个then，接收到上一个then返回的值
        echo '第二步：处理结果 ' . $value . PHP_EOL;
        return "Processed: " . $value;
    })
    ->then(function ($value) {
        // 第三个then
        echo '第三步：最终结果 ' . $value . PHP_EOL;
    });

// 触发Promise的解析，启动链式调用
$promise->resolve('World');
/* 输出：
第一步：接收到 World
第二步：处理结果 Hello, World
第三步：最终结果 Processed: Hello, World
*/</code>

<code class="php">use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;

// 示例1: 同步等待成功结果
$promiseSuccess = new Promise(function () use (&$promiseSuccess) {
    // 模拟异步操作完成
    $promiseSuccess->resolve('成功的数据');
});
echo "同步等待成功结果: " . $promiseSuccess->wait() . PHP_EOL; // 输出：同步等待成功结果: 成功的数据

// 示例2: 同步等待失败结果
$promiseFail = new Promise(function () use (&$promiseFail) {
    // 模拟异步操作失败
    $promiseFail->reject('网络错误');
});
try {
    $promiseFail->wait();
} catch (\Exception $e) {
    echo "同步等待失败结果，捕获到异常: " . $e->getMessage() . PHP_EOL; // 输出：同步等待失败结果，捕获到异常: The promise was rejected with value: 网络错误
}

// 示例3: 错误传递与处理
$errorPromise = new Promise();
$errorPromise->then(null, function ($reason) {
    echo '捕获到错误: ' . $reason . PHP_EOL;
    throw new \Exception('在处理错误时又发生了新错误'); // 抛出新异常
})->then(null, function ($newReason) {
    echo '捕获到链中新错误: ' . $newReason->getMessage() . PHP_EOL; // 捕获到链中新错误: 在处理错误时又发生了新错误
});

$errorPromise->reject('原始错误');</code>