告别PHP异步编程的“回调地狱”：用Composer与GuzzlePromises重构你的代码

// 伪代码：传统方式处理依赖的API调用
$result1 = callApi1();
if ($result1->success) {
    $result2 = callApi2($result1->data);
    if ($result2->success) {
        $result3 = callApi3($result2->data);
        if ($result3->success) {
            // ... 更多嵌套
        } else {
            // 处理API3错误
        }
    } else {
        // 处理API2错误
    }
} else {
    // 处理API1错误
}

composer require guzzlehttp/promises

use GuzzleHttp\Promise\Promise;

// 模拟异步操作
function asyncApiCall1($data) {
    $promise = new Promise();
    // 假设这是异步操作，例如发送HTTP请求
    // 成功时调用 $promise->resolve($result);
    // 失败时调用 $promise->reject($reason);
    // 这里我们模拟立即解决
    if ($data === 'start') {
        $promise->resolve('data_from_api1');
    } else {
        $promise->reject('Error from API1');
    }
    return $promise;
}

function asyncApiCall2($data) {
    $promise = new Promise();
    if ($data === 'data_from_api1') {
        $promise->resolve('data_from_api2');
    } else {
        $promise->reject('Error from API2');
    }
    return $promise;
}

function asyncApiCall3($data) {
    $promise = new Promise();
    if ($data === 'data_from_api2') {
        $promise->resolve('final_result');
    } else {
        $promise->reject('Error from API3');
    }
    return $promise;
}

$initialPromise = asyncApiCall1('start');

$initialPromise
    ->then(function ($value) {
        echo "API1 成功，获取到: " . $value . "\n";
        return asyncApiCall2($value); // 返回一个新的Promise，继续链式调用
    })
    ->then(function ($value) {
        echo "API2 成功，获取到: " . $value . "\n";
        return asyncApiCall3($value); // 再次返回Promise
    })
    ->then(function ($value) {
        echo "API3 成功，最终结果: " . $value . "\n";
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节的错误
        echo "操作失败，原因: " . $reason . "\n";
    });

// 注意：在没有事件循环的同步PHP脚本中，你需要手动触发Promise的执行
// Guzzle Promises 会在必要时自动运行内部的任务队列来解决Promise
// 对于简单的示例，通常会自动解决。对于复杂的异步IO，你可能需要配合事件循环。
// 例如：$promise->wait(); // 如果你需要等待结果，但通常推荐非阻塞方式

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作后解决Promise
    sleep(1); // 暂停1秒
    $promise->resolve('Hello, World!');
});

echo "等待Promise完成...\n";
try {
    $result = $promise->wait(); // 强制等待Promise完成并获取结果
    echo "Promise 已完成，结果: " . $result . "\n";
} catch (\Exception $e) {
    echo "Promise 失败，原因: " . $e->getMessage() . "\n";
}