PHP中复杂异步操作的回调地狱与阻塞困境：GuzzlePromises如何优雅化解

<pre class="brush:php;toolbar:false;">// 伪代码示例，实际会阻塞
$productInfo = fetchProductDetails($productId); // 等待完成
$reviews = fetchProductReviews($productId);     // 等待完成
$stock = fetchStockStatus($productId);         // 等待完成
$recommendations = fetchRecommendations($userId); // 等待完成

// 组合数据并渲染

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;

// 模拟一个异步操作，例如一个耗时的数据库查询或外部API请求
function asyncOperation(string $data): Promise
{
    $promise = new Promise();
    // 假设这里是异步执行的代码，例如通过一个非阻塞I/O库
    // 简化起见，我们直接在几毫秒后resolve或reject
    \GuzzleHttp\Promise\Utils::queue()->add(function () use ($promise, $data) {
        if (str_contains($data, 'error')) {
            $promise->reject("Error processing: " . $data);
        } else {
            $promise->resolve("Processed: " . $data);
        }
    });
    return $promise;
}

$initialPromise = asyncOperation('input_data');

$initialPromise
    ->then(function ($value) {
        echo "第一步成功: " . $value . "\n";
        // 返回一个新的Promise，将结果传递给下一个then
        return asyncOperation($value . '_step2');
    })
    ->then(function ($value) {
        echo "第二步成功: " . $value . "\n";
        return $value . '_final';
    })
    ->then(function ($finalValue) {
        echo "所有步骤完成，最终结果: " . $finalValue . "\n";
    })
    ->otherwise(function ($reason) { // 统一捕获链中任何环节的拒绝
        echo "操作失败: " . $reason . "\n";
    });

// 确保异步任务队列被执行 (在实际异步环境中，这通常由事件循环处理)
\GuzzleHttp\Promise\Utils::queue()->run();

then()

reject($reason)

otherwise()

then(null, $onRejected)

onFulfilled

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

$failingPromise = new Promise();
$failingPromise
    ->then(function ($value) {
        // 这段代码不会执行，因为Promise会被拒绝
        return "Success: " . $value;
    })
    ->otherwise(function ($reason) {
        echo "捕获到拒绝: " . $reason . "\n";
        throw new \Exception("进一步处理错误: " . $reason); // 抛出异常会传递给下一个otherwise
    })
    ->otherwise(function (\Exception $e) {
        echo "捕获到异常: " . $e->getMessage() . "\n";
    });

$failingPromise->reject('Something went wrong!');
\GuzzleHttp\Promise\Utils::queue()->run();

wait()

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个最终会解决的异步任务
    \GuzzleHttp\Promise\Utils::queue()->add(function () use ($promise) {
        sleep(1); // 模拟耗时
        $promise->resolve('Hello, Guzzle Promises!');
    });
});

echo "等待Promise完成...\n";
try {
    $result = $promise->wait(); // 阻塞直到Promise解决
    echo "Promise结果: " . $result . "\n";
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "Promise被拒绝: " . $e->getReason() . "\n";
}

echo "Promise已完成，脚本继续执行。\n";
\GuzzleHttp\Promise\Utils::queue()->run(); // 确保队列中的任务被执行

wait()