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长轮询。

  • 发表于:
  • 原文链接https://kuaibao.qq.com/s/20180606G11KHI00?refer=cp_1026
  • 腾讯「云+社区」是腾讯内容开放平台帐号(企鹅号)传播渠道之一,根据《腾讯内容开放平台服务协议》转载发布内容。

扫码关注云+社区

领取腾讯云代金券