如何解决PHP异步操作的性能瓶颈？使用Composer与GuzzlePromises库实现高效并发

<pre class="brush:php;toolbar:false;">// 伪代码示例
$data1 = fetchFromApi1(); // 等待 API 1 完成
$data2 = fetchFromApi2(); // 等待 API 2 完成
$data3 = fetchFromDatabase(); // 等待数据库查询完成

// 处理所有数据...

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

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

// 注册成功和失败的回调函数
$promise->then(
    // $onFulfilled：操作成功时执行
    function ($value) {
        echo "操作成功，得到值: " . $value . "\n";
    },
    // $onRejected：操作失败时执行
    function ($reason) {
        echo "操作失败，原因: " . $reason . "\n";
    }
);

// 模拟异步操作完成并解决 Promise
// 在实际应用中，这可能是在网络请求、文件读写等异步任务完成后调用
$promise->resolve('这是异步操作的结果'); // 输出：操作成功，得到值: 这是异步操作的结果

// 如果操作失败，你可以这样拒绝 Promise
// $promise->reject('出错了，无法完成操作'); // 输出：操作失败，原因: 出错了，无法完成操作

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$initialPromise = new Promise();

$initialPromise
    ->then(function ($value) {
        echo "第一步：接收到原始数据 -> " . $value . "\n";
        // 返回一个新的值，这个值将作为下一个 then 的输入
        return "经过第一步处理的数据：" . $value . " + 附加信息";
    })
    ->then(function ($processedValue) {
        echo "第二步：接收到处理后的数据 -> " . $processedValue . "\n";
        // 在这里，你可以返回另一个 Promise，下一个 then 会等待这个 Promise 完成
        $anotherAsyncStep = new Promise();
        // 模拟另一个异步操作，例如发送邮件或记录日志
        // sleep(1); // 模拟耗时
        $anotherAsyncStep->resolve('最终数据已准备好');
        return $anotherAsyncStep; // 返回一个 Promise
    })
    ->then(function ($finalResult) {
        echo "第三步：接收到最终结果 -> " . $finalResult . "\n";
        return "所有步骤完成！";
    })
    ->otherwise(function ($reason) { // 统一处理链中任何一个环节的拒绝
        echo "错误：链中某个环节失败了，原因 -> " . $reason . "\n";
    });

// 解决初始 Promise，触发整个链式调用
$initialPromise->resolve('原始用户数据');

// 如果在某个环节抛出异常或返回 RejectedPromise，就会触发 otherwise
// $initialPromise->reject('初始操作失败');

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$dataFetchingPromise = new Promise(function () use (&$dataFetchingPromise) {
    // 模拟一个耗时操作，例如从远程 API 获取数据
    echo "正在模拟耗时的数据获取...\n";
    sleep(2); // 阻塞 2 秒
    $dataFetchingPromise->resolve('从远程 API 获取到的数据');
});

echo "程序开始执行...\n";
// 调用 wait() 会阻塞当前脚本，直到 $dataFetchingPromise 完成
$result = $dataFetchingPromise->wait();
echo "数据获取完成，结果是: " . $result . "\n";
echo "程序继续执行...\n";