如何优雅地管理PHP异步操作？GuzzlePromises助你告别“回调地狱”

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

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

then()

then()

<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）状态，尚未有结果
echo "Promise 处于待定状态..." . PHP_EOL;

// 稍后，我们“解决”这个Promise，使其成功
$promise->resolve('Hello, World!');
// 输出：
// Promise 处于待定状态...
// Promise 成功兑现，值是: Hello, World!

then()

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 第一个then：处理初始值
        echo "第一步处理: " . $value . PHP_EOL;
        return "Hello, " . $value; // 返回的值将传递给下一个then
    })
    ->then(function ($value) {
        // 第二个then：处理上一步返回的值
        echo "第二步处理: " . $value . PHP_EOL;
        return strtoupper($value); // 再次返回一个值
    })
    ->then(function ($value) {
        // 第三个then：处理最终值
        echo "最终结果: " . $value . PHP_EOL;
    });

$promise->resolve('reader');
// 输出：
// 第一步处理: reader
// 第二步处理: Hello, reader
// 最终结果: HELLO, READER

then

then

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

$firstTask = new Promise();
$secondTask = new Promise();

$firstTask
    ->then(function ($value) use ($secondTask) {
        echo "任务A完成，准备启动任务B: " . $value . PHP_EOL;
        return $secondTask; // 返回一个新Promise，链条会等待它完成
    })
    ->then(function ($value) {
        echo "任务B完成，最终结果: " . $value . PHP_EOL;
    });

// 触发第一个任务
$firstTask->resolve('数据A');
// 此时，链条会等待 secondTask 完成
echo "等待第二个任务..." . PHP_EOL;

// 触发第二个任务
$secondTask->resolve('数据B');
// 输出：
// 任务A完成，准备启动任务B: 数据A
// 等待第二个任务...
// 任务B完成，最终结果: 数据B

onRejected

onRejected

RejectedPromise

onRejected

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

$promise = new Promise();

$promise
    ->then(null, function ($reason) {
        echo "捕获到错误: " . $reason . PHP_EOL;
        // 抛出异常或返回 RejectedPromise 会继续向下传递拒绝状态
        throw new \Exception("处理错误时又出错了: " . $reason);
    })
    ->then(null, function ($reason) {
        // 捕获到上一个then中抛出的异常
        echo "再次捕获到错误: " . $reason->getMessage() . PHP_EOL;
        // 如果这里不抛异常或返回RejectedPromise，后续的onFulfilled会被调用
        return "错误已处理，继续执行";
    })
    ->then(function ($value) {
        echo "从错误中恢复并继续: " . $value . PHP_EOL;
    });

$promise->reject('API调用失败');
// 输出：
// 捕获到错误: API调用失败
// 再次捕获到错误: 处理错误时又出错了: API调用失败
// 从错误中恢复并继续: 错误已处理，继续执行

wait()

wait()

<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(); // 会阻塞当前执行，直到Promise完成
echo "等待结束，结果是: " . $result . PHP_EOL;
// 输出：
// 开始等待...
// (等待1秒)
// 等待结束，结果是: 我等到了结果！

wait()

cancel()

cancel()

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

$promise = new Promise(
    function () use (&$promise) { /* 实际的异步任务 */ },
    function () {
        echo "Promise 被取消了！" . PHP_EOL;
        // 在这里执行取消任务的清理工作，例如关闭网络连接
    }
);

// 模拟异步任务还未完成时，用户取消了操作
$promise->cancel();
// 输出：Promise 被取消了！

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises