程序代码

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服务器相关推荐

  1. Go 快速起步:创建 WebSocket 服务器(聊天室)

    先了解 WebSocket 协议 和 HTTP 协议一样,WebSocket  协议也建立在 TCP/IP 协议基础上,但不一样的是 HTTP 协议 为单向协议,即只能客户端向服务器请求资源,服务器才 ...

  2. node.js创建WebSocket服务,并使用原生js ES6完成对WebSocket数据交互

    注意,前情提示: 本代码基于<Node.js(nodejs)对本地JSON文件进行增.删.改.查操作(轻车熟路)> 传送门Node.js(nodejs)对本地JSON文件进行增.删.改.查 ...

  3. python websocket异步高并发_Python3.5异步和多个websocket服务器

    我在Ubuntu上使用pythonwebsockets4.0.1.我想有2个websocket服务器运行.我可以通过为每个线程创建2个线程和独立的事件循环来实现这一点.我所说的"某种工作&q ...

  4. js websocket同步等待_WebSocket硬核入门:200行代码,教你徒手撸一个WebSocket服务器...

    本文原题"Node.js - 200 多行代码实现 Websocket 协议",为了提升内容品质,有较大修订. 1.引言 最近正在研究 WebSocket 相关的知识,想着如何能自 ...

  5. netty系列之:使用netty搭建websocket服务器

    文章目录 简介 netty中的websocket websocket的版本 FrameDecoder和FrameEncoder WebSocketServerHandshaker WebSocketF ...

  6. undertow服务器分析_使用undertow构建和测试Websocket服务器

    undertow服务器分析 即将发布的JBoss Application Server版本将不再使用Tomcat作为集成的Web服务器,而是将其替换为undertow . undertow的体系结构基 ...

  7. websocket 学习--简单使用,nodejs搭建websocket服务器,到模拟股票,到实现聊天室

    websocket简介: WebSocket协议是 HTML5 开始提供的一种基于TCP的一种新的全双工通讯的网络通讯协议.它允许服务器主动发送信息给客户端. 和http协议的不同?? HTTP 协议 ...

  8. go tcp客户端自动重连_使用 Go 语言创建 WebSocket 服务

    今天介绍如何用 Go 语言创建 WebSocket 服务,文章的前两部分简要介绍了 WebSocket 协议以及用 Go 标准库如何创建 WebSocket 服务.第三部分实践环节我们使用了 gori ...

  9. 使用Go语言创建WebSocket服务

    今天介绍如何用Go语言创建WebSocket服务,文章的前两部分简要介绍了WebSocket协议以及用Go标准库如何创建WebSocket服务.第三部分实践环节我们使用了gorilla/websock ...

最新文章

  1. ThinkPHP实现静态缓存和动态缓存
  2. mysql not in语句_MySQL命令
  3. Framework Design Studio 发布了
  4. android虚线边框_Android实现代码画虚线边框背景效果
  5. Buying Shovels CodeForces - 1360D(数论+找因子)
  6. mysql常用的备份命令有哪些_MySQL常用备份还原命令
  7. 初用vscode遇到中文乱码问题
  8. 网吧服务器系统如何配置,网吧服务器系统配置
  9. 上传视频到FTP服务器+播放
  10. Industry personnel quality of foam mixer is high
  11. 山西省计算机教师招聘试卷,山西教师招聘考试试题(一)
  12. spring boot rest例子
  13. ubuntu系统安装TIM,QQ,微信,迅雷,百度网盘
  14. windows环境下用python PyFtdi控制ftdi芯片生成方波信号
  15. PHP的ob_flush()与flush()区别
  16. c语言实现lower_bound和upper_bound
  17. Mac OSX系统下安装和删除程序
  18. Teen Readers【青少年读者】
  19. Linux实战教学笔记42:squid代理与缓存实践(一)
  20. NOIP模拟赛套路技巧经验总结

热门文章

  1. 卡尔曼滤波器求速度matlab,卡尔曼滤波器算法浅析及matlab实战
  2. mysql update delete_MySQL中UPDATE与DELETE语句的使用教程
  3. java equals比较_Java中equals()和==的比较
  4. 「Apollo」class DescriptorBase(metaclass=DescriptorMetaclass)
  5. solr从pdf、office文档中建立索引
  6. eclipse项目中的.settings .project .classpath 个人见解
  7. TopLink JPA
  8. sqlplus连接远程数据库
  9. MySQL Server 5.0安装教程
  10. 首届UBDC全域大数据峰会:未来的数据一定是全域数据