使用swoole实现异步任务处理
2017-12-19 09:15
696 查看
使用swoole实现异步任务处理,有以下几个目标:
能够异步非阻塞处理任务
能够实时查询任务状态
任务完成之后,可以执行一些操作或者回调
swoole内置的swoole_http_server正好非常适合处理这种业务,示例代码实现如下
#!/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();
能够异步非阻塞处理任务
能够实时查询任务状态
任务完成之后,可以执行一些操作或者回调
swoole内置的swoole_http_server正好非常适合处理这种业务,示例代码实现如下
#!/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();
相关文章推荐
- PHP使用swoole来实现实时异步任务队列
- PHP使用swoole来实现实时异步任务队列
- Javascript使用定时器来处理数组和分割任务实现异步
- 在tornado中使用celery实现异步任务处理之一
- PHP使用swoole来实现实时异步任务队列
- PHP使用swoole来实现实时异步任务队列
- 在tornado中使用celery实现异步任务处理之二
- 在tornado中使用celery实现异步任务处理之中的一个
- Android性能优化之使用线程池处理异步任务
- 使用libcurl第三方库实现Android异步任务
- Java基础知识强化之网络编程笔记15:Android网络通信之 Android异步任务处理(AsyncTask使用)
- Android性能优化之使用线程池处理异步任务
- 在ASP.NET Web API项目中使用Hangfire实现后台任务处理
- PHP实现异步任务分发处理利器-Gearman
- Android 性能优化之使用线程池处理异步任务
- Android性能优化之使用线程池处理异步任务
- 使用 RxAndroid 处理异步任务
- PHP使用QPM实现多进程并行任务处理程序
- Android使用自己封装的Http和Thread、Handler实现异步任务
- Android性能优化之使用线程池处理异步任务