如何解决PHP异步操作的“回调地狱”与阻塞问题？GuzzlePromises助你构建高效非阻塞应用

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

GuzzleHttp\Promise\Promise

guzzlehttp/promises

then()

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步完成，接收到：{$value}\n";
        // 返回一个新的值或另一个 Promise，传递给下一个 then
        return "从第一步处理后的数据";
    })
    ->then(function ($value) {
        echo "第二步完成，接收到：{$value}\n";
        return "最终处理结果";
    })
    ->then(function ($value) {
        echo "所有步骤完成，最终结果是：{$value}\n";
    });

// 模拟异步操作完成，解决 Promise
// 这会触发链式回调的执行
$promise->resolve('初始数据');
// 输出：
// 第一步完成，接收到：初始数据
// 第二步完成，接收到：从第一步处理后的数据
// 所有步骤完成，最终结果是：最终处理结果

guzzlehttp/promises

guzzlehttp/promises

then(null, $onRejected)

otherwise()

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "尝试第一步：{$value}\n";
        // 模拟一个错误发生
        throw new \Exception("第一步操作失败！");
    })
    ->then(function ($value) {
        echo "这一步不会执行，因为前面出错了。\n";
        return $value;
    }, function ($reason) { // 错误处理回调
        echo "捕获到错误：{$reason->getMessage()}\n";
        // 从错误中恢复，并返回一个新值，让后续的 onFulfilled 回调继续执行
        return "从错误中恢复的数据";
    })
    ->then(function ($value) {
        echo "错误处理后继续执行：{$value}\n";
    });

// 触发 Promise 链
$promise->resolve('开始执行');
// 输出：
// 尝试第一步：开始执行
// 捕获到错误：第一步操作失败！
// 错误处理后继续执行：从错误中恢复的数据

onRejected

onRejected

RejectedPromise

wait()

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1); // 模拟1秒延迟
    $promise->resolve('异步操作完成！');
});

echo "程序开始执行...\n";
$result = $promise->wait(); // 在这里同步等待 Promise 完成
echo "异步操作的结果是：{$result}\n";
echo "程序继续执行...\n";
// 输出：
// 程序开始执行...
// (等待1秒)
// 异步操作的结果是：异步操作完成！
// 程序继续执行...

guzzlehttp/promises

cancel()

cancel()

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

$promise = new Promise(
    function () use (&$promise) {
        // 模拟一个耗时操作，如果没被取消，最终会解决
        sleep(2);
        $promise->resolve('任务完成');
    },
    function () {
        // 取消逻辑，例如关闭网络连接、停止数据库查询等
        echo "任务被取消了！\n";
    }
);

echo "任务开始...\n";
// 假设在某个条件触发下，我们决定取消这个任务
// 比如用户点击了“取消”按钮
$promise->cancel();
// 尝试等待，此时会因为取消而抛出异常或返回取消状态
try {
    $promise->wait();
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "等待时捕获到异常：" . $e->getMessage() . "\n";
}
// 输出：
// 任务开始...
// 任务被取消了！
// 等待时捕获到异常：The promise was rejected with value: The promise was cancelled

guzzlehttp/promises

guzzlehttp/promises