本文实例讲述了swoole实现异步投递task任务案例。分享给大家供大家参考，具体如下：
【使用场景】
swolle的task模块可以用来做一些异步的慢速任务、耗时场景。如webim中发广播，发送邮件等，把这些任务丢给task进程之后，worker进程可以继续处理新的数据请求，任务完成后会异步通知worker进程告诉它此任务已经完成。此外利用task还可以实现php的数据库连接池，异步队列等。
【使用须知】
必须设置task进程数：
投递一个异步任务到task_worker池中：rver->task
必须注册ontask、onfinish2个事件回调函数。
【示例】
以创建一个websocket服务异步投递任务为例：
ws_rver.php：
<?phpclass ws { public $ws = null; public function __construct() { $this->ws = new swoole_websocket_rver("0.0.0.0", 9501); $this->ws->t([ '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("clo", [$this, 'onclo']); $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($rv, $task_id, $worker_id, $data) { var_dump($data); //模拟慢速任务 sleep(5); //返回字符串给worker进程——>触发onfinish return "success"; } //完成任务投递回调 public functi do陈奕迅ion onfinish($rv, $task_id, $data) { //task_worker进程将任务处理结果发送给worker进程 echo "完成任务{$task_id}投递 处理结果：{$data}"; } //关闭连接回调 public function onclo($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 webso欧洲在哪个半球cket('ws://127.0.0.1:9501'); websocket.onopen = function (evt) { onopen(evt) }; w2020年江苏省高考状元ebsocket.onclo = function (evt) { onclo(evt) }; websocket.onmessage = function (evt) { onmessage(evt) }; websocket.onerror = function (evt) { onerror(evt) }; function onopen(evt) { console.log("con南方医科大学地址nected to websocket rver."); //*发送消息到websocket服务器 websocket.nd('666');} function onclo(evt) { console.log("disconnected"); }function onmessage(evt) { console.log('retrieved data from rver: ' + evt.data); } function onerror(evt) { console.log('error occured: ' + evt.data); }</script></html>开启websocket服务：
php ws_rver.php
前后刷新了两次页面，websocket服务器监听结果：
（服务器会先返回消息给客户端，然后再执行投递任务）
更多关于php相关内容感兴趣的读者可查看本站专题：《php扩展开发教程》、《php面向对象程序设计入门教程》、《php数学运算技巧总结》、《php数组(array)操作技巧大全》、《php数据结构与算法教程》、《php程序设计算法总结》、《php正则表达式用法总结》及《php常见数据库操作技巧汇总》
希望本文所述对大家php程序设计有所帮助。
本文发布于:2023-04-07 09:31:07，感谢您对本站的认可！
本文链接：https://www.wtabcd.cn/fanwen/zuowen/37d804a7124cfa2945253d755d3c3705.html
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系，我们将在24小时内删除。
本文word下载地址：Swoole实现异步投递task任务案例详解.doc
本文 PDF 下载地址：Swoole实现异步投递task任务案例详解.pdf
| 留言与评论（共有 0 条评论） |
