php websocket 帧封装,swoole websocket封装类和调用

上代码 ws.php

/**

* ws 优化 基础类库

* User: singwa

* Date: 18/3/2

* Time: 上午12:34

*/

class Ws {

CONST HOST = "0.0.0.0";

CONST PORT = 9512;

public $ws = null;

public function __construct() {

$this->ws = new swoole_websocket_server("0.0.0.0", 9512);

$this->ws->set(

[

'worker_num' => 2,

'task_worker_num' => 2,

]

);

$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();

}

/**

* 监听ws连接事件

* @param $ws

* @param $request

*/

public function onOpen($ws, $request) {

var_dump($request->fd);

if($request->fd == 1) {

// 每2秒执行

swoole_timer_tick(2000, function($timer_id){

echo "2s: timerId:{$timer_id}\n";

});

}

}

/**

* 监听ws消息事件

* @param $ws

* @param $frame

*/

public function onMessage($ws, $frame) {

echo "ser-push-message:{$frame->data}\n";

// todo 10s

$data = [

'task' => 1,

'fd' => $frame->fd,

];

//$ws->task($data);

swoole_timer_after(5000, function() use($ws, $frame) {

echo "5s-after\n";

$ws->push($frame->fd, "server-time-after:");

});

$ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));

}

/**

* @param $serv

* @param $taskId

* @param $workerId

* @param $data

*/

public function onTask($serv, $taskId, $workerId, $data) {

print_r($data);

// 耗时场景 10s

sleep(10);

return "on task finish"; // 告诉worker

}

/**

* @param $serv

* @param $taskId

* @param $data

*/

public function onFinish($serv, $taskId, $data) {

echo "taskId:{$taskId}\n";

echo "finish-data-sucess:{$data}\n";

}

/**

* close

* @param $ws

* @param $fd

*/

public function onClose($ws, $fd) {

echo "clientid:{$fd}\n";

}

}

$obj = new Ws();

前端代码 ws_client.html

dahai-swoole-ws测试

var wsUrl = "ws://192.168.244.132:9512";

var websocket = new WebSocket(wsUrl);

//实例对象的onopen属性

websocket.onopen = function(evt) {

websocket.send("hello-sinwa");

console.log("conected-swoole-success");

}

// 实例化 onmessage

websocket.onmessage = function(evt) {

console.log("ws-server-return-data:" + evt.data);

}

//onclose

websocket.onclose = function(evt) {

console.log("close");

}

//onerror

websocket.onerror = function(evt, e) {

console.log("error:" + evt.data);

}

结果

00c374924d73f40d845a6aa5b1ef0332.png

874de53dbeec591c417963c25c755338.png

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/501821.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

夸克浏览器怎么安装脚本_广告看烦了?别砸手机!这五款浏览器能拯救你

哈喽大家好,欢迎来到黑马公社。随着各种良莠不齐的内容开始泛滥,黑马发现自己很难通过网络第一时间找到自己想要的内容。在电脑上,黑马为自己的每个浏览器都安装了不下三个广告屏蔽插件,而在手机上,很难。先不说手机浏…

php 今天 明天 后天 显示10天,【微信小程序】实现含有今天,明天,后天的日期组件...

封面图.JPG前言做过微信小程序的前端er都知道,小程序有个日期组件,叫picker,但是,需求方要求日期和时间都要显示的,用picker组件的话,那就用到两个picker,date和time,就是说要让用户…

python dlib 年龄 性别_python dlib学习(一):人脸检测

1、环境安装Windows: 旧版本安装pip install xxx.whl。以下是whl文件地址: ​ Python Package Index​ 最新版本安装:不要嫌麻烦,先装上visual studio2015 (C模块)。​ 具体的记不清了,装上cmake和boost,然…

php数组实例,php常用数组函数实例小结

本文实例总结了php常用数组函数。分享给大家供大家参考,具体如下:1. array array_merge(array $array1 [, array $array2 [, $array]])函数功能:将一个或多个数组的单元合并起来,一个数组中的值附加在前一个数组的后面。返回结果的…

python预测控制_无人驾驶——4.控制之MPC模型预测控制

源自:《无人驾驶无人驾驶车辆模型预测控制》——龚建伟参考:https://wenku.baidu.com/view/8e4633d519e8b8f67c1cb9fa.html0.车辆模型汽车的车轮转角为δf分别做垂直于后轮和前轮的射线,这两根射线会交于O点,两轮模型会绕O点进行运…

php实现git服务器,如何搭建和配置Git服务器

本篇文章给大家带来的内容是介绍如何搭建和配置Git服务器,有一定的参考价值,有需要的朋友可以参考一下,希望对你有所帮助。安装Git安装依赖yum install curl-devel expat-devel gcc gcc-cyum install perl perl-devel gettext-devel openssl-…

手机连接投影机的步骤_投影机安装过程详解

投影机安装过程详解一 投影机的安装方式1、桌面摆放桌面投影虽然看起来不是很美观,但可以省去那些繁琐的步骤,只需要准备一张桌子,还可以购买一些专门用来摆放投影机的可移动小车架,把投影机往上一放,连接上线缆就可以…

