如何解决PHP异步操作中的回调地狱与复杂性？GuzzlePromises助你优雅地处理异步任务

<code class="bash">composer require guzzlehttp/promises</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise->then(
    // $onFulfilled：当Promise成功时执行
    function ($value) {
        echo 'Promise成功完成，结果是：' . $value . "\n";
    },
    // $onRejected：当Promise失败时执行
    function ($reason) {
        echo 'Promise失败了，原因是：' . $reason . "\n";
    }
);

// 模拟异步操作成功：解决Promise
$promise->resolve('这是异步操作的结果！');
// 输出：Promise成功完成，结果是：这是异步操作的结果！</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$firstPromise = new Promise();

$firstPromise
    ->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;
    })
    ->then(function ($finalValue) {
        echo "第三步完成，最终结果: " . $finalValue . "\n";
    });

// 触发第一个Promise的解决
$firstPromise->resolve('原始数据');
// 输出：
// 第一步完成，接收到: 原始数据
// 第二步完成，接收到: 原始数据 - 经过处理
// 第三步完成，最终结果: 最终数据</code>

<code class="php">use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\RejectedPromise; // 可以直接创建已拒绝的Promise

$errorPromise = new Promise();
$errorPromise->then(null, function ($reason) {
    echo "捕获到错误： " . $reason . "\n";
    // 也可以返回一个RejectedPromise，将错误继续向下传递
    return new RejectedPromise("再次拒绝: " . $reason);
})->then(null, function ($reason) {
    echo "错误再次被捕获： " . $reason . "\n";
});

$errorPromise->reject('网络连接失败');
// 输出：
// 捕获到错误： 网络连接失败
// 错误再次被捕获： 再次拒绝: 网络连接失败</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$taskPromise = new Promise();

$taskPromise
    ->then(function ($data) {
        if (empty($data)) {
            throw new \Exception("数据为空，无法处理！");
        }
        return "处理后的数据: " . $data;
    })
    ->then(function ($processedData) {
        echo $processedData . "\n";
    })
    ->otherwise(function (\Exception $e) { // 使用otherwise()更简洁地捕获拒绝
        echo "发生了一个错误: " . $e->getMessage() . "\n";
    });

$taskPromise->resolve(''); // 传入空数据，触发异常
// 输出：发生了一个错误: 数据为空，无法处理！</code>

<code class="php">use GuzzleHttp\Promise\Promise;

$dataPromise = new Promise(function () use (&$dataPromise) {
    // 模拟一个耗时操作，最终解决Promise
    sleep(1); // 实际应用中可能是网络请求等
    $dataPromise->resolve('从远程服务获取的数据');
});

echo "开始等待Promise...\n";
$result = $dataPromise->wait(); // 会阻塞当前执行，直到Promise解决
echo "Promise已完成，结果是: " . $result . "\n";
// 输出：
// 开始等待Promise...
// Promise已完成，结果是: 从远程服务获取的数据</code>

<code class="php">// 这是一个概念示例，实际需要结合 Guzzle HTTP Client 的异步请求
// $client = new GuzzleHttp\Client();
// $promise1 = $client->getAsync('http://api.service1.com/data');
// $promise2 = $client->getAsync('http://api.service2.com/data');
// $promise3 = $client->getAsync('http://api.service3.com/data');

// Guzzle Promises 提供工具来组合这些Promise
use GuzzleHttp\Promise\Utils;
use GuzzleHttp\Promise\Promise; // 仅为示例，实际会是Guzzle HTTP client返回的Promise

// 模拟三个异步操作
$promiseA = new Promise(function($resolve) {
    sleep(1); $resolve('Data A');
});
$promiseB = new Promise(function($resolve) {
    sleep(2); $resolve('Data B');
});
$promiseC = new Promise(function($resolve) {
    sleep(1); $resolve('Data C');
});

$allPromises = Utils::all([$promiseA, $promiseB, $promiseC]);

$allPromises->then(function ($results) {
    echo "所有数据已获取：\n";
    print_r($results); // $results 将是 [Data A, Data B, Data C]
})->otherwise(function ($reason) {
    echo "有Promise失败了: " . $reason . "\n";
})->wait(); // 在此等待所有Promise完成</code>