PHP异步编程的利器：如何使用GuzzlePromises解决“回调地狱”与提升应用响应速度

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

<pre class="brush:php;toolbar:false">// 伪代码：假设这些是异步函数
asyncOperation1(function($result1) {
    asyncOperation2($result1, function($result2) {
        asyncOperation3($result2, function($result3) {
            // ... 更多嵌套
        });
    });
});

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

// 假设我们有一个模拟的异步操作，最终会返回一个值
$promise = new Promise();

$promise
    ->then(function ($value) {
        // 第一个异步操作完成，返回一个新值或新的Promise
        echo "第一步完成，接收到：{$value}\n";
        return "Hello, " . $value; // 将结果传递给下一个then
    })
    ->then(function ($value) {
        // 第二个异步操作完成，接收到上一步的返回值
        echo "第二步完成，接收到：{$value}\n";
        // 如果这里返回另一个Promise，链条会等待那个Promise完成
        // return new AnotherPromise();
    })
    ->then(function ($value) {
        echo "所有异步操作完成，最终结果：{$value}\n";
    });

// 模拟异步操作完成，兑现Promise
$promise->resolve('reader.');
// 输出：
// 第一步完成，接收到：reader.
// 第二步完成，接收到：Hello, reader.
// 所有异步操作完成，最终结果：Hello, reader.

$onRejected

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

$promise = new Promise();
$promise->then(
    null, // 成功回调为null
    function ($reason) {
        echo "Promise被拒绝了，原因：{$reason}\n";
    }
);

$promise->reject('API调用失败，请检查网络！');
// 输出：Promise被拒绝了，原因：API调用失败，请检查网络！

RejectedPromise

wait()

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终兑现Promise
    sleep(1); // 模拟1秒延迟
    $promise->resolve('这是异步获取的数据');
});

echo "等待Promise完成...\n";
try {
    $result = $promise->wait(); // 同步等待，直到Promise完成
    echo "获取到结果：{$result}\n";
} catch (\Exception $e) {
    echo "Promise被拒绝了：{$e->getMessage()}\n";
}
// 输出：
// 等待Promise完成...
// 获取到结果：这是异步获取的数据

cancel()

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

$client = new Client();

$promises = [
    'google' => $client->getAsync('https://www.google.com'),
    'baidu'  => $client->getAsync('https://www.baidu.com'),
];

// 等待所有Promise完成
$results = Utils::settle($promises)->wait();

foreach ($results as $name => $result) {
    if ($result['state'] === 'fulfilled') {
        echo "{$name} 成功，状态码：{$result['value']->getStatusCode()}\n";
    } else {
        echo "{$name} 失败，原因：{$result['reason']->getMessage()}\n";
    }
}