告别PHP回调地狱：如何使用GuzzlePromises优雅处理异步操作

curl_multi

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

onFulfilled

onRejected

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步成功：{$value}\n";
        // 返回一个新的Promise，可以继续链式操作
        return new Promise(function ($resolve) use ($value) {
            // 模拟一个异步操作
            sleep(1); 
            $resolve($value . ' - 第二步数据');
        });
    })
    ->then(function ($value) {
        echo "第二步成功：{$value}\n";
        // 返回一个普通值，也会被包装成Promise传递下去
        return $value . ' - 第三步数据';
    })
    ->then(function ($value) {
        echo "第三步成功：{$value}\n";
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节的错误
        echo "操作失败：{$reason}\n";
    });

// 模拟异步操作的开始，最终解决Promise
$promise->resolve('初始数据');

// 在非事件循环环境下，你需要手动运行任务队列来处理Promise
// 或者使用wait()方法等待Promise完成
// GuzzleHttp\Promise\Utils::queue()->run();

resolve()

reject()

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

$successPromise = new Promise();
$successPromise->then(function($value) { echo "成功: " . $value; });
$successPromise->resolve('Hello World'); // 输出 "成功: Hello World"

$errorPromise = new Promise();
$errorPromise->then(null, function($reason) { echo "失败: " . $reason; });
$errorPromise->reject('Something went wrong!'); // 输出 "失败: Something went wrong!"

// 你也可以直接创建已完成或已拒绝的Promise
$fulfilled = new GuzzleHttp\Promise\FulfilledPromise('立即成功');
$rejected = new GuzzleHttp\Promise\RejectedPromise('立即失败');

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

$dataPromise = new Promise(function ($resolve) {
    // 模拟一个耗时操作，最终解决Promise
    sleep(2);
    $resolve('从API获取的数据');
});

try {
    $result = $dataPromise->wait(); // 同步等待，直到Promise完成
    echo "获取到数据：" . $result . "\n";
} catch (\Exception $e) {
    echo "等待过程中发生错误：" . $e->getMessage() . "\n";
}