如何解决PHP异步编程的性能瓶颈？GuzzlePromises助你驾驭并发提升效率

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

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

$promise = new Promise();

$promise->then(
    // $onFulfilled: 当Promise成功兑现时执行
    function ($value) {
        echo '操作成功，结果是: ' . $value . "\n";
    },
    // $onRejected: 当Promise被拒绝时执行
    function ($reason) {
        echo '操作失败，原因是: ' . $reason . "\n";
    }
);

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

// 如果是失败
// $promise->reject('网络连接失败');
// 输出: 操作失败，原因是: 网络连接失败

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

$initialPromise = new Promise();

$initialPromise
    ->then(function ($value) {
        echo "第一步：处理初始值 '{$value}'\n";
        // 返回一个新值，传递给下一个then
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        echo "第二步：处理上一步的结果 '{$value}'\n";
        // 返回一个Promise，下一个then会等待这个Promise完成
        $nextPromise = new Promise();
        $nextPromise->resolve('World!'); // 模拟异步完成
        return $nextPromise;
    })
    ->then(function ($value) {
        echo "第三步：最终结果 '{$value}'\n";
    });

// 触发整个链条
$initialPromise->resolve('Reader');
/*
输出:
第一步：处理初始值 'Reader'
第二步：处理上一步的结果 'Hello, Reader'
第三步：最终结果 'World!'
*/

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        throw new \Exception("第一步出错！"); // 抛出异常会拒绝Promise
    })
    ->then(null, function ($reason) { // 捕获上一步的拒绝
        echo "捕获到错误: " . $reason->getMessage() . "\n";
        // 你可以选择继续抛出，或者返回一个正常值来“恢复”链条
        return new RejectedPromise("更严重的错误：" . $reason->getMessage()); // 继续拒绝
    })
    ->then(null, function ($reason) {
        echo "捕获到下游错误: " . $reason . "\n";
    });

$promise->resolve('开始');
/*
输出:
捕获到错误: 第一步出错！
捕获到下游错误: 更严重的错误：第一步出错！
*/

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

$promise = new Promise(function () use (&$promise) {
    // 模拟耗时操作，最终解决Promise
    sleep(1);
    $promise->resolve('数据已就绪');
});

echo "等待Promise完成...\n";
$result = $promise->wait(); // 会阻塞1秒
echo "Promise已完成，结果: " . $result . "\n";
// 输出:
// 等待Promise完成...
// Promise已完成，结果: 数据已就绪

<pre class="brush:php;toolbar:false;">// 假设你正在使用一个事件循环 (例如 ReactPHP)
// $loop = React\EventLoop\Factory::create();
// $queue = GuzzleHttp\Promise\Utils::queue();
// $loop->addPeriodicTimer(0, [$queue, 'run']);
// ... 你的异步逻辑 ...
// $loop->run();

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

$client = new Client();

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

// 等待所有请求完成
$responses = Utils::settle($promises)->wait();

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