WebSocket 服務(wù)器

程序代碼

ws_server.php

//創(chuàng)建websocket服務(wù)器對(duì)象，監(jiān)聽0.0.0.0:9502端口
$ws = new Swoole\WebSocket\Server("0.0.0.0", 9502);

//監(jiān)聽WebSocket連接打開事件
$ws->on('open', function ($ws, $request) {
    var_dump($request->fd, $request->get, $request->server);
    $ws->push($request->fd, "hello, welcome\n");
});

//監(jiān)聽WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    echo "Message: {$frame->data}\n";
    $ws->push($frame->fd, "server: {$frame->data}");
});

//監(jiān)聽WebSocket連接關(guān)閉事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();

• 客戶端向服務(wù)器端發(fā)送信息時(shí)，服務(wù)器端觸發(fā) onMessage 事件回調(diào)
• 服務(wù)器端可以調(diào)用 $server->push() 向某個(gè)客戶端（使用 $fd 標(biāo)識(shí)符）發(fā)送消息

運(yùn)行程序

php ws_server.php

可以使用 Chrome 瀏覽器進(jìn)行測(cè)試，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);
};

Comet

WebSocket 服務(wù)器除了提供 WebSocket 功能之外，實(shí)際上也可以處理 Http 長連接。只需要增加 onRequest 事件監(jiān)聽即可實(shí)現(xiàn) Comet 方案 Http 長輪詢。

詳細(xì)使用方法參考 Swoole\Websocket