如何利用Composer和GuzzlePromises优雅地解决PHP异步操作的性能瓶颈

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

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

guzzlehttp/promises

Promise

then()

then()

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

// 创建一个Promise实例
$promise = new Promise();

// 注册成功和失败的回调
$promise->then(
    // $onFulfilled: 成功时执行
    function ($value) {
        echo "操作成功，结果是: " . $value . "\n";
    },
    // $onRejected: 失败时执行
    function ($reason) {
        echo "操作失败，原因是: " . $reason . "\n";
    }
);

// 模拟异步操作完成，并兑现Promise
// 这会触发 $onFulfilled 回调
$promise->resolve('数据已成功获取！');
// 输出：操作成功，结果是: 数据已成功获取！

echo "-------------------\n";

// 另一个Promise，模拟操作失败
$anotherPromise = new Promise();
$anotherPromise->then(null, function ($reason) {
    echo "哎呀，出错了！错误信息: " . $reason . "\n";
});

// 模拟异步操作失败，并拒绝Promise
// 这会触发 $onRejected 回调
$anotherPromise->reject('网络连接超时。');
// 输出：哎呀，出错了！错误信息: 网络连接超时。

guzzlehttp/promises

then()

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：处理数据 '" . $value . "'\n";
        // 返回一个新值，这个值会传递给下一个then
        return "处理后的 " . $value;
    })
    ->then(function ($value) {
        echo "第二步：进一步处理 '" . $value . "'\n";
        // 也可以返回一个新的Promise，后续的then会等待这个Promise完成
        $nextStepPromise = new Promise();
        // 模拟异步操作
        // $nextStepPromise->resolve("最终数据");
        return $nextStepPromise; // 返回一个待解决的Promise
    })
    ->then(function ($value) {
        echo "第三步：最终结果是 '" . $value . "'\n";
    });

// 解决第一个Promise，触发链式调用
$promise->resolve('原始数据');

// 假设第二步返回的Promise在某个时刻被解决了
// (在实际应用中，这通常由Guzzle HTTP客户端等异步库驱动)
// $nextStepPromise->resolve("最终数据"); // 假设这里在某个地方被调用

wait()

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

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

echo "开始等待异步操作...\n";
try {
    $result = $promise->wait(); // 同步等待Promise完成
    echo "异步操作完成，结果: " . $result . "\n";
} catch (RejectionException $e) {
    echo "异步操作失败: " . $e->getReason() . "\n";
} catch (\Exception $e) {
    echo "发生异常: " . $e->getMessage() . "\n";
}
echo "等待结束，继续执行同步代码。\n";

wait()

GuzzleHttp\Promise\RejectionException

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises