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

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

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

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 创建一个Promise对象
$promise = new Promise();

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

echo "异步操作正在进行中...\n";

// 在某个时刻，异步操作完成，并兑现Promise
$promise->resolve('Hello, Guzzle Promises!');

echo "主程序继续执行其他任务。\n";

<pre class="brush:php;toolbar:false;">异步操作正在进行中...
Promise 成功兑现，值是: Hello, Guzzle Promises!
主程序继续执行其他任务。

<pre class="brush:php;toolbar:false;"><?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 ($value) {
        echo "第二步：接收到上一步的值 - " . $value . PHP_EOL;
        // 也可以返回一个新的Promise，后续链会等待这个Promise完成
        $anotherPromise = new Promise();
        // 模拟异步操作
        \GuzzleHttp\Promise\Utils::queue()->add(function () use ($anotherPromise) {
            $anotherPromise->resolve('来自另一个Promise的数据');
        });
        return $anotherPromise;
    })
    ->then(function ($value) {
        echo "第三步：接收到嵌套Promise的值 - " . $value . PHP_EOL;
    });

echo "开始解析Promise...\n";
$promise->resolve('原始数据');
// 在异步场景下，你需要运行任务队列来确保回调被执行
\GuzzleHttp\Promise\Utils::queue()->run();
echo "所有Promise链已处理。\n";

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

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "成功回调，但这里抛出异常！" . PHP_EOL;
        throw new Exception("第一步操作失败");
    })
    ->otherwise(function ($reason) {
        echo "捕获到异常： " . $reason->getMessage() . PHP_EOL;
        // 也可以在这里返回一个新的RejectedPromise来继续转发拒绝状态
        // return new RejectedPromise("更深层次的错误");
        // 或者返回一个普通值，使后续链转为成功状态
        return "错误已处理，继续前进";
    })
    ->then(function ($value) {
        echo "异常处理后，链条继续成功执行，接收到值： " . $value . PHP_EOL;
    }, function ($reason) {
        echo "如果上一步返回RejectedPromise，这里会捕获到新的拒绝： " . $reason . PHP_EOL;
    });

$promise->resolve('初始值');
\GuzzleHttp\Promise\Utils::queue()->run();

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

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

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

echo "开始等待 Promise 完成...\n";
$result = $promise->wait(); // 会阻塞1秒
echo "Promise 同步完成，结果是: " . $result . PHP_EOL;

// 尝试取消一个Promise
$cancellablePromise = new Promise(
    function () { /* 模拟一些工作 */ },
    function () {
        echo "Promise 被取消了！" . PHP_EOL;
    }
);

echo "尝试取消 Promise...\n";
$cancellablePromise->cancel();
// 再次调用wait会抛出RejectionException，因为Promise已被取消
try {
    $cancellablePromise->wait();
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "捕获到取消导致的拒绝异常: " . $e->getMessage() . PHP_EOL;
}