使用swoole实现异步任务处理

淡淡的烟草味﹌ 2022-02-13 13:45 460阅读 0赞

使用swoole实现异步任务处理，有以下几个目标：

*  能够异步非阻塞处理任务
 *  能够实时查询任务状态
 *  任务完成之后，可以执行一些操作或者回调

swoole内置的swoole\_http\_server正好非常适合处理这种业务，示例代码实现如下

php#!/bin/env php
    <?php
    $http = new swoole_http_server("0.0.0.0", 9501);
    //redis 存储任务处理结果和进度
    $redis = new \Redis();
    $redis->connect("127.0.0.1", 6379);
    
    $http->set([
        'worker_num' => 2,
        'open_tcp_nodelay' => true,
        'task_worker_num' => 2,
        'daemonize' => true,
        'log_file' => '/tmp/swoole_http_server.log',
    ]);
    
    $http->on('request', function(swoole_http_request $request, swoole_http_response $response) use ($http, $redis) {
        //请求过滤
        if($request->server['path_info'] == '/favicon.ico' || $request->server['request_uri'] == '/favicon.ico'){
            return $response->end();
        }   
        $taskId = isset($request->get['taskId']) ? $request->get['taskId']: ''; 
        if($taskId !== ''){
            //返回任务状态
            $status = $redis->get($taskId);
            return $response->end("task: $taskId;status: $status");
        }   
        $params = json_encode(array(111,222));//此处处理requst请求数据作为任务执行的数据，根据需要修改
        $taskId = $http->task($params);
        $response->end("
    
    <h1>Do task:$taskId.</h1>
    
    ");
    });
    $http->on('Finish', function($serv, $taskId, $data){
       //TDDO 任务结束之后处理任务或者回调
        echo "$taskId task finish";
    });
    $http->on('task', function($serv, $taskId, $fromId, $data) use($redis){
        //任务处理，可以把处理结果和状态在redis里面实时更新，便于获取任务状态
        for($i = 0; $i < 100;$i++){
             $redis->set($taskId, $i);
             sleep(1);
        }
        return $i;//必须有return 否则不会调用onFinish
    });
    
    $http->start();

如有更好方案，请多多指教。