如何解决PHP异步操作的阻塞与复杂性？GuzzlePromises助你构建高性能应用

<pre class="brush:php;toolbar:false;">$data1 = $microservice1->getData(); // 等待服务1响应，期间程序阻塞
$data2 = $microservice2->getData(); // 等待服务2响应，期间程序阻塞
$data3 = $microservice3->getData(); // 等待服务3响应，期间程序阻塞

// 合并数据并返回
return combineData($data1, $data2, $data3);

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

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

$promise = new Promise();

// 假设这是一个异步操作的模拟，例如在后台线程中执行
// 实际中，这通常由Guzzle HTTP客户端等库自动返回
// 1秒后解决promise
\Amp\Loop::delay(1000, function () use ($promise) {
    $promise->resolve('异步操作完成！');
});

$promise->then(
    function ($value) {
        echo "Promise兑现了: " . $value . PHP_EOL;
    },
    function ($reason) {
        echo "Promise被拒绝了: " . $reason . PHP_EOL;
    }
);

// 为了让上面的异步回调执行，我们需要运行一个事件循环
// 在实际应用中，这通常由框架或HTTP客户端自动处理
// 这里只是一个简单的同步等待示例
echo "等待Promise完成..." . PHP_EOL;
$promise->wait(); // 同步等待promise完成

<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，实现更复杂的异步链
        return new Promise(function ($resolve) use ($value) {
            \Amp\Loop::delay(500, function () use ($resolve, $value) {
                $resolve($value . " (延迟500ms)");
            });
        });
    })
    ->then(function ($value) {
        echo "第三步：最终结果 " . $value . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的拒绝
        echo "Promise链中发生错误: " . $reason . PHP_EOL;
    });

$promise->resolve('原始数据');
$promise->wait(); // 同步等待整个链条完成

<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'),
];

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

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