PHP异步编程不再是难题：如何使用GuzzlePromises解决I/O阻塞问题，提升应用性能

guzzlehttp/promises

guzzlehttp/promises

fulfilled

rejected

guzzlehttp/promises

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

Promise

guzzlehttp/promises

then()

then()

$onFulfilled

$onRejected

then()

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

$promise = new Promise();

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

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

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

then()

then

then

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：接收到 " . $value . PHP_EOL;
        // 返回一个新值，传递给下一个then
        return $value . "，处理完成";
    })
    ->then(function ($newValue) {
        echo "第二步：接收到 " . $newValue . PHP_EOL;
        // 返回一个新的Promise，模拟另一个异步操作
        $anotherPromise = new Promise();
        // 假设这里有一些耗时操作，比如另一个API请求
        // 稍后会 resolve 这个 Promise
        return $anotherPromise;
    })
    ->then(function ($finalValue) {
        echo "第三步：最终结果是 " . $finalValue . PHP_EOL;
    });

// 触发第一个Promise的解决
$promise->resolve('原始数据'); // 输出: 第一步：接收到 原始数据

// 模拟第二个Promise的解决 (它会触发第三个then)
// 注意：在实际异步场景中，这通常由事件循环或外部I/O完成
// 为了演示，我们在这里手动解决它
// GuzzleHttp\Promise\Utils::queue()->run(); // 如果在事件循环中，需要运行队列
// 假设我们在第二个then中返回的 $anotherPromise 现在被解决了
// 可以在某个地方获取到 $anotherPromise 的引用并 resolve 它
// 为了演示，我们假设 $anotherPromise 最终被解决了
// 如果你运行上面的代码，你会发现第三步不会立即执行，因为它在等待第二个Promise
// 如果你想让它执行，你需要一个机制来解决那个返回的 $anotherPromise。
// 在实际应用中，这通常由底层的异步I/O库（如Guzzle HTTP客户端）自动处理。

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "步骤1：接收到 " . $value . PHP_EOL;
        return $value . " processed"; // 传递新值
    })
    ->then(function ($valueFromPrev) {
        echo "步骤2：接收到 " . $valueFromPrev . PHP_EOL;
        return "Final Result: " . $valueFromPrev; // 再次传递新值
    })
    ->then(function ($finalValue) {
        echo "步骤3：最终结果是 " . $finalValue . PHP_EOL;
    });

$promise->resolve('Initial Data');
// 输出：
// 步骤1：接收到 Initial Data
// 步骤2：接收到 Initial Data processed
// 步骤3：最终结果是 Final Result: Initial Data processed

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "成功回调1: " . $value . PHP_EOL;
        // 模拟一个错误
        throw new \Exception('第一步出错啦！');
        return '不会执行到这里';
    })
    ->then(function ($value) {
        echo "成功回调2: " . $value . PHP_EOL;
    }, function ($reason) {
        echo "错误回调1 (捕获到): " . $reason->getMessage() . PHP_EOL;
        // 可以在这里处理错误，也可以再次抛出或返回一个被拒绝的Promise来继续转发
        // throw new \Exception('再次抛出错误');
        return '错误已被处理，链条继续'; // 返回一个值，将链条转为成功状态
    })
    ->then(function ($value) {
        echo "成功回调3: " . $value . PHP_EOL;
    }, function ($reason) {
        echo "错误回调2: " . $reason->getMessage() . PHP_EOL;
    });

$promise->resolve('开始');
// 输出：
// 成功回调1: 开始
// 错误回调1 (捕获到): 第一步出错啦！
// 成功回调3: 错误已被处理，链条继续

wait()

wait()

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

$promise = new Promise(function () use (&$promise) {
    // 模拟耗时操作，最终解决Promise
    sleep(1); // 暂停1秒
    $promise->resolve('等待结束，结果来了！');
});

echo "开始等待..." . PHP_EOL;
$result = $promise->wait(); // 脚本会在这里暂停1秒
echo "等待完成，结果是: " . $result . PHP_EOL; // 输出: 等待完成，结果是: 等待结束，结果来了！

wait(false)

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Utils;
// ... 你的异步代码和Promise操作 ...

// 如果你在一个事件循环环境中，需要定期运行任务队列
// $loop = React\EventLoop\Factory::create();
// $loop->addPeriodicTimer(0, [Utils::queue(), 'run']);
// $loop->run();

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises