swoole的task模块 应用?
2023-06-13 09:12:23 时间
Swoole的task模块可以用来做一些异步的慢速任务、耗时场景。
如webim中发广播,发送邮件等,把这些任务丢给task进程之后,worker进程可以继续处理新的数据请求,任务完成后会异步通知worker进程告诉它此任务已经完成。 此外利用task还可以实现PHP的数据库连接池,异步队列等。
使用须知
必须设置Task进程数,task_worker_num 投递一个异步任务到task_worker池中。 Server->task 必须注册onTask、onFinish 2个事件回调函数。
示例
以创建一个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服务器监听结果
服务器会先返回消息给客户端,然后再执行投递任务
相关文章
- [译] 依赖注入在多模块工程中的应用
- 《隐私计算技术应用合规指南(2022年)》正式发布
- 【Android Gradle 插件】自定义 Gradle 插件模块 ④ ( META-INF 中声明自定义插件的核心类 | 在应用中依赖本地 Maven 仓库中的自定义 Gradle 插件 )
- 京东37岁程序员回应“被猝死”;腾讯员工2020年人均年薪81万;HM商城App遭多家应用商店下架 | Q资讯
- Oracle 周统计数据分析与应用(oracle周统计数据)
- 每日安全资讯:黑客掌控数万个 GPS 应用账号,甚至可远程关闭汽车引擎
- 下载量超过一亿的流行应用被发现含有恶意模块
- Linux中的神器:Boost库的应用与优化(linuxboost)
- MySQL中SUM类型函数的应用(mysql sum 类型)
- SQL Server在企业应用中的指导作用(sqlserver 应用)
- MSSQL中浮点数据类型的使用及其应用(mssql浮点数据类型)
- 数据库CE模块Oracle数据库构建企业级应用的首选方案(CE模块oracle)
- MySQL文件操作指令,应用广泛,涵盖广泛掌握这些操作指令能够快速编辑和处理各种文件,大大提高工作效率
- Oracle中Java虚拟机的应用与研究(oracle中jvm)
- Ajax+asp应用实例注册模块,表单提交
- ThinkPHP写第一个模块应用
- Apache内容动态缓冲模块mod_cache应用