好的，这是一篇关于如何使用Composer和GuzzlePromises解决PHP异步操作痛点的博客文章。告别回调地狱：如何使用Composer和GuzzlePromises优雅地处理PHP异步操作

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

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

// 创建一个 Promise 实例
$promise = new Promise();

// 使用 then() 方法注册成功和失败的回调
$promise->then(
    // $onFulfilled: Promise 成功时执行
    function ($value) {
        echo "Promise 成功完成，值为: " . $value . PHP_EOL;
    },
    // $onRejected: Promise 失败时执行
    function ($reason) {
        echo "Promise 失败，原因为: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成，解决 Promise
$promise->resolve('Hello, Guzzle Promises!');
// 输出: Promise 成功完成，值为: Hello, Guzzle Promises!</code>

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

$promise = new Promise();

$promise
    // 第一个 then()，处理初始值
    ->then(function ($value) {
        echo "第一步：接收到值 - " . $value . PHP_EOL;
        // 返回一个新值，传递给下一个 then()
        return "经过处理的 " . $value;
    })
    // 第二个 then()，接收上一个 then() 返回的值
    ->then(function ($value) {
        echo "第二步：接收到新值 - " . $value . PHP_EOL;
        // 也可以返回另一个 Promise，实现异步操作的串联
        $nextPromise = new Promise();
        // 模拟一个延迟操作
        // sleep(1); // 实际异步操作中不会阻塞
        $nextPromise->resolve("最终结果");
        return $nextPromise; // 返回一个 Promise
    })
    // 第三个 then()，会等待第二个 then() 返回的 Promise 解决
    ->then(function ($value) {
        echo "第三步：接收到最终结果 - " . $value . PHP_EOL;
    });

// 解决初始 Promise，启动链式调用
$promise->resolve('原始数据');
/*
输出：
第一步：接收到值 - 原始数据
第二步：接收到新值 - 经过处理的 原始数据
第三步：接收到最终结果 - 最终结果
*/</code>

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

$promise = new Promise();

$promise->then(
    function ($value) {
        echo "成功: " . $value . PHP_EOL;
    },
    function ($reason) {
        echo "失败捕获: " . $reason . PHP_EOL;
        // 可以在这里处理错误，也可以抛出异常让下一个 then() 的 onRejected 捕获
        // throw new \Exception("新的错误: " . $reason);
        return "错误已被处理并恢复"; // 返回一个非 Promise 值，后续链会转为成功
    }
)->then(function ($value) {
    echo "链的后续步骤 (成功): " . $value . PHP_EOL;
}, function ($reason) {
    echo "链的后续步骤 (失败): " . $reason . PHP_EOL;
});

// 拒绝 Promise
$promise->reject('网络请求失败');
/*
输出：
失败捕获: 网络请求失败
链的后续步骤 (成功): 错误已被处理并恢复
*/</code>

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(2);
    $promise->resolve('数据已准备好');
});

echo "开始等待 Promise..." . PHP_EOL;
$result = $promise->wait(); // 阻塞当前执行，直到 Promise 解决
echo "Promise 完成，结果是: " . $result . PHP_EOL;
// 输出：
// 开始等待 Promise...
// (等待2秒)
// Promise 完成，结果是: 数据已准备好</code>

<code class="php">// 假设这些是返回 Promise 的函数
function payOrder($orderId) {
    return new GuzzleHttp\Promise\Promise(function ($resolve, $reject) use ($orderId) {
        // 模拟支付 API 调用
        sleep(1); // 假设支付需要1秒
        if (rand(0, 1)) { // 50% 成功率
            $resolve("订单 {$orderId} 支付成功");
        } else {
            $reject("订单 {$orderId} 支付失败");
        }
    });
}

function sendConfirmationEmail($email, $orderInfo) {
    return new GuzzleHttp\Promise\Promise(function ($resolve) use ($email, $orderInfo) {
        // 模拟发送邮件
        sleep(0.5); // 假设发送邮件需要0.5秒
        $resolve("邮件已发送至 {$email}");
    });
}

function updateInventory($items) {
    return new GuzzleHttp\Promise\Promise(function ($resolve) use ($items) {
        // 模拟更新库存
        sleep(0.8); // 假设更新库存需要0.8秒
        $resolve("库存已更新");
    });
}

// 模拟一个下单流程
$orderId = 'ORD' . uniqid();
$userEmail = 'user@example.com';
$orderItems = ['itemA' => 2, 'itemB' => 1];

echo "开始处理订单 {$orderId}..." . PHP_EOL;

// 支付操作（可能失败）
$payPromise = payOrder($orderId);

// 邮件和库存更新可以并行进行，不依赖支付结果，但通常会依赖支付成功
// 这里为了演示 Promise.all 的概念，假设它们可以独立开始
$emailPromise = sendConfirmationEmail($userEmail, ['orderId' => $orderId]);
$inventoryPromise = updateInventory($orderItems);

// 使用 Promise::all 等待所有并行操作完成
// 注意：Promise::all 是 GuzzleHttp\Promise\Utils::all，通常与 Guzzle HTTP 客户端一起使用
// 这里为了演示概念，我们手动组合并等待
$allPromises = [
    'payment' => $payPromise,
    'email' => $emailPromise,
    'inventory' => $inventoryPromise,
];

// 创建一个主 Promise，等待所有子 Promise 完成
$mainPromise = new GuzzleHttp\Promise\Promise(function ($resolve, $reject) use ($allPromises) {
    $results = [];
    $errors = [];
    $completedCount = 0;
    $totalPromises = count($allPromises);

    foreach ($allPromises as $key => $promise) {
        $promise->then(
            function ($value) use (&$results, &$completedCount, $key, $totalPromises, $resolve, $reject) {
                $results[$key] = $value;
                $completedCount++;
                if ($completedCount === $totalPromises) {
                    $resolve($results); // 所有 Promise 都成功，解决主 Promise
                }
            },
            function ($reason) use (&$errors, &$completedCount, $key, $totalPromises, $resolve, $reject) {
                $errors[$key] = $reason;
                $completedCount++;
                // 如果有任何一个失败，主 Promise 就失败
                $reject($errors);
            }
        );
    }
});

$mainPromise->then(
    function ($results) {
        echo "所有异步操作成功完成！" . PHP_EOL;
        print_r($results);
    },
    function ($errors) {
        echo "部分异步操作失败！" . PHP_EOL;
        print_r($errors);
    }
)->wait(); // 同步等待所有操作完成

echo "订单处理流程结束。" . PHP_EOL;</code>