如何优雅地处理PHP异步操作？GuzzlePromises与Composer助你事半功倍！

guzzlehttp/promises

fulfilled

rejected

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

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

guzzlehttp/promises

vendor/

autoload.php

guzzlehttp/promises

require

guzzlehttp/promises

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php'; // 引入Composer自动加载

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise;

// 示例1: 基本的Promise链式调用
echo "--- 示例1: 基本Promise链式调用 ---\n";
$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：接收到值 - " . $value . "\n";
        // 返回一个新值，传递给下一个then
        return "Hello, " . $value;
    })
    ->then(function ($value) {
        echo "第二步：处理新值 - " . $value . "\n";
        // 再次返回一个新值
        return strtoupper($value);
    })
    ->then(function ($value) {
        echo "第三步：最终结果 - " . $value . "\n";
    });

// 模拟异步操作完成，解决Promise
$promise->resolve('reader.');
// 输出:
// 第一步：接收到值 - reader.
// 第二步：处理新值 - Hello, reader.
// 第三步：最终结果 - HELLO, READER.

echo "\n--- 示例2: 带有同步等待的Promise ---\n";
// 示例2: 带有同步等待的Promise（通常在CLI或测试中使用）
$dataPromise = new Promise(function () use (&$dataPromise) {
    echo "模拟耗时操作开始...\n";
    sleep(2); // 模拟2秒的网络请求或计算
    $dataPromise->resolve('异步数据已加载！');
});

// 在这里，我们可以继续做其他事情，而不必等待dataPromise完成
echo "程序继续执行，等待异步数据...\n";

// 当我们需要数据时，可以同步等待它完成
try {
    $result = $dataPromise->wait();
    echo "同步等待结果: " . $result . "\n";
} catch (Exception $e) {
    echo "Promise被拒绝: " . $e->getMessage() . "\n";
}
// 输出:
// 模拟耗时操作开始...
// 程序继续执行，等待异步数据...
// (2秒后)
// 同步等待结果: 异步数据已加载！

echo "\n--- 示例3: Promise的拒绝与错误处理 ---\n";
$errorPromise = new Promise();
$errorPromise
    ->then(null, function ($reason) { // 第一个参数为null表示不处理成功情况
        echo "捕获到错误: " . $reason . "\n";
        // 可以选择抛出异常，或返回一个值来“恢复”链式操作
        // throw new Exception("新的错误！");
        return "错误已处理，链式操作继续...";
    })
    ->then(function ($value) {
        echo "错误处理后继续: " . $value . "\n";
    });

$errorPromise->reject('网络连接失败！');
// 输出:
// 捕获到错误: 网络连接失败！
// 错误处理后继续: 错误已处理，链式操作继续...

echo "\n--- 示例4: Promise链中返回Promise ---\n";
$nestedPromise = new Promise();
$innerPromise = new Promise();

$nestedPromise
    ->then(function ($value) use ($innerPromise) {
        echo "外层Promise接收到: " . $value . "\n";
        // 在then中返回另一个Promise，外层Promise会等待内层Promise完成
        return $innerPromise;
    })
    ->then(function ($value) {
        echo "内层Promise最终解决值: " . $value . "\n";
    });

$nestedPromise->resolve('初始数据'); // 触发外层Promise
$innerPromise->resolve('来自内层Promise的数据'); // 触发内层Promise
// 输出:
// 外层Promise接收到: 初始数据
// 内层Promise最终解决值: 来自内层Promise的数据

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises