PHP 怎么Task结果获取

wen PHP项目 2026-08-04 166

本文目录导读：

PHP 怎么Task结果获取

Swoole 协程任务
Workerman 异步任务
ReactPHP promise 方式
使用协程（Coroutine）方式
使用 MySQL 异步查询结果
Redis 异步任务队列
Swoole 协程 channel 方式
关键要点

在 PHP 中获取任务（Task）结果通常取决于你使用的并发/异步模型,以下是几种常见场景和解决方案：

Swoole 协程任务

使用 TaskWorker（异步任务）

<?php
use Swoole\Server;
$server = new Server('127.0.0.1', 9501);
// 设置 task 进程数
$server->set([
    'task_worker_num' => 4,
]);
// 投递任务
$server->on('Receive', function ($server, $fd, $reactor_id, $data) {
    echo "收到请求，投递任务\n";
    // 异步投递任务
    $task_id = $server->task("执行任务的数据");
    // 清理旧数据
    $server->send($fd, "任务已投递，ID: {$task_id}\n");
});
// 处理任务
$server->on('Task', function ($server, $task_id, $reactor_id, $data) {
    echo "开始处理任务\n";
    // 执行耗时操作
    $result = "处理结果：" . $data;
    // 返回结果给 Worker 进程
    $server->finish($result);
});
// 接收任务结果
$server->on('Finish', function ($server, $task_id, $data) {
    echo "任务完成，结果：{$data}\n";
});
$server->start();

同步等待任务结果

<?php
use Swoole\Coroutine;
$scheduler = new Coroutine\Scheduler;
$scheduler->add(function () {
    $result = Swoole\Coroutine::create(function () {
        // 模拟耗时操作
        co::sleep(2);
        return "任务结果";
    });
    echo "结果: " . $result;
});
$scheduler->start();

Workerman 异步任务

使用 AsyncTcpConnection

<?php
use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;
require_once __DIR__ . '/vendor/autoload.php';
$worker = new Worker('http://0.0.0.0:8080');
$worker->onMessage = function ($connection, $data) {
    // 建立异步连接
    $task_connection = new AsyncTcpConnection('tcp://127.0.0.1:1234');
    // 发送任务
    $task_connection->send(json_encode(['task' => 'do_something']));
    // 接收任务结果
    $task_connection->onMessage = function ($task_connection, $task_result) use ($connection) {
        $connection->send("任务完成，结果：" . $task_result);
        $task_connection->close();
    };
    $task_connection->connect();
};
Worker::runAll();

ReactPHP promise 方式

<?php
require __DIR__ . '/vendor/autoload.php';
use React\EventLoop\Factory;
use React\Promise\Promise;
$loop = Factory::create();
// 创建异步任务
function asyncTask() {
    return new Promise(function ($resolve, $reject) {
        // 模拟异步操作
        $loop = Factory::create();
        $loop->addTimer(2, function () use ($resolve) {
            $resolve("任务结果");
        });
    });
}
// 调用任务
$promise = asyncTask();
// 获取结果
$promise->then(
    function ($result) {
        echo "任务结果: " . $result;
    },
    function ($error) {
        echo "任务失败: " . $error;
    }
);
$loop->run();

使用协程（Coroutine）方式

<?php
use Swoole\Coroutine;
// 创建协程
Coroutine::create(function () {
    // 使用 Go 函数
    $result = go(function () {
        // 模拟耗时操作
        Coroutine::sleep(2);
        return "协程任务结果";
    });
    // 等待并获取结果
    $data = $result->get();
    echo "获取到结果: " . $data;
});

使用 MySQL 异步查询结果

<?php
use Swoole\Coroutine\MySQL;
$swoole_mysql = new MySQL();
$swoole_mysql->connect([
    'host' => '127.0.0.1',
    'user' => 'root',
    'password' => 'password',
    'database' => 'test',
]);
// 异步查询
$result = $swoole_mysql->query('SELECT * FROM users WHERE id=1');
// 获取结果
$data = $result ? $swoole_mysql->fetch() : null;
echo "查询结果: " . json_encode($data);

Redis 异步任务队列

<?php
use Swoole\Coroutine\Redis;
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
// 生产任务
$task_id = uniqid();
$redis->lpush('task_queue', json_encode(['id' => $task_id, 'data' => '任务数据']));
// 异步消费
Coroutine::create(function () use ($redis) {
    while (true) {
        $result = $redis->brpop('task_queue', 1);
        if ($result) {
            echo "获取到任务: " . $result[1] . PHP_EOL;
            // 处理任务...
        }
        Coroutine::sleep(0.1);
    }
});

Swoole 协程 channel 方式

<?php
use Swoole\Coroutine;
$channel = new Coroutine\Channel(10);
// 生产者
Coroutine::create(function () use ($channel) {
    // 模拟耗时任务
    $channel->push("任务结果1");
    $channel->push("任务结果2");
    $channel->close();
});
// 消费者
Coroutine::create(function () use ($channel) {
    while ($data = $channel->pop()) {
        echo "获取到结果：" . $data . PHP_EOL;
    }
});
Coroutine\run();