PHP swoole中使用task进程异步的处理耗时任务应用案例分析

【攻略】PHP swoole中使用task进程异步的处理耗时任务应用案例分析

什么是PHP swoole task进程

swoole是一款支持高并发、异步、协程的PHP网络编程框架。而swoole中的task进程是指同步执行完毕后，再进行异步处理的一种进程。可以看作是PHP中的后台异步任务处理进程。

task进程的用途

task进程通常用于那些需要执行时间较久，无法直接在worker进程中处理的任务，在worker进程中调用task进程去异步处理。

例如，后台发送邮件、短信、推送等消息通知功能，采用异步方式去发送，传统方式往往需要等待邮件、短信、推送等返回结果，而这个等待时间往往就长达几秒或者更长时间，容易造成请求阻塞，用户体验不好。此时，通过调用task进程异步处理这些任务，可以将等待时间减少到几毫秒级别，提高用户的操作体验。

swoole的异步task进程基本操作

1. 首先，定义swoole_server::$task_worker_num的值，表示开启task进程的数量；

2. 在onTask回调函数中，进行任务的异步处理；

3. 在onFinish回调函数中，处理异步任务完成后的结果。

示例一

以下的示例是在swoole的TCP服务器中使用task进程异步处理一个每次加1的计数器，获取计数器的值。

//创建swoole TCP服务器
$server = new Server("127.0.0.1", 9501);

//设置task进程的数量
$server->set(['task_worker_num' => 4]);

//设置onReceive事件
$server->on('Receive', function($serv, $fd, $from_id, $data) {
    //异步投递一个任务
    $serv->task($data);
});

//设置onTask事件
$server->on('Task', function ($serv, $task_id, $from_id, $data) {
    //任务处理
    $serv->finish($data + 1);
});

//设置onFinish事件
$server->on('Finish', function ($serv, $task_id, $data) {
    //获取任务执行结果
    echo "Task {$task_id} finish: {$data}\n";
});

//启动服务器
$server->start();

示例中，onReceive回调函数中，接收到客户端发送的数据后，向task进程投递一个异步任务。onTask回调函数中，处理异步任务，将数据加1，将处理结果传递给onFinish回调函数。onFinish回调函数中，获取异步任务结果并输出。

示例二

下面的示例是在swoole的HTTP服务器中使用task进程异步处理请求速度。

//创建swoole HTTP服务器
$server = new swoole_http_server("127.0.0.1", 9501);

//设置task进程的数量
$server->set([
    'worker_num'      => 2,
    'task_worker_num' => 2,
]);

//设置onRequest事件
$server->on('Request', function ($request, $response) use ($server) {
    //开始处理任务
    $task_id = $server->task($request->get['url']);

    //设置超时时间
    $server->tick(1000, function() use ($server, $response) {
        $response->end('Task timeout!');
        $server->clearTimer($task_id);
    });
});

//设置onTask事件
$server->on('Task', function ($serv, $task_id, $from_id, $data) {
    $start_time = microtime(true);
    file_get_contents($data['url']);
    $end_time = microtime(true);

    //处理时间大于5s的任务为失败
    if (($end_time - $start_time) > 5) {
        return false;
    }

    //返回处理结果
    return "success";
});

//设置onFinish事件
$server->on('Finish', function ($serv, $task_id, $data) use ($response) {
    $response->end($data);
});

//启动服务器
$server->start();

在示例中，onRequest回调函数中，接收到客户端请求后，向task进程投递一个异步任务，同时设置超时时间为1秒。onTask回调函数中，处理异步任务，判断请求时间是否大于5秒，如果大于5秒，则返回失败。如果请求时间小于5秒，则返回"success"。onFinish回调函数中，获取异步任务结果并输出。