Swoole异步投递task任务
2019-07-24 08:58:17来源:编程学习网 阅读 ()
【使用场景】
Swoole的task模块可以用来做一些异步的慢速任务、耗时场景。如webim中发广播,发送邮件等,把这些任务丢给task进程之后,worker进程可以继续处理新的数据请求,任务完成后会异步通知worker进程告诉它此任务已经完成。此外利用task还可以实现PHP的数据库连接池,异步队列等。
【使用须知】
必须设置Task进程数:task_worker_num
投递一个异步任务到task_worker池中:Server->task
必须注册onTask、onFinish2个事件回调函数。
【示例】
以创建一个WebSocket服务异步投递任务为例:
ws_server.php:
<?php class Ws { public $ws = null; public function __construct() { $this->ws = new swoole_websocket_server("0.0.0.0", 9501); $this->ws->set([ 'worker_num' => 2, //worker进程数 'task_worker_num' => 2, //task进程数 ]); $this->ws->on("open", [$this, 'onOpen']); $this->ws->on("message", [$this, 'onMessage']); $this->ws->on("task", [$this, 'onTask']); $this->ws->on("finish", [$this, 'onFinish']); $this->ws->on("close", [$this, 'onClose']); $this->ws->start(); } //建立连接回调 public function onOpen($ws, $request) { echo "{$request->fd}建立了连接"; } //接受消息回调 public function onMessage($ws, $frame) { //worker进程异步投递任务到task_worker进程中 $data = [ 'fd' => $frame->fd, ]; $ws->task($data); //服务器返回 echo "服务器发送消息:666"; } //完成异步任务回调 public function onTask($serv, $task_id, $worker_id, $data) { var_dump($data); //模拟慢速任务 sleep(5); //返回字符串给worker进程——>触发onFinish return "success"; } //完成任务投递回调 public function onFinish($serv, $task_id, $data) { //task_worker进程将任务处理结果发送给worker进程 echo "完成任务{$task_id}投递 处理结果:{$data}"; } //关闭连接回调 public function onClose($ws, $fd) { echo "{$fd}关闭了连接"; } } $obj = new Ws();
前端页面js监听:
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> <html xmlns="http://www.w3.org/1999/xhtml"> <head> <title>WebSocket</title> </head> <body> </body> <script type="text/javascript"> var websocket = new WebSocket('ws://127.0.0.1:9501'); websocket.onopen = function (evt) { onOpen(evt) }; websocket.onclose = function (evt) { onClose(evt) }; websocket.onmessage = function (evt) { onMessage(evt) }; websocket.onerror = function (evt) { onError(evt) }; function onOpen(evt) { console.log("Connected to WebSocket server."); //*发送消息到websocket服务器 websocket.send('666'); } function onClose(evt) { console.log("Disconnected"); } function onMessage(evt) { console.log('Retrieved data from server: ' + evt.data); } function onError(evt) { console.log('Error occured: ' + evt.data); } </script> </html>
开启WebSocket服务:
php ws_server.php
前后刷新了两次页面,WebSocket服务器监听结果
服务器会先返回消息给客户端,然后再执行投递任务
原文链接:http://www.phpxs.com/post/6328/
如有疑问请与原作者联系
标签:
版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点,本站所提供的摄影照片,插画,设计作品,如需使用,请与原作者联系,版权归原作者所有
下一篇:用Redis实现用户积分排行榜
- PHP 使用 Swoole - TaskWorker 实现异步操作 Mysql 2019-09-23
- ThinkPHP5结合Swoole开发实现WebSocket在线聊天 2019-09-08
- php+swoole多线程的操作 2019-07-24
- Swoole_process实现进程池的方法 2019-07-24
- 协程与Swoole的原理,相关应用以及适用场景等 2019-07-24
IDC资讯: 主机资讯 注册资讯 托管资讯 vps资讯 网站建设
网站运营: 建站经验 策划盈利 搜索优化 网站推广 免费资源
网络编程: Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它
服务器技术: Web服务器 Ftp服务器 Mail服务器 Dns服务器 安全防护
软件技巧: 其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷
网页制作: FrontPages Dreamweaver Javascript css photoshop fireworks Flash