让PHP不再“等待”：如何用Composer和GuzzlePromises优化异步操作性能

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

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

require 'vendor/autoload.php';

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

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

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

// 2. 注册回调函数：当Promise成功时执行 onFulfilled，失败时执行 onRejected
// then 方法可以链式调用，每个 then 都会返回一个新的 Promise
$promise->then(
    function ($value) {
        echo "  [回调1] 操作成功，得到原始值: " . $value . "\n";
        // 返回一个新值，会传递给下一个 then 的 onFulfilled 回调
        return "处理后的数据: " . $value . "!";
    },
    function ($reason) {
        echo "  [回调1] 操作失败，原因: " . $reason . "\n";
        // 如果这里不抛出异常或返回 RejectedPromise，下一个 then 的 onFulfilled 会被调用
        // 为了演示失败链，我们返回一个 RejectedPromise
        return new RejectedPromise("二次处理失败: " . $reason);
    }
)->then(
    function ($newValue) {
        echo "  [回调2] 链式操作成功，得到新值: " . $newValue . "\n";
    },
    function ($newReason) {
        echo "  [回调2] 链式操作失败，新原因: " . $newReason . "\n";
    }
);

echo "Promise 已创建并注册回调，程序继续执行其他任务（非阻塞）...\n";

// 3. 在某个时刻，异步操作完成，我们手动解决Promise
// 尝试用 '原始数据' 解决 Promise
// $promise->resolve('原始数据'); 

// 尝试用 '网络连接超时' 拒绝 Promise
$promise->reject('网络连接超时'); 

// 4. 在非事件循环环境中，如果你需要获取Promise的最终结果并阻塞当前进程，可以使用 wait()
// 注意：这会使操作同步化，失去部分异步优势，但对于获取最终结果是必要的。
try {
    // $finalResult = $promise->wait(); // 如果是resolve，这里会得到最终值
    // echo "最终结果 (通过wait获取): " . $finalResult . "\n";
    // 如果是reject，wait() 默认会抛出异常
    // 我们可以传递 false 给 wait() 来避免抛出异常，只确保 Promise 状态已解决
    $promise->wait(false); 
} catch (\GuzzleHttp\Promise\RejectionException $e) {
    echo "通过 wait() 捕获到异常: " . $e->getMessage() . "\n";
} catch (\Exception $e) {
    echo "通过 wait() 捕获到其他异常: " . $e->getMessage() . "\n";
}

echo "--- 程序执行完毕 ---\n";