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
您可能感兴趣
- sw动态注解视图干嘛的(Swoole 5将移除自动添加Event::wait特性详解)
- linux虚拟主机怎么设置(linux系统虚拟主机开启支持Swoole Loader扩展的方法)
- thinkphp接口开发实例(ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例详解)
- php系统化框架教程(PHP+swoole+linux实现系统监控和性能优化操作示例)
- php的流程控制语句(PHP基于swoole多进程操作示例)
- drools机制(Swoole实现异步投递task任务案例详解)
- php脚本控制方法(php swoole多进程/多线程用法示例基于php7nts版)
- curl怎么设置方法(关于Curl在Swoole协程中的解决方案详析)
- php的流程控制语句(php基于 swoole 实现的异步处理任务功能示例)
- php单例模式教程学习(PHP下用Swoole实现Actor并发模型的方法)
- php 创建定时任务(PHP扩展Swoole实现实时异步任务队列示例)
- phpredis怎么实现任务(PHP swoole和redis异步任务实现方法分析)
- drools动态执行规则(使用swoole 定时器变更超时未支付订单状态的解决方案)
- 800壮士拼死拖住30万日军 八佰 的真实历史,誓与阵地共存亡(800壮士拼死拖住30万日军)
- 演员陈创,火于 哮天犬 ,颠峰于 福贵 ,现状却令人唏嘘(演员陈创火于哮天犬)
- 幼小衔接-20以内看图读数 写数 数的组成练习题(幼小衔接-20以内看图读数)
- 你只要花上20天记单词,英语成绩就能从57提到100(你只要花上20天记单词)
- 夕云天际飞,亢龙化太极(夕云天际飞亢龙化太极)
- 爱情可以当饭吃吗(怎么回复)
热门推荐
- sp_reset_connection的作用
- jquery中find()与filter()的区别
- css3图片悬停切换代码(CSS3 实现的图片悬停的切换按钮)
- 华为云服务器远程登录后怎么办(华为云服务器怎么登陆不上去)
- centos7 apache配置(CentOSLinux下的apache服务器配置与管理方法分享)
- python socket 设置通信协议(详解python中TCP协议中的粘包问题)
- Visual Studio 调试方法
- idea如何运行tomcat项目(在IDEA 2020.3.1中部署Tomcat并且创建第一个web项目的过程详解)
- mysql存储过程limit参数(MySQL存储过程in、out和inout参数示例和总结)
- thinkphp5框架分析(thinkPHP5框架路由常用知识点汇总)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9