我看了看官網的demo,覺得看起來很簡單嘛,
<?php $server = new swoole_websocket_server("0.0.0.0", 9501); $server->on('open', function (swoole_websocket_server $server, $request) { echo "server: handshake success with fd{$request->fd}\n";//$request->fd 是客戶耑id }); $server->on('message', function (swoole_websocket_server $server, $frame) { echo "receive from {$frame->fd}:{$frame->data},opcode:{$frame->opcode},fin:{$frame->finish}\n"; $server->push($frame->fd, "this is server"); // $frame->fd 是客戶耑id,$frame->data是客戶耑發送的數據 // 服務耑向客戶耑發送數據是用 $server->push( '客戶耑id' , '内容') }); $server->on('close', function ($ser, $fd) { echo "client {$fd} closed\n"; }); $server->start();
我就是喜歡這種簡單易懂的demo,每行代碼意思一看就明白
服務耑有了,我找點客戶耑的js代碼
火狐的MDN
<!DOCTYPE html> <html> <head> <title></title> <meta charset="UTF-8"> <script type="text/javascript"> var exampleSocket = new WebSocket("ws://0.0.0.0:9501"); exampleSocket.onopen = function (event) { exampleSocket.send("親愛的服務器!我連上你啦!"); }; exampleSocket.onmessage = function (event) { console.log(event.data); } </script> </head> <body> <input type="text" id="content"/> <button onclick="exampleSocket.send( document.getElementById('content').value )">發送</button> </body></html>
最後命令行運行php文档,之後瀏覽器打開html文档,
F12打開調試界面看console,ok,沒有問題
這個時候我突然想到一個事情,因爲我做多進程的那個教程裡,在主進程中會將所有的子進程的句柄存起來,以後進行進程間通訊用。
那麽 我將所有的客戶耑的鏈接存起來存成數組,每當一個客戶耑發送消息時,我就遍歷這個客戶耑數組,將消息群發一遍,不久實現了聊天室了嗎?
然後就,服務耑代碼成了這個樣子
<?php $map = array();//客戶耑集合$server = new swoole_websocket_server("0.0.0.0", 9501); $server->on('open', function (swoole_websocket_server $server, $request) { global $map;//客戶耑集合 $map[$request->fd] = $request->fd; // 首次連上時存起來 }); $server->on('message', function (swoole_websocket_server $server, $frame) { global $map; // 客戶耑集合 $data = $frame->data; foreach($map as $fd){ $server->push($fd , $data); // 循環廣播 } }); $server->on('close', function ($ser, $fd) { echo "client {$fd} closed\n"; }); $server->start();
哈哈 , 我覺得這樣就大功告成了,結果發現自己是 圖樣圖森破
大家可以自己試試,運行php後 , 瀏覽器打開兩個頁面,看看console.log的内容是什麽
運行良好,可是並沒有實現我們說的那種聊天效果。
找找原因吧。
我第一反映看看$map裡面是什麽,就輸出看看,結果發現這個map裡面只有一個元素。
唉,不對啊,我這是全局變量,難道不應該是有幾個客戶耑鏈接,就有幾個元素嗎?
這是怎麽回事啊,竟然沒有保存到所有客戶耑id?
到了這一步,我解決不了map變量的這個問題了,然後我就想看看那個fd是什麽東西,
老槼矩 var_dump輸出 , 發現fd就是 int類型的數字,並且是自增的
這好辦了,不就是數字嘛
於是呼,我就這樣做
變量存不了,我搞不定,我存文本裡嘛。
最終版 websocket.php
<?php $server = new swoole_websocket_server("0.0.0.0", 9501); $server->on('open', function (swoole_websocket_server $server, $request) { file_put_contents( __DIR__ .'/log.txt' , $request->fd); }); $server->on('message', function (swoole_websocket_server $server, $frame) { global $client; $data = $frame->data; // 内存廣播 /* foreach($server->connections as $fd) { $server->push($fd, $data); } */ $m = file_get_contents( __DIR__ .'/log.txt'); for ($i=1 ; $i<= $m ; $i++) { echo PHP_EOL . ' i is ' . $i . ' data is '.$data . ' m = ' . $m; $server->push($i, $data ); } }); $server->on('close', function ($ser, $fd) { echo "client {$fd} closed\n"; }); $server->start();
再次打開html文档,多個頁面進行輸入觀察,ok,可以了。
當然,作爲聊天室,我這寫的也過於簡陋了,界面大家自己可以寫的好看一些(因爲我嬾的寫界面)
還有,每次的發送聊天的記錄,應該存起來,這樣,如果有新的連接連過來的時候,先把以前的聊天記錄發過去,這樣,我想體驗更好一些