告别阻塞！如何使用Composer与GuzzlePromises优化PHP异步操作

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

vendor/

composer.json

composer.lock

fulfilled

rejected

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

$promise = new Promise();

$promise->then(
    // $onFulfilled: 操作成功时调用
    function ($value) {
        echo "操作成功，结果是: " . $value . PHP_EOL;
    },
    // $onRejected: 操作失败时调用
    function ($reason) {
        echo "操作失败，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟异步操作完成并成功
$promise->resolve('数据已获取'); // 输出: 操作成功，结果是: 数据已获取

// 模拟异步操作完成并失败
// $promise->reject('网络错误'); // 输出: 操作失败，原因是: 网络错误

resolve($value)

reject($reason)

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：处理数据 " . $value . PHP_EOL;
        return $value . " 处理完成"; // 返回值会传递给下一个 then
    })
    ->then(function ($value) {
        echo "第二步：进一步处理 " . $value . PHP_EOL;
        // 可以在这里返回一个新的 Promise，实现更复杂的异步流程
        $anotherPromise = new Promise();
        $anotherPromise->resolve('最终结果');
        return $anotherPromise;
    })
    ->then(function ($value) {
        echo "第三步：获取到最终结果 " . $value . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中任何一个环节的错误
        echo "链中发生错误：" . $reason . PHP_EOL;
    });

$promise->resolve('原始数据');
// 输出：
// 第一步：处理数据 原始数据
// 第二步：进一步处理 原始数据 处理完成
// 第三步：获取到最终结果 最终结果

then(null, $onRejected)

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决 Promise
    sleep(1);
    $promise->resolve('等待结果');
});

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 脚本会在这里阻塞1秒
echo "等待结束，结果是: " . $result . PHP_EOL; // 输出：等待结束，结果是: 等待结果

try-catch

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Client;
use GuzzleHttp\Promise\Utils; // 注意这里使用了 Utils

$client = new Client();

// 创建多个异步请求的 Promise
$promises = [
    'google' => $client->getAsync('https://www.google.com/'),
    'bing' => $client->getAsync('https://www.bing.com/'),
    'example' => $client->getAsync('https://www.example.com/'),
];

echo "开始并行发送请求..." . PHP_EOL;

// 使用 Utils::all() 等待所有 Promise 完成
// 这会返回一个新的 Promise，当所有子 Promise 都成功时，它才会成功
// 如果任何一个子 Promise 失败，它就会失败
$results = Utils::all($promises)->wait();

echo "所有请求完成！" . PHP_EOL;

foreach ($results as $key => $response) {
    echo "请求 {$key} 的状态码: " . $response->getStatusCode() . PHP_EOL;
}

// 也可以使用 Utils::some() 来等待指定数量的 Promise 完成
// Utils::some(2, $promises)->wait(); // 等待其中任意2个完成

GuzzleHttp\Promise\Utils::all($promises)->wait()