告别回调地狱与阻塞等待：如何使用GuzzlePromises优雅地处理PHP异步操作

curl_multi_exec

<pre class="brush:php;toolbar:false;">// 伪代码：深层嵌套的回调
fetchUserData(function ($userData) {
    processUserData($userData, function ($processedUser) {
        fetchOrders(function ($orders) use ($processedUser) {
            processOrders($orders, function ($processedOrders) use ($processedUser) {
                fetchAnalytics(function ($analytics) use ($processedUser, $processedOrders) {
                    // ... 更多嵌套，错误处理更是一团糟
                    displayDashboard($processedUser, $processedOrders, $analytics);
                });
            });
        });
    });
});

guzzlehttp/promises

Promise

fulfilled

rejected

guzzlehttp/promises

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

then()

$onFulfilled

$onRejected

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

$promise = new Promise();

$promise->then(
    function ($value) {
        echo "操作成功，得到值: " . $value . "\n";
    },
    function ($reason) {
        echo "操作失败，原因: " . $reason . "\n";
    }
);

// 模拟异步操作完成
// $promise->resolve('这是成功的结果'); // 输出：操作成功，得到值: 这是成功的结果
// $promise->reject('出错了！');      // 输出：操作失败，原因: 出错了！

then()

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步成功，接收到: " . $value . "\n";
        return "Hello, " . $value; // 返回一个新值，传递给下一个 then
    })
    ->then(function ($value) {
        echo "第二步成功，接收到: " . $value . "\n";
        // 如果这里返回另一个 Promise，下一个 then 会等待它完成
        return new FulfilledPromise($value . " World!");
    })
    ->then(function ($value) {
        echo "第三步成功，接收到: " . $value . "\n";
        return $value;
    });

$promise->resolve('Reader'); // 触发整个链条
// 预期输出：
// 第一步成功，接收到: Reader
// 第二步成功，接收到: Hello, Reader
// 第三步成功，接收到: Hello, Reader World!

then

then

reject()

onFulfilled

onRejected

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步成功: " . $value . "\n";
        throw new Exception("在第一步中发生了一个错误！"); // 抛出异常
    })
    ->then(
        function ($value) {
            echo "这一步不会执行\n";
        },
        function ($reason) {
            echo "在第二步捕获到错误: " . $reason->getMessage() . "\n";
            // 你可以选择在这里返回一个值，使后续链条恢复正常
            // 或者继续抛出异常，让错误继续向下传递
            return "从错误中恢复";
        }
    )
    ->then(function ($value) {
        echo "第三步成功，接收到: " . $value . "\n";
    });

$promise->resolve('开始');
// 预期输出：
// 第一步成功: 开始
// 在第二步捕获到错误: 在第一步中发生了一个错误！
// 第三步成功，接收到: 从错误中恢复

otherwise()

then(null, $onRejected)

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

$promise = new Promise();

$promise
    ->then(function () {
        throw new Exception("发生错误！");
    })
    ->otherwise(function ($reason) { // 专门用于处理拒绝的回调
        echo "捕获到错误: " . $reason->getMessage() . "\n";
        return "已处理的错误";
    })
    ->then(function ($value) {
        echo "错误处理后继续: " . $value . "\n";
    });

$promise->resolve('start');

wait()

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

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

echo "程序继续执行...\n";
$result = $promise->wait(); // 这里会阻塞程序执行，直到 Promise 完成
echo "获取到异步结果: " . $result . "\n";

// 如果 Promise 被拒绝，wait() 会抛出异常
$rejectedPromise = new Promise();
$rejectedPromise->reject('哦，不，失败了！');
try {
    $rejectedPromise->wait();
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "捕获到拒绝异常: " . $e->getReason() . "\n";
}

wait()

wait(false)

cancel()

cancelFn

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

$promise = new Promise(
    function () use (&$promise) {
        // 实际的异步操作逻辑
        // ...
        // $promise->resolve('完成');
    },
    function () {
        echo "Promise 被取消了！\n";
        // 执行清理操作，停止异步任务
    }
);

// 模拟在 Promise 完成前取消它
// $promise->cancel(); // 输出：Promise 被取消了！

guzzlehttp/promises

guzzlehttp/promises