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

guzzlehttp/promises

guzzlehttp/promises

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

fulfilled

rejected

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 模拟一个异步操作，比如API调用
function simulateApiCall(string $data, int $delay = 1000): Promise
{
    $promise = new Promise();

    // 在实际应用中，这里会是一个非阻塞的I/O操作
    // 为了演示，我们用setTimeout模拟异步
    // Guzzle Promises在事件循环中处理任务队列，确保非阻塞
    \GuzzleHttp\Promise\Utils::queue()->add(function () use ($promise, $data, $delay) {
        // 模拟延迟
        usleep($delay * 1000);
        if (rand(0, 1)) { // 随机成功或失败
            $promise->resolve("处理成功: " . $data);
        } else {
            $promise->reject(new Exception("处理失败: " . $data));
        }
    });

    return $promise;
}

echo "开始异步操作...\n";

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

// 使用then()方法注册成功和失败的回调
$promise->then(
    function ($value) {
        echo "Promise成功: " . $value . "\n";
        return simulateApiCall($value . " -> 第二步", 500); // 返回一个新的Promise，实现链式调用
    },
    function ($reason) {
        echo "Promise失败: " . $reason->getMessage() . "\n";
        // 可以在这里处理错误，也可以抛出异常让下一个then的onRejected捕获
        throw $reason;
    }
)->then(
    function ($value) {
        echo "链式Promise成功: " . $value . "\n";
    },
    function ($reason) {
        echo "链式Promise失败: " . $reason->getMessage() . "\n";
        return "从失败中恢复并返回新值"; // 失败回调也可以返回一个值，使链条继续
    }
)->then(
    function ($value) {
        echo "最终成功: " . $value . "\n";
    },
    function ($reason) {
        echo "最终失败: " . $reason->getMessage() . "\n";
    }
);

// 触发初始Promise的解决
$promise->resolve("初始数据");

// 在异步环境中，你需要运行任务队列
// 如果在同步环境中需要等待结果，可以使用wait()
// 对于此示例，我们手动运行队列以确保回调被执行
\GuzzleHttp\Promise\Utils::queue()->run();

echo "所有异步操作已触发。\n";

// 如果需要阻塞等待最终结果，可以使用wait()方法
// echo $promise->wait(); // 这将阻塞直到promise解决或拒绝
?>

guzzlehttp/promises