php memcached close,PHP连接Memcached安装及数据库操作

memcached介绍Memcached是一套开源的高性能分布式内存对象缓存系统,它将所有的数据都存储在内存中,因为在内存中会统一维护一张巨大的Hash表,所以支持任意存储类型的数据。很多网站通过使用 Memcached提高网站的访问速度,尤其是对于大型的需要频繁访问数据的网站。Memcached是典…

坏道修复是不是硬盘东西全部都没有了_硬盘有坏道就不能用了吗?别再吃哑巴亏了,今天跟大家再说一次...

硬盘是电脑的存储硬件,是电脑中核心的硬件之一,目前市场上主要使用的是固态硬盘与机械硬盘两种,固态硬盘的读写速度较快,容量小,价格贵,机械硬盘读写速度慢,容量大价格便宜,现在的电…

html5+php调用android手机图片,html5+exif.js+canvas+php实现手机上传图片,图片损坏无法打开...

上传图片,图片损坏无法打开,图片路径也是正确的,function selectFileImage(fileObj) {var file fileObj.files[0];//图片方向角 added by lzkvar Orientation null;if (file) {console.log("正在上传,请稍后...");var rFilter /…

word 编辑域中的汉字_15条Word常用操作教程,简单实用,纯干货分享,收藏备用!...

点击蓝字关注我们1. 去除页眉横线在页眉插入信息的时候经常会在下面出现一条横线,如果这条横线影响你的视觉。这时你可以采用下述的两种方法去掉:用第一种的朋友比较多,即选中页眉的内容后,选取“格式”选项,选取“边框…

matlab里面连接器是什么,连接器

连接器连接器,即CONNECTOR。国内亦称作接插件、插头和插座。一般是指电连接器。即连接两个有源器件的器件,传输电流或信号。它广泛应用于航空、航天、国防等军用系统中。连接器是我们电子工程技术人员经常接触的一种部件。它的作用非常单纯:在…

安卓抓包软件_Packet Capture安卓抓包神器介绍及使用教程

除了干货,其他什么也没有源码|资源|软件|教程|揭秘关 注Packet Capture是一款安卓抓包软件,能用来提取用户操作程序内容,Packet Capture可以捕获网络数据包,并记录它们使用中间人技术…

队列处理高并发_高并发场景下缓存处理的一些思路

在实际的开发当中,我们经常需要进行磁盘数据的读取和搜索,因此经常会有出现从数据库读取数据的场景出现。但是当数据访问量次数增大的时候,过多的磁盘读取可能会最终成为整个系统的性能瓶颈,甚至是压垮整个数据库,导致…

多元线性回归分析matlab实验报告,利用MATLAB进行多元线性回归.ppt

《利用MATLAB进行多元线性回归.ppt》由会员分享,可在线阅读,更多相关《利用MATLAB进行多元线性回归.ppt(15页珍藏版)》请在人人文库网上搜索。1、2.线性回归,bregress(y,X) b,bint,r,rint,sregress(y,X,alpha),输入: y因变量(列向量), X1与自变量组成的矩…

python3.6安装tensorflow gpu_tensorflow-gpu安装的常见问题及解决方案

装tensorflow-gpu的时候经常遇到问题,自己装过几次,经常遇到相同或者类似的问题,所以打算记录一下,也希望对其他人有所帮助基本信息tensorflow-gpupip安装(virtualenv等虚拟安装实质也是pip安装,只是建了个独立的环境&…

php env 没有值,PHP DOTENV无法加载env变种

我正在使用php dotenv for env vars for my php application .自述文件说我可以将 php dotenv 加载到我的应用程序中:$dotenv new Dotenv\Dotenv(__DIR__);$dotenv->load();当我尝试登录时,出现500错误 . 我试着 var_dump ing我的 $dotenv var看看它…

pywin32 获取窗口句柄_Excel VBA | 这个窗口居然关不掉

我的目标:让中国的大学生走出校门的那一刻就已经具备这些office技能,让职场人士能高效使用office为其服务。支持我,也为自己加油!还有关不掉的窗体?先来看下效果:通过上图,大家很容易看出二者之…

python mysql驱动写入datetime类型的数据_解决python写入mysql中datetime类型遇到的问题...

刚开始使用python,还不太熟练,遇到一个datetime数据类型的问题:在mysql数据库中,有一个datetime类型的字段用于存储记录的日期时间值。python程序中有对应的一个datetime变量dt。现在需要往mysql数据库中添加记录,每次…

php 函数命名 特殊字符,php 特殊字符处理函数

php 特殊字符处理函数发布于 2014-09-27 23:15:58 | 202 次阅读 | 评论: 0 | 来源: 网友投递PHP开源脚本语言PHP(外文名: Hypertext Preprocessor,中文名:“超文本预处理器”)是一种通用开源脚本语言。语法吸收了C语言、Java和Perl的特点,入门…