WebSocket
最后更新于：2022-04-02 02:20:27
[TOC]
## Web Socket
Web Socket协议是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双工full -duplex)通信——**允许服务器主动发送信息给客户端**。
http 的通信只能由客户端去发起
Websockett特点
- 建立在TCP协议之上
- 性能开销小通信高效
- 客户端可以与任意服务器通信
- 协议标识符 WS WSS
- 持久化网络通信协议
## demo
`server/websocket.php`
```
$server = new swoole_websocket_server("0.0.0.0", 8812);
$server->on('open', function (swoole_websocket_server $server, $request) {
echo "server: handshake success with fd: ".$request->fd."\n";
});
$server->on('message', function (swoole_websocket_server $server, $frame) {
echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n";
//push 把数据发送给终端
$server->push($frame->fd, "this is server");
});
$server->on('close', function ($ser, $fd) {
echo "client {$fd} closed\n";
});
$server->start();
```
`data/ws_client.html`
```
Title
测试
```
### 启动方法
在开启 webscoket.php状态下
1. 直接双击打开` ws_client.html`
2. 通过 http_server.php
然后在 http_server.php中设置了`document_root`的目录下打开
3. 只在websocket.php 中设置
```
$server->set([
'document_root' => '/Users/idcpj/Web/swoole/data/', //静态文件存放路径
'enable_static_handler' => true,
]);
```
然后直接访问静态文件即可,无需 http_server.php
## 面向对象的 demo
```
class ws{
const HOST = '0.0.0.0';
const PORT = 8812;
const CHART_PORT = 8813;
public $ws = null;
public function __construct(){
$this->ws = new swoole_websocket_server("0.0.0.0", 8812);
//添加监听端口,用于
$this->ws->listen(self::HOST, self::CHART_PORT, SWOOLE_SOCK_TCP);
$this->ws->on('open',[$this,'onOpen']);
$this->ws->on('message',[$this,'onMsg']);
$this->ws->on('close',[$this,'onClose']);
$this->ws->start();
}
//监听连接事件
public function onOpen($ws, $request){
print_r($request->fd);
}
//监听ws消息事件
public function onMsg($ws,$frame){
echo "ser-push-message".$frame->data."\n";
$ws->push($frame->fd,'server-push'.date('Y-m-d H:i:s',time()));
}
public function onClose($ws,$fd){
echo "clientid:{$fd}\n";
}
}
```
## 获取连接的 id 并放入 redis 中
在 `open` 事件中用redis的 sAdd 存储有序集合 id
```
//存储 只是原来 demo
redis()->sAdd('live_game_key',$id);
//查看 在 redis-cli
SMEMBERS live_game_key
```
在` close` 中删除连接的 id
';