Swoole WebSocket服务
Posted willem_chen
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Swoole WebSocket服务相关的知识，希望对你有一定的参考价值。
Swoole WebSocket服务
什么是websockt？
websocket协议是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双工（full-duplex）通信—— 允许服务器主动发送信息给客户端。
为什么需要websocket
缺陷：HTTP的同学只能有客户端发起
WebSocket 特点
建立在TCP协议之上
性能开销小通信高效
客户端可以与任意服务器通信
协议标识符ws wss
持久化网络通信协议
Swoole WebSocket服务
服务端示例
t.php
<?php
/*
0.0.0.0 代表本机IP和所有内外网IP
*/
$server = new Swoole\\WebSocket\\Server("0.0.0.0", 8818);
// set 用于设置运行时的各项参数。服务器启动后通过 $serv->setting 来访问 Server->set 方法设置的参数数组。
$server->set(
[
//开启静态文件请求处理功能，需配合 document_root 使用 默认 false
'enable_static_handler'=>true,
//配置静态文件根目录，与 enable_static_handler 配合使用。v4.4.0以下版本, 此处必须为绝对路径
'document_root'=>"/www/wwwroot/test.cc",
]
);
//监听websocket连接打开事件
$server->on("open","onOpen");
function onOpen($server,$request){
print_r($request->fd.'_打开的连接');
echo PHP_EOL;
}
// 监听ws消息事件
$server->on('message', function (Swoole\\WebSocket\\Server $server, $frame) {
echo "收到连接_{$frame->fd}发送的信息：{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\\n";
$server->push($frame->fd, "后台返回给前台的信息：willem-push-sucsess");
});
$server->on('close', function ($ser, $fd) {
echo "client {$fd} closed\\n";
});
$server->start();
文件位置在linux的项目根目录。
前端示例
t.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>client</title>
</head>
<h1>willem-swoole-ws测试</h1>
<script>
var wsUrl = "ws://test.cc:8818";
var websocket=new WebSocket(wsUrl);
//实例对象的onopen属性
websocket.onopen=function(evt){
websocket.send("发送 hello-willem");
console.log("conected-swoole-success");
}
//实例化 onmessage
websocket.onmessage=function(evt){
alert(evt.data+"：接收到后端发来的信息弹窗");
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);
}
</script>
</body>
</html>
这个代码在Windows的随便一个地方存HTML即可。
应用
1 运行程序
2 预览
3 代码优化
Ws.php
<?php
/*ws 优化 基础类库*/
class Ws{
CONST HOST = "0.0.0.0";
CONST PORT = 8812;
public $ws = null;
public function __construct(){
$this->ws = new Swoole\\WebSocket\\Server("0.0.0.0",8818);
$this->ws->on("open",[$this,"onOpen"]);
$this->ws->on("message",[$this,"onMessage"]);
$this->ws->on("close",[$this,"onClose"]);
$this->ws->start();
}
# 监听ws连接事件
public function onOpen($ws,$request){
var_dump($request->fd);
}
# 监听ws消息事件
public function onMessage($ws,$frame){
echo "收到连接_{$frame->fd}发送的信息：{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\\n";
$ws->push($frame->fd, "后台返回给前台的信息：willem-push-sucsess".date("Y-m-d H:i:s"));
}
# close
public function onClose($ws,$fd){
echo "client:{$fd}\\n";
}
}
$obj=new Ws();
以上是关于Swoole WebSocket服务的主要内容，如果未能解决你的问题，请参考以下文章