创建WebSocket服务器
生活随笔
收集整理的這篇文章主要介紹了
创建WebSocket服务器
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
程序代碼
ws_server.php
//創(chuàng)建websocket服務(wù)器對象,監(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();WebSocket服務(wù)器是建立在Http服務(wù)器之上的長連接服務(wù)器,客戶端首先會發(fā)送一個(gè)Http的請求與服務(wù)器進(jìn)行握手。握手成功后會觸發(fā)onOpen事件,表示連接已就緒,onOpen函數(shù)中可以得到$request對象,包含了Http握手的相關(guān)信息,如GET參數(shù)、Cookie、Http頭信息等。
建立連接后客戶端與服務(wù)器端就可以雙向通信了。
- 客戶端向服務(wù)器端發(fā)送信息時(shí),服務(wù)器端觸發(fā)onMessage事件回調(diào)
- 服務(wù)器端可以調(diào)用$server->push()向某個(gè)客戶端(使用$fd標(biāo)識符)發(fā)送消息
- 服務(wù)器端可以設(shè)置onHandShake事件回調(diào)來手工處理WebSocket握手
運(yùn)行程序
php ws_server.php可以使用Chrome瀏覽器進(jìn)行測試,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); };- 不能直接使用swoole_client與websocket服務(wù)器通信,swoole_client是TCP客戶端
- 必須實(shí)現(xiàn)WebSocket協(xié)議才能和WebSocket服務(wù)器通信,可以使用swoole/framework提供的PHP WebSocket客戶端
Comet
WebSocket服務(wù)器除了提供WebSocket功能之外,實(shí)際上也可以處理Http長連接。只需要增加onRequest事件監(jiān)聽即可實(shí)現(xiàn)Comet方案Http長輪詢。
- 程序代碼
- 運(yùn)行程序
- Comet
來源:https://wiki.swoole.com/wiki/page/479.html
總結(jié)
以上是生活随笔為你收集整理的创建WebSocket服务器的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 创建Web服务器
- 下一篇: swoole安装基本配置