如何解决PHP异步操作的复杂性，使用GuzzlePromises让代码更优雅

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

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php'; // 确保 Composer 自动加载可用

use GuzzleHttp\Promise\Promise;

// 创建一个 Promise 实例
$promise = new Promise();

// 模拟一个异步操作，例如在后台线程或事件循环中执行
// 这里我们用一个简单的延迟来模拟
// 实际应用中，这可能是网络请求、文件读写等
$someAsyncProcess = function () use ($promise) {
    sleep(2); // 模拟耗时2秒
    if (rand(0, 1)) {
        $promise->resolve('数据已成功加载！'); // 异步操作成功
    } else {
        $promise->reject(new \Exception('数据加载失败！')); // 异步操作失败
    }
};

// 在 Promise 上注册回调
$promise->then(
    function ($value) {
        echo "成功: " . $value . PHP_EOL;
    },
    function (\Throwable $reason) {
        echo "失败: " . $reason->getMessage() . PHP_EOL;
    }
);

echo "程序继续执行，不等待异步操作。" . PHP_EOL;

// 实际触发异步操作，并等待其完成（这里为了演示效果，实际中通常集成到事件循环）
// 注意：在真正的异步场景中，你通常不会在这里直接调用 $someAsyncProcess()
// 而是在某个地方（如事件循环的tick）调用 resolve/reject
$someAsyncProcess();

// 如果需要等待 Promise 完成并获取结果，可以使用 wait()
// 在异步场景中，通常是在所有 Promise 都发出后，在程序的最后统一等待或通过事件循环处理
try {
    echo "最终结果: " . $promise->wait() . PHP_EOL;
} catch (\Throwable $e) {
    echo "最终失败: " . $e->getMessage() . PHP_EOL;
}

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php'; // 确保 Composer 自动加载可用

use GuzzleHttp\Promise\Promise;

$firstPromise = new Promise();

$firstPromise
    ->then(function ($value) {
        echo "第一步：处理 " . $value . PHP_EOL;
        // 返回一个新的值，这个值会传递给下一个 then
        return $value . ' processed';
    })
    ->then(function ($newValue) {
        echo "第二步：接收到 " . $newValue . PHP_EOL;
        // 也可以返回一个新的 Promise，实现更复杂的异步链
        $anotherPromise = new Promise();
        // 模拟另一个异步操作，例如延迟1秒
        // ...
        sleep(1);
        $anotherPromise->resolve(' and transformed');
        return $anotherPromise;
    })
    ->then(function ($finalValue) {
        echo "第三步：最终结果 " . $finalValue . PHP_EOL;
        return $finalValue . ' done!';
    })
    ->otherwise(function (\Throwable $e) { // 统一处理链中任何环节的错误
        echo "链中发生错误: " . $e->getMessage() . PHP_EOL;
    });

echo "Promise 链已建立，等待触发..." . PHP_EOL;

// 触发第一个 Promise
$firstPromise->resolve('原始数据');

// 如果需要，等待所有链式 Promise 完成
// 实际中，你可能通过事件循环来驱动，而不是在这里阻塞
// 这里的 wait() 会等待整个链条完成
try {
    echo "链式调用最终等待结果: " . $firstPromise->wait() . PHP_EOL;
} catch (\Throwable $e) {
    echo "链式调用最终等待失败: " . $e->getMessage() . PHP_EOL;
}

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php'; // 确保 Composer 自动加载可用

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

$faultyPromise = new Promise();

$faultyPromise
    ->then(function ($value) {
        echo "成功回调，但将抛出异常: " . $value . PHP_EOL;
        throw new \RuntimeException('第一步操作失败！');
    })
    ->then(null, function (\Throwable $e) {
        echo "捕获到错误: " . $e->getMessage() . PHP_EOL;
        // 可以在这里处理错误，并返回一个值，让后续链条恢复正常
        // 或者返回一个 RejectedPromise 继续传递错误
        return new RejectedPromise('错误已处理，但仍需拒绝！');
    })
    ->then(function ($value) {
        echo "这个回调不会被执行，因为上一步返回了 RejectedPromise。" . PHP_EOL;
    })
    ->otherwise(function (\Throwable $e) {
        echo "最终错误捕获: " . $e->getMessage() . PHP_EOL;
    });

$faultyPromise->resolve('初始值');

// 等待并捕获最终的错误
try {
    $faultyPromise->wait();
} catch (\Throwable $e) {
    echo "Wait 捕获到最终异常: " . $e->getMessage() . PHP_EOL;
}