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

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

<code class="php"><?php

require 'vendor/autoload.php'; // 引入 Composer 自动加载

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于运行任务队列

// 模拟一个异步操作，比如从外部服务获取数据
function fetchDataAsync(): Promise
{
    $promise = new Promise();

    // 在实际应用中，这里会启动一个非阻塞的I/O操作，
    // 并在操作完成后调用 $promise->resolve() 或 $promise->reject()
    // 为了演示，我们用 PHP 协程库 Amp 来模拟一个非阻塞延迟
    // 注意：你需要安装 amphp/amp (composer require amphp/amp) 才能运行此部分
    Amp\Loop::delay(2000, function () use ($promise) { // 模拟2秒延迟
        $success = (bool)rand(0, 1); // 随机成功或失败
        if ($success) {
            $promise->resolve(['id' => 1, 'name' => '异步获取的示例数据']);
            echo "数据获取成功！\n";
        } else {
            $promise->reject(new Exception('数据获取失败，模拟网络错误！'));
            echo "数据获取失败！\n";
        }
    });

    return $promise;
}

// 使用 Promise
$promise = fetchDataAsync();

$promise->then(
    function ($data) {
        echo "在then()中处理成功数据: " . json_encode($data) . "\n";
        // 返回值会传递给下一个then()
        return "处理后的数据: " . $data['name'] . " - 已转换";
    },
    function (Throwable $reason) {
        echo "在then()中处理失败原因: " . $reason->getMessage() . "\n";
        // 可以选择抛出异常继续向下传递拒绝状态，或返回一个值转为成功状态
        // throw $reason; // 抛出异常会继续向下传递拒绝状态
        return "错误恢复: 默认值 (异步操作失败，但已恢复)"; // 错误恢复，后续链将进入成功状态
    }
)->then(
    function ($processedValue) {
        echo "链式调用：上一个then()返回的值是: " . $processedValue . "\n";
    },
    function (Throwable $reason) {
        echo "链式调用：处理上一个then()的拒绝: " . $reason->getMessage() . "\n";
    }
);

// Guzzle Promises 内部使用任务队列处理，如果你没有集成事件循环，
// 需要手动运行队列来触发回调。
// 在使用 Amp 或 ReactPHP 等事件循环库时，它们会负责运行队列。
// 这里我们手动运行 Guzzle 的任务队列。
// 注意：如果 fetchDataAsync 内部没有真正的非阻塞机制（如 Amp），
// 这里的 run() 可能立即执行，因为没有异步任务在等待。
Utils::queue()->run(); // 运行 Guzzle Promises 的内部任务队列

echo "程序继续执行，不等待数据获取完成（如果fetchDataAsync是真正的异步）。\n";

// 如果你的 PHP 环境没有事件循环，并且你希望强制等待 Promise 完成，可以使用 wait()
// 但请注意，wait() 会阻塞当前进程，失去异步的优势。
$syncPromise = new Promise(function () use (&$syncPromise) {
    sleep(1); // 阻塞1秒
    $syncPromise->resolve('这是通过 wait() 同步获取的结果');
});
echo "开始同步等待...\n";
$syncResult = $syncPromise->wait(); // 阻塞等待
echo "同步等待结果: " . $syncResult . "\n";</code>

<code class="php"><?php

require 'vendor/autoload.php';

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

// 模拟第一个异步操作
$promiseA = new Promise();
// 模拟第二个异步操作
$promiseB = new Promise();

$promiseA
    ->then(function ($value) use ($promiseB) {
        echo "第一步成功: " . $value . "\n";
        // 返回另一个Promise，后续链将等待这个Promise完成
        return $promiseB;
    })
    ->then(function ($value) {
        echo "第二步成功: " . $value . "\n";
        // 模拟一个错误，这将触发后续的onRejected回调
        throw new Exception('第二步处理数据时出错！');
    })
    ->then(null, function (Throwable $reason) { // 只处理拒绝 (onRejected)
        echo "捕获到错误: " . $reason->getMessage() . "\n";
        // 可以选择返回一个 RejectedPromise 继续传递拒绝状态
        // 也可以返回一个普通值，将链条从拒绝状态转为成功状态
        return new RejectedPromise('错误已处理，但仍是拒绝状态');
    })
    ->then(null, function ($reason) { // 再次捕获拒绝
        echo "最终错误处理: " . $reason . "\n";
    });

// 触发第一个Promise
$promiseA->resolve('从服务A获取的数据');
// 触发第二个Promise (这将导致链式调用继续)
$promiseB->resolve('从服务B获取的数据');

// 运行任务队列，确保所有Promise回调被执行
Utils::queue()->run();</code>

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，完成后解决Promise
    sleep(1); // 阻塞1秒
    $promise->resolve('这是等待的结果');
});

echo "在调用wait()之前...\n";
$result = $promise->wait(); // 阻塞直到Promise完成
echo "wait()返回的结果: " . $result . "\n";
echo "在调用wait()之后...\n";

// 如果Promise被拒绝，wait()会抛出异常
$rejectedPromise = new Promise();
$rejectedPromise->reject(new Exception('操作失败了！'));

try {
    $rejectedPromise->wait();
} catch (Exception $e) {
    echo "wait()捕获到异常: " . $e->getMessage() . "\n";
}</code>

<code class="bash">composer require eventsauce/clock</code>

<code class="php"><?php

require 'vendor/autoload.php';

use EventSauce\Clock\SystemClock;
use EventSauce\Clock\TestClock;
use DateInterval;

// 在生产环境中使用 SystemClock
$systemClock = new SystemClock(new DateTimeZone('Asia/Shanghai'));
echo "当前系统系统时间: " . $systemClock->now()->format('Y-m-d H:i:s') . "\n";

// 在测试环境中使用 TestClock
$testClock = new TestClock();
echo "测试时钟初始时间: " . $testClock->now()->format('Y-m-d H:i:s') . "\n";

// 移动测试时钟
$testClock->moveForward(DateInterval::createFromDateString('1 day'));
echo "测试时钟前进一天: " . $testClock->now()->format('Y-m-d H:i:s') . "\n";

// 固化测试时钟到特定时间
$testClock->fixate('2023-01-01 10:00:00');
echo "测试时钟固化到: " . $testClock->now()->format('Y-m-d H:i:s') . "\n";</code>