在PHP中高效管理异步操作：告别回调地狱，使用guzzlehttp/promises优雅地处理并发任务

curl_multi_exec

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

fulfilled

rejected

guzzlehttp/promises

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

guzzlehttp/promises

Promise

then()

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

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

// 模拟一个异步操作：获取用户数据
function fetchUserData(): Promise
{
    $promise = new Promise();
    // 假设这里是实际的异步网络请求或数据库查询
    // 为了演示，我们延迟1秒后解决Promise
    echo "开始获取用户数据...\n";
    \GuzzleHttp\Promise\Utils::queue()->add(function () use ($promise) {
        sleep(1); // 模拟耗时操作
        $promise->resolve(['id' => 1, 'name' => '张三']);
        echo "用户数据获取完成。\n";
    });
    return $promise;
}

// 模拟另一个异步操作：根据用户数据发送欢迎邮件
function sendWelcomeEmail(array $userData): Promise
{
    $promise = new Promise();
    echo "开始发送欢迎邮件给 {$userData['name']}...\n";
    \GuzzleHttp\Promise\Utils::queue()->add(function () use ($promise, $userData) {
        sleep(0.5); // 模拟耗时操作
        if ($userData['name'] === '张三') {
            $promise->resolve("邮件已发送给 {$userData['name']}");
        } else {
            $promise->reject("无法发送邮件给未知用户");
        }
        echo "欢迎邮件发送完成。\n";
    });
    return $promise;
}

echo "程序开始执行。\n";

fetchUserData()
    ->then(function ($userData) {
        // 第一个Promise成功后，处理用户数据，并返回下一个Promise
        echo "处理用户数据: " . json_encode($userData) . "\n";
        return sendWelcomeEmail($userData);
    })
    ->then(function ($emailStatus) {
        // 第二个Promise成功后，处理邮件发送状态
        echo "最终成功: " . $emailStatus . "\n";
    })
    ->otherwise(function ($reason) {
        // 链中任何一个Promise被拒绝，都会捕获到这里
        echo "发生错误: " . $reason . "\n";
    });

// 重要：在没有事件循环的同步PHP脚本中，需要手动运行任务队列来解决Promise
// 在实际异步环境中（如ReactPHP、Swoole），这通常由事件循环自动处理
\GuzzleHttp\Promise\Utils::queue()->run();

echo "所有异步操作已调度，程序将继续执行或等待。\n";

// 示例输出：
// 程序开始执行。
// 开始获取用户数据...
// 所有异步操作已调度，程序将继续执行或等待。
// 用户数据获取完成。
// 处理用户数据: {"id":1,"name":"张三"}
// 开始发送欢迎邮件给 张三...
// 欢迎邮件发送完成。
// 最终成功: 邮件已发送给 张三

Promise

fetchUserData

sendWelcomeEmail

then()

otherwise()

then(null, $onRejected)

guzzlehttp/promises

wait()

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

$promise = new Promise(function () use (&$promise) {
    echo "等待函数被调用...\n";
    $promise->resolve('我被同步等待了！');
});

echo $promise->wait(); // 输出 "等待函数被调用..." 然后 "我被同步等待了！"

cancel()

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises