drools机制(Swoole实现异步投递task任务案例详解)
类别:编程学习 浏览量:1067
时间:2022-03-31 20:07:47 drools机制
Swoole实现异步投递task任务案例详解本文实例讲述了swoole实现异步投递task任务案例。分享给大家供大家参考,具体如下:
【使用场景】
swolle的task模块可以用来做一些异步的慢速任务、耗时场景。如webim中发广播,发送邮件等,把这些任务丢给task进程之后,worker进程可以继续处理新的数据请求,任务完成后会异步通知worker进程告诉它此任务已经完成。此外利用task还可以实现php的数据库连接池,异步队列等。
【使用须知】
必须设置task进程数:
投递一个异步任务到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服务器监听结果:
(服务器会先返回消息给客户端,然后再执行投递任务)
希望本文所述对大家php程序设计有所帮助。
原文链接:https://blog.csdn.net/msllws/article/details/84782809
您可能感兴趣
- php脚本控制方法(php swoole多进程/多线程用法示例基于php7nts版)
- phpredis怎么实现任务(PHP swoole和redis异步任务实现方法分析)
- php 创建定时任务(PHP扩展Swoole实现实时异步任务队列示例)
- linux虚拟主机怎么设置(linux系统虚拟主机开启支持Swoole Loader扩展的方法)
- php的流程控制语句(php基于 swoole 实现的异步处理任务功能示例)
- drools机制(Swoole实现异步投递task任务案例详解)
- drools动态执行规则(使用swoole 定时器变更超时未支付订单状态的解决方案)
- php单例模式教程学习(PHP下用Swoole实现Actor并发模型的方法)
- php的流程控制语句(PHP基于swoole多进程操作示例)
- thinkphp接口开发实例(ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例详解)
- php系统化框架教程(PHP+swoole+linux实现系统监控和性能优化操作示例)
- sw动态注解视图干嘛的(Swoole 5将移除自动添加Event::wait特性详解)
- curl怎么设置方法(关于Curl在Swoole协程中的解决方案详析)
- 袁冰妍轧戏 拍《琉璃》的同时还在拍《将夜》,难怪被骂演技差(拍琉璃的同时还在拍将夜)
- 刚红就耍大牌,《琉璃》角色滤镜碎一地,心疼工作人员(琉璃角色滤镜碎一地)
- 袁冰妍郑业成这对可以处,有脸红情话他们是真的敢说(袁冰妍郑业成这对可以处)
- 《祝卿好》台词又土又甜,就喜欢这么直接的恋爱(祝卿好台词又土又甜)
- 大女主 汤唯垂青电视圈,搭档朱亚文出演《大明皇妃孙若微传》(汤唯垂青电视圈)
- 红色代表什么(红色代表什么情感和含义)
热门推荐
- apache漏洞怎么排查(apache urlrewrite防盗链功能配置)
- linux基本命令pwd(在Linux上使用xargs命令的详细教程)
- try中finally与return
- python爬取酷狗收费音乐(python爬取酷狗音乐排行榜)
- python如何把字符串转换成数字(python实现字符串加密成纯数字)
- 命令行如何使用xampp中的mysql(解决xampp自启动和mysql.sock问题)
- python爬虫request方法介绍(详解Python3网络爬虫二:利用urllib.urlopen向有道翻译发送数据获得翻译结果)
- react性能优化是哪个周期(React 并发功能体验前端的并发模式)
- pythonredis列表(Python redis操作实例分析连接、管道、发布和订阅等)
- dedecms分页样式(dedecms列表页文章摘要字数的设置方法)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9