告别PHP阻塞：如何利用Composer与GuzzlePromises实现高效异步编程

<code class="php">$data1 = callApi1(); // 等待API1返回
$data2 = callApi2(); // 等待API2返回
$data3 = callApi3(); // 等待API3返回
// 处理所有数据</code>

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

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

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

// 注册成功和失败的回调
$promise->then(
    // $onFulfilled: 成功时执行
    function ($value) {
        echo "Promise成功了，收到的值是: " . $value . PHP_EOL;
    },
    // $onRejected: 失败时执行
    function ($reason) {
        echo "Promise失败了，原因是: " . $reason . PHP_EOL;
    }
);

// 模拟一个异步操作，并在稍后解决Promise
// 实际应用中，这里可能是API调用、文件读取等
// 假设2秒后成功
echo "开始模拟异步操作..." . PHP_EOL;
// 实际场景中，这里不会阻塞，而是将resolve/reject的逻辑放在异步操作的回调中
// 为了演示，我们直接resolve
$promise->resolve('这是异步操作的结果！'); 

echo "主程序继续执行，无需等待Promise立即完成。" . PHP_EOL;

// 如果你需要在某个点强制等待Promise完成，可以使用wait()
// 注意：wait()会阻塞当前进程，直到Promise完成
// echo $promise->wait(); // 如果不调用resolve，这里会抛出异常或一直等待
?></code>

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$initialPromise = new Promise();

$initialPromise
    ->then(function ($value) {
        echo "第一步：收到值 - " . $value . PHP_EOL;
        // 返回一个新的值，它将作为下一个then的输入
        return $value . ' + 步骤1';
    })
    ->then(function ($value) {
        echo "第二步：收到值 - " . $value . PHP_EOL;
        // 也可以返回一个全新的Promise，后续链条会等待这个Promise完成
        $anotherPromise = new Promise();
        // 模拟异步操作
        // 假设1秒后，这个新的Promise被解决
        // 这里只是为了演示，实际应用中会是真实的异步操作
        \GuzzleHttp\Promise\Utils::queue()->add(function() use ($anotherPromise) {
            $anotherPromise->resolve('来自第二步的异步结果');
        });
        return $anotherPromise;
    })
    ->then(function ($value) {
        echo "第三步：收到值 - " . $value . PHP_EOL;
        return "所有步骤完成！";
    })
    ->then(function ($finalResult) {
        echo "最终结果: " . $finalResult . PHP_EOL;
    })
    ->otherwise(function ($reason) { // 捕获链中任何环节的错误
        echo "链式调用中出现错误: " . $reason . PHP_EOL;
    });

// 启动Promise链
$initialPromise->resolve('初始数据');

// 注意：Guzzle Promises的异步执行依赖于任务队列。
// 如果不在事件循环中，需要手动运行任务队列来处理Promise的回调。
// 在同步上下文中，通常会使用wait()来强制执行队列并获取结果。
// 但这里我们希望演示非阻塞，所以需要确保任务队列被处理。
// 对于简单的演示，或者在集成到如ReactPHP的事件循环中时，这部分是自动的。
// 对于更复杂的场景，你需要手动运行任务队列，例如：
// while (\GuzzleHttp\Promise\Utils::queue()->run()) { /* continue */ }
// 或者在wait()调用后，它会自动运行任务队列。
// 为了演示非阻塞，我们假设在一个事件循环环境中。
// 如果在命令行直接运行，可能需要一个微小的延迟或强制运行队列来观察效果。
?></code>

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，例如从数据库获取数据
    sleep(2); 
    $promise->resolve('数据库查询结果');
});

echo "尝试获取Promise结果..." . PHP_EOL;
$result = $promise->wait(); // 阻塞当前进程，直到Promise完成
echo "Promise结果已获取: " . $result . PHP_EOL;
?></code>

<code class="php">// 获取全局任务队列
$queue = \GuzzleHttp\Promise\Utils::queue();

// 假设你正在使用ReactPHP事件循环
$loop = React\EventLoop\Factory::create();
$loop->addPeriodicTimer(0, [$queue, 'run']); // 在每个循环周期运行Guzzle的任务队列
$loop->run(); // 启动事件循环</code>

<code class="php"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$promise = new Promise(
    function () use (&$promise) {
        // 这是一个会阻塞的模拟操作，通常我们会在这个函数内部处理异步逻辑
        // 如果被取消，这里应该停止
        echo "Promise开始执行，等待3秒..." . PHP_EOL;
        sleep(3);
        $promise->resolve('操作完成');
    },
    function () {
        // 取消回调：在这里清理资源，停止正在进行的计算
        echo "Promise被取消了！" . PHP_EOL;
    }
);

$promise->then(
    function ($value) {
        echo "Promise成功: " . $value . PHP_EOL;
    },
    function ($reason) {
        echo "Promise失败: " . $reason . PHP_EOL;
    }
);

echo "主程序等待1秒后尝试取消Promise..." . PHP_EOL;
sleep(1);
$promise->cancel(); // 尝试取消Promise

// 运行任务队列以处理取消逻辑
// 如果在事件循环中，则无需手动调用
\GuzzleHttp\Promise\Utils::queue()->run();
?></code>