告别PHP异步操作的“回调地狱”：如何使用GuzzlePromises优雅地管理异步任务

<code class="php">$user = $userService->getUser($userId); // 阻塞等待
if ($user) {
    $orders = $orderService->getOrders($user->id); // 阻塞等待
    $stockA = $stockService->checkStock('itemA'); // 阻塞等待
    $stockB = $stockService->checkStock('itemB'); // 阻塞等待
    // ... 更多操作
}
// 整合数据并返回</code>

<code class="php">$userService->getUser($userId, function($user) use ($orderService, $stockService) {
    $orderService->getOrders($user->id, function($orders) use ($stockService) {
        $stockService->checkStock('itemA', function($stockA) use ($stockService) {
            $stockService->checkStock('itemB', function($stockB) {
                // 在这里处理所有数据，代码可读性极差
            });
        });
    });
});</code>

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

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

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

// 模拟异步操作完成
// $promise->resolve('数据已获取'); // 输出：操作成功，结果是: 数据已获取
$promise->reject('网络连接超时'); // 输出：操作失败，原因是: 网络连接超时</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($userId) {
        echo "第一步：获取到用户ID: " . $userId . "\n";
        // 模拟调用订单服务，返回一个新的Promise
        return new Promise(function ($resolve, $reject) use ($userId) {
            // 假设这里是异步调用
            if ($userId === 123) {
                $resolve(['order1', 'order2']);
            } else {
                $reject('用户无订单');
            }
        });
    })
    ->then(function ($orders) {
        echo "第二步：获取到订单列表: " . implode(', ', $orders) . "\n";
        // 模拟并行检查库存，返回一个 Promise 数组或 Promise::all()
        return new Promise(function ($resolve) {
            $resolve(['itemA_stock' => 10, 'itemB_stock' => 5]);
        });
    })
    ->then(function ($stockData) {
        echo "第三步：获取到库存数据: " . json_encode($stockData) . "\n";
        return "所有数据已整合！";
    })
    ->then(function ($finalResult) {
        echo "第四步：最终结果: " . $finalResult . "\n";
    })
    ->otherwise(function ($reason) { // 统一的错误处理
        echo "操作链中途失败，原因: " . $reason . "\n";
    });

// 启动第一个Promise
$promise->resolve(123); // 尝试用用户ID 123 触发成功流程
// $promise->resolve(456); // 尝试用用户ID 456 触发失败流程</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise(function ($resolve) {
    // 模拟一个耗时操作
    sleep(1);
    $resolve('操作完成！');
});

echo "等待Promise完成...\n";
$result = $promise->wait(); // 阻塞当前执行，直到Promise完成
echo "Promise结果: " . $result . "\n";</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        if ($value === 'error') {
            throw new \Exception("故意抛出错误");
        }
        return "处理成功: " . $value;
    })
    ->then(function ($result) {
        echo $result . "\n";
    })
    ->otherwise(function (\Exception $e) {
        echo "捕获到异常: " . $e->getMessage() . "\n";
    });

$promise->resolve('error'); // 触发错误
// $promise->resolve('success'); // 正常执行</code>