如何解决PHP异步操作的“回调地狱”与效率瓶颈，GuzzlePromises助你优雅驾驭并发！

<pre class="brush:php;toolbar:false;">// 伪代码：传统同步请求
$data1 = callApi1(); // 等待API1响应
$data2 = callApi2(); // 等待API2响应
$data3 = callApi3(); // 等待API3响应

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

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

<pre class="brush:php;toolbar:false;">use GuzzleHttp\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仍处于pending状态
// ... 模拟一些异步操作 ...

// 假设异步操作成功，我们手动解决Promise
$promise->resolve('这是异步操作的结果！');
// 输出: Promise 成功，结果是: 这是异步操作的结果！

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 第一个then，接收初始值
        echo "步骤1：接收到 " . $value . PHP_EOL;
        return "Hello, " . $value; // 返回的值会传递给下一个then
    })
    ->then(function ($value) {
        // 第二个then，接收上一个then的返回值
        echo "步骤2：处理后的值是 " . $value . PHP_EOL;
        return $value . " World!";
    })
    ->then(function ($value) {
        // 第三个then
        echo "步骤3：最终结果是 " . $value . PHP_EOL;
    });

// 解决初始Promise，触发链式调用
$promise->resolve('Reader');

/* 输出:
步骤1：接收到 Reader
步骤2：处理后的值是 Hello, Reader
步骤3：最终结果是 Hello, Reader World!
*/

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "成功回调，但这里将抛出异常！" . PHP_EOL;
        throw new \Exception('Oops, something went wrong!');
    })
    ->then(null, function ($reason) { // 捕获上一个then抛出的异常
        echo "捕获到错误: " . $reason->getMessage() . PHP_EOL;
        return "从错误中恢复！"; // 返回一个非Promise值，链条将转为成功状态
    })
    ->then(function ($value) {
        echo "错误处理后，链条继续成功: " . $value . PHP_EOL;
    });

$promise->resolve('初始值');

/* 输出:
成功回调，但这里将抛出异常！
捕获到错误: Oops, something went wrong!
错误处理后，链条继续成功: 从错误中恢复！
*/

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

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

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 阻塞1秒，直到Promise解决
echo "等待结束，结果是: " . $result . PHP_EOL;
// 输出:
// 开始等待...
// 等待结束，结果是: 我等到了！

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;

$promise = new Promise(
    function () use (&$promise) {
        // 这是一个会执行的waitFn
        sleep(5); // 模拟一个很长的操作
        $promise->resolve('操作完成');
    },
    function () {
        // 这是一个cancelFn，当promise被取消时执行
        echo "Promise 被取消了！" . PHP_EOL;
    }
);

// 模拟在短时间内取消Promise
echo "尝试取消Promise..." . PHP_EOL;
$promise->cancel();

try {
    $promise->wait(); // 此时wait会抛出异常，因为Promise已取消
} catch (\Exception $e) {
    echo "捕获到异常: " . $e->getMessage() . PHP_EOL;
}
/* 输出:
尝试取消Promise...
Promise 被取消了！
捕获到异常: The promise was cancelled
*/