如何解决PHP异步任务的阻塞与回调地狱，GuzzlePromises助你构建高效优雅的应用

<pre class="brush:php;toolbar:false;">callPaymentApi(function ($paymentResult) {
    if ($paymentResult->success) {
        updateInventory(function ($inventoryResult) {
            if ($inventoryResult->success) {
                sendShippingRequest(function ($shippingResult) {
                    if ($shippingResult->success) {
                        sendNotification(function ($notificationResult) {
                            // ... 天哪，这代码还能看吗？
                        });
                    }
                });
            }
        });
    }
});

guzzlehttp/promises

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

Promise

then()

resolve()

reject()

<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";
    }
);

// 模拟异步操作完成并成功
// 实际中，这可能在一个非阻塞的I/O操作完成后调用
$promise->resolve('订单已创建'); // 输出: 操作成功，得到值: 订单已创建

// 模拟异步操作完成并失败
// $promise->reject('支付失败'); // 如果调用这个，会输出: 操作失败，原因: 支付失败

then()

then()

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

$orderPromise = new Promise();

$orderPromise
    ->then(function ($orderId) {
        echo "1. 订单创建成功，ID: " . $orderId . "\n";
        // 假设这里调用支付API，并返回一个新的Promise
        return new Promise(function ($resolve, $reject) use ($orderId) {
            echo "2. 开始调用支付服务...\n";
            // 模拟支付成功
            sleep(1); // 模拟耗时操作
            $resolve("支付成功 for order " . $orderId);
        });
    })
    ->then(function ($paymentResult) {
        echo "3. " . $paymentResult . "\n";
        // 假设这里更新库存，并返回一个普通值
        echo "4. 更新库存中...\n";
        sleep(0.5);
        return "库存已更新";
    })
    ->then(function ($inventoryResult) {
        echo "5. " . $inventoryResult . "\n";
        echo "6. 所有核心操作完成！\n";
    })
    ->otherwise(function ($reason) { // 统一捕获链中任何环节的错误
        echo "操作链中发生错误: " . $reason . "\n";
    });

// 启动订单创建流程
$orderPromise->resolve('ORD12345');

// 注意：在实际异步环境中，你可能需要一个事件循环来驱动Promise的执行
// 但对于同步等待的场景，Promise会在wait()时自动驱动

then()

GuzzleHttp\Promise

wait()

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

$dataPromise = new Promise(function () use (&$dataPromise) {
    echo "模拟从数据库加载数据...\n";
    sleep(2); // 模拟数据库查询耗时
    $dataPromise->resolve(['item1', 'item2']);
});

echo "程序继续执行，不等待数据加载。\n";

// 在需要数据时，同步等待Promise完成
$data = $dataPromise->wait(); // 此时程序会阻塞，直到$dataPromise被resolve或reject
echo "获取到的数据: " . implode(', ', $data) . "\n";

wait()

cancel()

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

$longRunningTask = new Promise(
    function () use (&$longRunningTask) {
        // 模拟一个长时间运行的任务，最终会resolve
        sleep(5);
        $longRunningTask->resolve('任务完成');
    },
    function () {
        echo "任务被取消了！\n";
        // 这里可以执行清理操作
    }
);

// 假设3秒后我们决定取消这个任务
sleep(3);
$longRunningTask->cancel(); // 如果任务未完成，会触发cancel回调

// 尝试等待，如果被取消，wait会抛出异常
try {
    echo $longRunningTask->wait();
} catch (\Exception $e) {
    echo "Wait抛出异常: " . $e->getMessage() . "\n";
}

guzzlehttp/promises