swoole——创建WebSocket服务器

一、脚本创建

选择一个文件夹，例如在/var/www/html/project/swoole/pratice下

> vim swoole_ws_service.php

//创建websocket服务器对象，监听0.0.0.0:9502端口

$ws=newswoole_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函数中可以得到 对象，包含了Http握手的相关信息，如GET参数、Cookie、Http头信息等。

建立连接后客户端与服务器端就可以双向通信了。

客户端向服务器端发送信息时，服务器端触发 事件回调

服务器端可以调用 向某个客户端（使用$fd标识符）发送消息

服务器端可以设置 事件回调来手工处理WebSocket握手

二、执行脚本

可以使用Chrome浏览器进行测试，JS代码为：

varwsServer='ws://127.0.0.1:9502';varwebsocket=newWebSocket(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客户端

在项目有中使用swoole/framework可以直接composer require yaozhibo/swoole_framework_libs

三、Comet

WebSocket服务器除了提供WebSocket功能之外，实际上也可以处理Http长连接。只需要增加 事件监听即可实现Comet方案Http长轮询。