如何优雅地处理PHP异步操作？GuzzlePromises助你告别“回调地狱”！

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

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

then()

guzzlehttp/promises

then()

then()

<pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于运行队列

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步完成，获得值: " . $value . "\n";
        // 返回一个新的值，传递给下一个then
        return "处理后的 " . $value;
    })
    ->then(function ($newValue) {
        echo "第二步完成，获得新值: " . $newValue . "\n";
        // 也可以返回一个Promise，实现异步操作的串联
        $anotherPromise = new Promise();
        // 假设这里模拟一个耗时操作，例如网络请求，并在未来某个时刻解决它
        // $anotherPromise->resolve('最终数据'); // 实际中会在异步操作完成后调用
        return $anotherPromise; // 返回一个Promise
    })
    ->then(function ($finalData) {
        echo "所有异步操作完成，最终数据: " . $finalData . "\n";
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的错误
        echo "操作失败: " . $reason . "\n";
    });

// 模拟异步操作开始
$promise->resolve('原始数据');

// 注意：在实际的异步环境中（例如使用ReactPHP事件循环），
// 你需要定期运行Guzzle Promises的任务队列，以便Promise能够被解决。
// 例如：
// $loop = React\EventLoop\Factory::create();
// $loop->addPeriodicTimer(0, [Utils::queue(), 'run']);
// $loop->run();

// 为了演示，我们在这里手动解决第二个Promise
// 在实际应用中，这会由异步操作的完成触发
$promise->then(function($value) use ($promise) {
    // 假设第二个then返回的Promise是这个$promise的内部状态
    // 这里仅为演示，实际应由异步操作本身解决
    if ($value === "处理后的 原始数据") {
        // 找到由第二个then返回的那个Promise，并解决它
        // 这部分逻辑在真实异步场景中由Promise的实际创建者处理
        // 为了演示，我们假设它会被解决
        // 实际应用中，你不会直接在这里控制链中的Promise
        // 而是让异步操作本身去resolve它
    }
});

// 在同步上下文演示，需要手动触发队列运行，确保所有Promise被处理
// 否则，如果第二个Promise没有被resolve，最后一个then不会执行
// 在没有事件循环的情况下，wait()会自动运行队列
// $promise->wait(false); // 确保Promise被解决，但不强制获取值
// 如果第二个then返回的Promise没有被外部resolve，那么最终的then不会执行
// 这是一个Promise链的复杂性，需要理解其异步本质。

wait()

guzzlehttp/promises

wait()

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

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，最终解决Promise
    sleep(1); // 暂停1秒
    $promise->resolve('这是异步操作的结果');
});

echo "开始等待异步操作...\n";
$result = $promise->wait(); // 会阻塞当前进程直到Promise被解决
echo "异步操作完成，结果是: " . $result . "\n";

wait()

otherwise()

reject()

otherwise()

then

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步: " . $value . "\n";
        // 模拟一个错误发生
        throw new \Exception("第一步发生错误！");
        return "成功"; // 这行不会执行
    })
    ->then(function ($value) {
        echo "第二步: " . $value . "\n"; // 这行不会执行
    })
    ->otherwise(function (\Throwable $reason) {
        echo "捕获到错误: " . $reason->getMessage() . "\n";
    });

$promise->resolve('初始数据');
// 在没有事件循环的情况下，需要运行队列来处理Promise的解析
Utils::queue()->run();

guzzlehttp/promises

guzzlehttp/promises