告别PHP阻塞等待：如何使用Composer和GuzzlePromises优雅解决异步操作难题

<pre class="brush:php;toolbar:false;">$data1 = callApiOne(); // 等待API 1响应
$data2 = callApiTwo(); // 等待API 2响应
$data3 = callApiThree(); // 等待API 3响应
// 聚合处理数据...

Promise

guzzlehttp/promises

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

guzzlehttp/promises

then

$onFulfilled

$onRejected

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

$promise = new Promise();

$promise->then(
    function ($value) {
        echo "操作成功，得到值: " . $value . "\n";
    },
    function ($reason) {
        echo "操作失败，原因: " . $reason . "\n";
    }
);

// 模拟异步操作成功
$promise->resolve('API数据已返回'); // 触发 $onFulfilled 回调
// 输出: 操作成功，得到值: API数据已返回

// 模拟异步操作失败
// $promise->reject('API请求超时'); // 触发 $onRejected 回调
// 输出: 操作失败，原因: API请求超时

resolve($value)

$value

$onFulfilled

reject($reason)

$reason

$onRejected

then

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

$promise = new Promise();

$promise
    ->then(function ($initialValue) {
        echo "第一步：处理初始值 - " . $initialValue . "\n";
        return "处理后的值：" . $initialValue; // 返回一个新值，传递给下一个then
    })
    ->then(function ($processedValue) {
        echo "第二步：接收并处理上一步的值 - " . $processedValue . "\n";
        return new Promise(function ($resolve) use ($processedValue) {
            // 模拟一个更复杂的异步操作，例如一个数据库查询，1秒后完成
            sleep(1); 
            $resolve($processedValue . " & 数据库结果");
        });
    })
    ->then(function ($finalResult) {
        echo "第三步：最终结果 - " . $finalResult . "\n";
    });

// 触发整个链条
$promise->resolve('原始数据');
// 观察输出顺序，第二步的promise会等待1秒

then

$onRejected

then

RejectedPromise

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        // 模拟一个可能失败的操作
        if ($value === '错误数据') {
            throw new \Exception("数据格式不正确！");
        }
        return "数据处理成功：" . $value;
    })
    ->then(null, function ($reason) { // 只处理拒绝
        echo "捕获到错误: " . $reason->getMessage() . "\n";
        // 可以选择返回一个RejectedPromise继续传递拒绝，或返回一个普通值来“恢复”链条
        return new RejectedPromise("再次拒绝: " . $reason->getMessage());
    })
    ->then(null, function ($finalReason) {
        echo "最终错误处理: " . $finalReason . "\n";
    });

$promise->resolve('错误数据');
// 输出:
// 捕获到错误: 数据格式不正确！
// 最终错误处理: 再次拒绝: 数据格式不正确！

// 如果没有错误，链条会正常执行
// $promise->resolve('有效数据');

wait()

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决Promise
    sleep(2);
    $promise->resolve('等待2秒后的结果');
});

echo "开始等待...\n";
$result = $promise->wait(); // 会阻塞当前执行，直到Promise解决
echo "等待结束，结果: " . $result . "\n";
// 输出:
// 开始等待...
// (等待2秒)
// 等待结束，结果: 等待2秒后的结果

wait()

$promise->wait(false)

guzzlehttp/promises