PHP异步操作的救星：如何优雅地处理并发任务和回调地狱，使用GuzzlePromises可以！

guzzlehttp/promises

guzzlehttp/promises

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

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

use GuzzleHttp\Promise\Promise;

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

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

// 模拟一个异步操作，稍后解决Promise
// 在实际应用中，这可能是一个网络请求完成后的回调
echo "异步操作开始..." . PHP_EOL;
// 假设这里有一些耗时操作...
sleep(1); // 模拟耗时

// 解决Promise，触发 $onFulfilled 回调
$promise->resolve('数据已成功获取');

echo "主程序继续执行..." . PHP_EOL;
// 输出:
// 异步操作开始...
// 主程序继续执行...
// 操作成功，结果是: 数据已成功获取

"主程序继续执行..."

"操作成功..."

.then()

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

use GuzzleHttp\Promise\Promise;

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "第一步：处理值 '{$value}'，返回新的数据..." . PHP_EOL;
        return "Hello, " . $value; // 返回的值会传递给下一个then
    })
    ->then(function ($value) {
        echo "第二步：接收到 '{$value}'，进行二次处理..." . PHP_EOL;
        return strtoupper($value); // 再次返回
    })
    ->then(function ($value) {
        echo "第三步：最终结果是 '{$value}'。" . PHP_EOL;
    });

echo "开始异步流程..." . PHP_EOL;
$promise->resolve('reader.'); // 解决初始Promise，启动链式调用
echo "流程已启动，主程序继续..." . PHP_EOL;

// 输出:
// 开始异步流程...
// 流程已启动，主程序继续...
// 第一步：处理值 'reader.'，返回新的数据...
// 第二步：接收到 'Hello, reader.'，进行二次处理...
// 第三步：最终结果是 'HELLO, READER.'。

.then()

.then()

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

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

$promise = new Promise();

$promise
    ->then(function ($value) {
        echo "成功处理: " . $value . PHP_EOL;
        // 模拟一个错误，返回一个RejectedPromise
        return new RejectedPromise('操作失败：数据不符合要求');
    })
    ->then(
        function ($value) {
            echo "这部分不会执行，因为上一个Promise被拒绝了。" . PHP_EOL;
        },
        function ($reason) {
            echo "捕获到错误: " . $reason . PHP_EOL;
            // 可以在这里处理错误，也可以再次抛出或返回一个新的Promise
            throw new \Exception("错误已处理，但需要更正: " . $reason);
        }
    )
    ->then(null, function ($reason) { // 只关心拒绝回调
        echo "最终错误处理: " . $reason->getMessage() . PHP_EOL;
    });

$promise->resolve('初始数据');

// 输出:
// 成功处理: 初始数据
// 捕获到错误: 操作失败：数据不符合要求
// 最终错误处理: 错误已处理，但需要更正: 操作失败：数据不符合要求

wait()

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

use GuzzleHttp\Promise\Promise;

$promise = new Promise(function () use (&$promise) {
    // 模拟一个耗时操作，完成后解决Promise
    sleep(2);
    $promise->resolve('等待成功的数据');
});

echo "异步操作已启动，但现在需要同步等待其结果..." . PHP_EOL;
$result = $promise->wait(); // 会阻塞直到Promise完成
echo "同步等待完成，结果是: " . $result . PHP_EOL;

// 输出:
// 异步操作已启动，但现在需要同步等待其结果...
// (等待2秒)
// 同步等待完成，结果是: 等待成功的数据

wait()

wait()

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises