如何解决PHP异步操作的复杂性与效率问题，使用GuzzlePromises轻松驾驭异步编程

<pre class="brush:php;toolbar:false;">// 伪代码：同步调用多个API
$data1 = callApi1(); // 等待
$data2 = callApi2(); // 等待
$data3 = callApi3(); // 等待

processData($data1, $data2, $data3);

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

<pre class="brush:php;toolbar:false;"><?php

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

// 注册成功和失败的回调
$promise->then(
    // $onFulfilled: 成功时执行
    function ($value) {
        echo 'Promise 成功完成，值为: ' . $value . PHP_EOL;
    },
    // $onRejected: 失败时执行
    function ($reason) {
        echo 'Promise 被拒绝，原因为: ' . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成，解决 Promise
$promise->resolve('这是异步操作的结果！');
// 输出: Promise 成功完成，值为: 这是异步操作的结果！

// 另一个例子：拒绝 Promise
$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) {
    echo '另一个 Promise 被拒绝，原因为: ' . $reason . PHP_EOL;
});
$anotherPromise->reject('异步操作失败了！');
// 输出: 另一个 Promise 被拒绝，原因为: 异步操作失败了！

<pre class="brush:php;toolbar:false;"><?php

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步完成，接收到: " . $value . PHP_EOL;
        // 返回一个新的值，它将传递给下一个 then
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        echo "第二步完成，接收到: " . $value . PHP_EOL;
        // 返回一个 Promise，下一个 then 将等待这个 Promise 完成
        $nextPromise = new Promise();
        $nextPromise->resolve("World!");
        return $nextPromise;
    })
    ->then(function ($value) {
        echo "第三步完成，接收到: " . $value . PHP_EOL;
    });

// 解决初始 Promise，触发整个链条
$promise->resolve('reader');
/*
输出:
第一步完成，接收到: reader
第二步完成，接收到: Hello, reader
第三步完成，接收到: World!
*/

<pre class="brush:php;toolbar:false;"><?php

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1);
    $promise->resolve('foo');
});

echo "开始等待 Promise..." . PHP_EOL;
$result = $promise->wait(); // 阻塞，直到 Promise 完成
echo "Promise 完成，结果是: " . $result . PHP_EOL;
// 输出: 开始等待 Promise... (等待1秒) Promise 完成，结果是: foo

// 处理拒绝的 Promise
$rejectedPromise = new Promise();
$rejectedPromise->reject('异步操作失败了！');

try {
    $rejectedPromise->wait(); // 这会抛出异常
} catch (RejectionException $e) {
    echo "捕获到拒绝异常: " . $e->getReason() . PHP_EOL;
}
// 输出: 捕获到拒绝异常: 异步操作失败了！

<pre class="brush:php;toolbar:false;"><?php

use GuzzleHttp\Promise\Promise;

$promise = new Promise(
    function () use (&$promise) {
        // 模拟一个长时间运行的任务，最终会解决 Promise
        // ...
        $promise->resolve('任务完成');
    },
    function () {
        // 取消逻辑：例如关闭数据库连接、终止外部请求等
        echo "Promise 被取消了！" . PHP_EOL;
    }
);

// 假设在某个条件触发下，我们决定取消这个 Promise
$promise->cancel();
// 输出: Promise 被取消了！