创建WebSocket服务器
程序代码
ws_server.php
//创建websocket服务器对象,监听0.0.0.0:9502端口
$ws = new swoole_websocket_server("0.0.0.0", 9502);//监听WebSocket连接打开事件
$ws->on('open', function ($ws, $request) {var_dump($request->fd, $request->get, $request->server);$ws->push($request->fd, "hello, welcome\n");
});//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {echo "Message: {$frame->data}\n";$ws->push($frame->fd, "server: {$frame->data}");
});//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {echo "client-{$fd} is closed\n";
});$ws->start();
WebSocket服务器是建立在Http服务器之上的长连接服务器,客户端首先会发送一个Http的请求与服务器进行握手。握手成功后会触发onOpen事件,表示连接已就绪,onOpen函数中可以得到$request
对象,包含了Http握手的相关信息,如GET参数、Cookie、Http头信息等。
建立连接后客户端与服务器端就可以双向通信了。
- 客户端向服务器端发送信息时,服务器端触发
onMessage
事件回调 - 服务器端可以调用
$server->push()
向某个客户端(使用$fd标识符)发送消息 - 服务器端可以设置
onHandShake
事件回调来手工处理WebSocket握手
运行程序
php ws_server.php
可以使用Chrome浏览器进行测试,JS代码为:
var wsServer = 'ws://127.0.0.1:9502';
var websocket = new WebSocket(wsServer);
websocket.onopen = function (evt) {console.log("Connected to WebSocket server.");
};websocket.onclose = function (evt) {console.log("Disconnected");
};websocket.onmessage = function (evt) {console.log('Retrieved data from server: ' + evt.data);
};websocket.onerror = function (evt, e) {console.log('Error occured: ' + evt.data);
};
- 不能直接使用swoole_client与websocket服务器通信,swoole_client是TCP客户端
- 必须实现WebSocket协议才能和WebSocket服务器通信,可以使用swoole/framework提供的PHP WebSocket客户端
Comet
WebSocket服务器除了提供WebSocket功能之外,实际上也可以处理Http长连接。只需要增加onRequest
事件监听即可实现Comet方案Http长轮询。
- 程序代码
- 运行程序
- Comet
来源:https://wiki.swoole.com/wiki/page/479.html
创建WebSocket服务器相关推荐
- Go 快速起步:创建 WebSocket 服务器(聊天室)
先了解 WebSocket 协议 和 HTTP 协议一样,WebSocket 协议也建立在 TCP/IP 协议基础上,但不一样的是 HTTP 协议 为单向协议,即只能客户端向服务器请求资源,服务器才 ...
- node.js创建WebSocket服务,并使用原生js ES6完成对WebSocket数据交互
注意,前情提示: 本代码基于<Node.js(nodejs)对本地JSON文件进行增.删.改.查操作(轻车熟路)> 传送门Node.js(nodejs)对本地JSON文件进行增.删.改.查 ...
- python websocket异步高并发_Python3.5异步和多个websocket服务器
我在Ubuntu上使用pythonwebsockets4.0.1.我想有2个websocket服务器运行.我可以通过为每个线程创建2个线程和独立的事件循环来实现这一点.我所说的"某种工作&q ...
- js websocket同步等待_WebSocket硬核入门:200行代码,教你徒手撸一个WebSocket服务器...
本文原题"Node.js - 200 多行代码实现 Websocket 协议",为了提升内容品质,有较大修订. 1.引言 最近正在研究 WebSocket 相关的知识,想着如何能自 ...
- netty系列之:使用netty搭建websocket服务器
文章目录 简介 netty中的websocket websocket的版本 FrameDecoder和FrameEncoder WebSocketServerHandshaker WebSocketF ...
- undertow服务器分析_使用undertow构建和测试Websocket服务器
undertow服务器分析 即将发布的JBoss Application Server版本将不再使用Tomcat作为集成的Web服务器,而是将其替换为undertow . undertow的体系结构基 ...
- websocket 学习--简单使用,nodejs搭建websocket服务器,到模拟股票,到实现聊天室
websocket简介: WebSocket协议是 HTML5 开始提供的一种基于TCP的一种新的全双工通讯的网络通讯协议.它允许服务器主动发送信息给客户端. 和http协议的不同?? HTTP 协议 ...
- go tcp客户端自动重连_使用 Go 语言创建 WebSocket 服务
今天介绍如何用 Go 语言创建 WebSocket 服务,文章的前两部分简要介绍了 WebSocket 协议以及用 Go 标准库如何创建 WebSocket 服务.第三部分实践环节我们使用了 gori ...
- 使用Go语言创建WebSocket服务
今天介绍如何用Go语言创建WebSocket服务,文章的前两部分简要介绍了WebSocket协议以及用Go标准库如何创建WebSocket服务.第三部分实践环节我们使用了gorilla/websock ...
最新文章
- ThinkPHP实现静态缓存和动态缓存
- mysql not in语句_MySQL命令
- Framework Design Studio 发布了
- android虚线边框_Android实现代码画虚线边框背景效果
- Buying Shovels CodeForces - 1360D(数论+找因子)
- mysql常用的备份命令有哪些_MySQL常用备份还原命令
- 初用vscode遇到中文乱码问题
- 网吧服务器系统如何配置,网吧服务器系统配置
- 上传视频到FTP服务器+播放
- Industry personnel quality of foam mixer is high
- 山西省计算机教师招聘试卷,山西教师招聘考试试题(一)
- spring boot rest例子
- ubuntu系统安装TIM,QQ,微信,迅雷,百度网盘
- windows环境下用python PyFtdi控制ftdi芯片生成方波信号
- PHP的ob_flush()与flush()区别
- c语言实现lower_bound和upper_bound
- Mac OSX系统下安装和删除程序
- Teen Readers【青少年读者】
- Linux实战教学笔记42:squid代理与缓存实践(一)
- NOIP模拟赛套路技巧经验总结
热门文章
- 卡尔曼滤波器求速度matlab,卡尔曼滤波器算法浅析及matlab实战
- mysql update delete_MySQL中UPDATE与DELETE语句的使用教程
- java equals比较_Java中equals()和==的比较
- 「Apollo」class DescriptorBase(metaclass=DescriptorMetaclass)
- solr从pdf、office文档中建立索引
- eclipse项目中的.settings .project .classpath 个人见解
- TopLink JPA
- sqlplus连接远程数据库
- MySQL Server 5.0安装教程
- 首届UBDC全域大数据峰会:未来的数据一定是全域数据