php 创建定时任务(PHP扩展Swoole实现实时异步任务队列示例)
类别:编程学习 浏览量:1221
时间:2022-03-29 10:06:29 php 创建定时任务
PHP扩展Swoole实现实时异步任务队列示例本文实例讲述了PHP扩展Swoole实现实时异步任务队列。分享给大家供大家参考,具体如下:
假如要发100封邮件,for循环100遍,用户直接揭竿而起,什么破网站!
但实际上,我们很可能有超过1万的邮件。怎么处理这个延迟的问题?
答案就是用异步。把“发邮件”这个操作封装,然后后台异步地执行1万遍。这样的话,用户提交网页后,他所等待的时间只是“把发邮件任务请求推送进队列里”的时间。而我们的后台服务将在用户看不见的地方跑。
在实现“异步队列”这点上,有人采用MySQL表或者redis来存放待发送的邮件,然后,每分钟定时读取待发送列表,然后处理。这便是定时异步任务队列。但当前提交的任务要一分钟后才能执行,在某些实时性要求应用场景里还是不快。有些场景要求,只有一提交任务,便马上执行,但用户不需要等待返回结果。
本文将探讨用php扩展swoole实现实时异步任务队列的方案。
服务端
在打算放置脚本的目录(你也可以自行新建)新建Server.php,代码如下
|
<?php class Server { private $serv ; public function __construct() { $this ->serv = new swoole_server( "0.0.0.0" , 9501); $this ->serv->set( array ( 'worker_num' => 1, //一般设置为服务器CPU数的1-4倍 'daemonize' => 1, //以守护进程执行 'max_request' => 10000, 'dispatch_mode' => 2, 'task_worker_num' => 8, //task进程的数量 "task_ipc_mode " => 3, //使用消息队列通信,并设置为争抢模式 //"log_file" => "log/taskqueueu.log" ,//日志 )); $this ->serv->on( 'Receive' , array ( $this , 'onReceive' )); // bind callback $this ->serv->on( 'Task' , array ( $this , 'onTask' )); $this ->serv->on( 'Finish' , array ( $this , 'onFinish' )); $this ->serv->start(); } public function onReceive(swoole_server $serv , $fd , $from_id , $data ) { //echo "Get Message From Client {$fd}:{$data}\n"; // send a task to task worker. $serv ->task( $data ); } public function onTask( $serv , $task_id , $from_id , $data ) { $array = json_decode( $data , true); if ( $array [ 'url' ]) { return $this ->httpGet( $array [ 'url' ], $array [ 'param' ]); } } public function onFinish( $serv , $task_id , $data ) { //echo "Task {$task_id} finish\n"; //echo "Result: {$data}\n"; } protected function httpGet( $url , $data ) { if ( $data ) { $url .= '?' . http_build_query( $data ); } $curlObj = curl_init(); //初始化curl, curl_setopt( $curlObj , CURLOPT_URL, $url ); //设置网址 curl_setopt( $curlObj , CURLOPT_RETURNTRANSFER, 1); //将curl_exec的结果返回 curl_setopt( $curlObj , CURLOPT_SSL_VERIFYPEER, FALSE); curl_setopt( $curlObj , CURLOPT_SSL_VERIFYHOST, FALSE); curl_setopt( $curlObj , CURLOPT_HEADER, 0); //是否输出返回头信息 $response = curl_exec( $curlObj ); //执行 curl_close( $curlObj ); //关闭会话 return $response ; } } $server = new Server(); |
客户端
启动服务后,让我们看看如何调用服务。新建测试文件Client_test.php
|
<?php class Client { private $client ; public function __construct() { $this ->client = new swoole_client(SWOOLE_SOCK_TCP); } public function connect() { if (! $this ->client->connect( "127.0.0.1" , 9501, 1)) { throw new Exception(sprintf( 'Swoole Error: %s' , $this ->client->errCode)); } } public function send( $data ) { if ( $this ->client->isConnected()) { if (! is_string ( $data )) { $data = json_encode( $data ); } return $this ->client->send( $data ); } else { throw new Exception( 'Swoole Server does not connected.' ); } } public function close() { $this ->client->close(); } } $data = array ( "url" => "http://192.168.10.19/send_mail" , "param" => array ( "username" => 'test' , "password" => 'test' ) ); $client = new Client(); $client ->connect(); if ( $client ->send( $data )) { echo 'success' ; } else { echo 'fail' ; } $client ->close(); |
在上面代码中,url即为任务所在地址,param为所需传递参数。
保存好代码,在命令行或者浏览器中执行Client_test.php,便实现了异步任务队列。你所填写的URL,将会在每次异步任务被提交后,以HTTP GET的方式异步执行。
希望本文所述对大家PHP程序设计有所帮助。
原文链接:https://www.cnblogs.com/tdalcn/p/9359816.html
您可能感兴趣
- php批量导出所有数据库(php快速导入大量数据的实例方法)
- thinkphp5.1插件实现(Thinkphp5.0框架使用模型Model的获取器、修改器、软删除数据操作示例)
- phpcurl请求能在日志里记录吗(php使用curl模拟多线程实现批处理功能示例)
- php不能用mysql(php写入mysql中文乱码的实例解决方法)
- php考试复习题(php+mysql开发的最简单在线题库在线做题系统完整案例)
- php 支付系统(php 实现银联商务H5支付的示例代码)
- 如何用thinkphp框架来写一个网站(php tpl模板引擎定义与使用示例)
- php数组取值方法(php给数组赋值的实例方法)
- php开启curl(解决PHP使用CURL发送GET请求时传递参数的问题)
- php在已有目录下创建文件(php写入文件不覆盖的实例讲解)
- php执行超时怎么办(PHP错误提示It is not safe to rely on the system……的解决方法)
- 腾讯云换php版本(腾讯云服务器配置php环境的方法)
- php小例子(PHP反射实际应用示例)
- dedecms最新手册(在自己的php页面中使用dedecms标签的代码示例)
- php使用yield处理并发(Yii2.0框架模型多表关联查询示例)
- php关注公众号发送消息(php实现QQ小程序发送模板消息功能)
- 今天是什么日子(今天是什么日子有什么特殊意义吗)
- 这里输入关键词(怎么输入关键词搜索)
- 34岁的舒畅,就这样走到了末路,不知会不会后悔15年前的草率决定(就这样走到了末路)
- 不走心的古装造型 舒畅 毁容式 出演,萧蔷雷出新高度(不走心的古装造型)
- 嘉南传 第22集(嘉南传第22集)
- 哪版孙悟空最萌 黄渤躺萌了(哪版孙悟空最萌)
热门推荐
- mysql的7种索引(浅入浅出 MySQL 索引)
- python协程结果(深入浅析python 协程与go协程的区别)
- html5中canvas标签(html5 canvas绘制网络字体的常用方法)
- docker端口映射怎么添加(Docker 动态修改容器端口映射的方法)
- php脚本通过文件路径批量上传文件(php遍历目录下文件并按修改时间排序操作示例)
- python教程第126节(Python 学习教程之networkx)
- asp.net自定义分页控件
- xampp二次安装方法(xampp中apache在windows7下无法启动的解决方法)
- 云服务器如何选择(好的云服务器需要怎么选择?)
- canvas时钟代码(canvas实现烟花的示例代码)