五分鐘教你寫超簡單的swoole聊天室
原本我是準備接著寫我那個多進程教程的，今天心血來潮想看看swoole的websocket,
swoole-1.7.9 增加了內置的websocket服務器支持，通過幾行PHP代碼就可以寫出一個異步非阻塞多進程的WebSocket服務器。
swoole_websocket_server 繼承自 swoole_http_server，如果設置了onRequest回調，websocket服務器也可以同時作為http服務器。
- $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";
- });
- $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");
- });
- $server->on('close', function ($ser, $fd) {
- echo "client {$fd} closed\n";
- });
- $server->start();
我看了看官網的demo,覺得看起來很簡單嘛，
- <?php
- //官網demo
- $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是客戶端發(fā)送的數(shù)據(jù)
- //服務端向客戶端發(fā)送數(shù)據(jù)是用 $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 )">發(fā)送</button>
- </body>
- </html>
***命令行運行php文件，之后瀏覽器打開html文件，
F12打開調試界面看console，ok ， 沒有問題
這個時候我突然想到一個事情，因為我做多進程的那個教程里，在主進程中會將所有的子進程的句柄存起來，以后進行進程間通訊用。
那么 我將所有的客戶端的鏈接存起來存成數(shù)組，每當一個客戶端發(fā)送消息時，我就遍歷這個客戶端數(shù)組，將消息群發(fā)一遍，不久實現(xiàn)了聊天室了嗎？
然后就，服務端代碼成了這個樣子
- <?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);//循環(huán)廣播
- }
- });
- $server->on('close', function ($ser, $fd) {
- echo "client {$fd} closed\n";
- });
- $server->start();
哈哈 ， 我覺得這樣就大功告成了，結果發(fā)現(xiàn)自己是 圖樣圖森破
大家可以自己試試，運行php后 ， 瀏覽器打開兩個頁面，看看console.log的內容是什么
運行良好，可是并沒有實現(xiàn)我們說的那種聊天效果。
找找原因吧。
我***反映看看$map里面是什么，就輸出看看，結果發(fā)現(xiàn)這個map里面只有一個元素。
唉，不對啊，我這是全局變量，難道不應該是有幾個客戶端鏈接，就有幾個元素嗎？
這是怎么回事啊，竟然沒有保存到所有客戶端id？
到了這一步，我解決不了map變量的這個問題了，然后我就想看看那個fd是什么東西，
老規(guī)矩 var_dump輸出 ， 發(fā)現(xiàn)fd就是 int類型的數(shù)字，并且是自增的
這好辦了，不就是數(shù)字嘛
于是呼，我就這樣做
變量存不了，我搞不定，我存文本里嘛。
最終版 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;
- $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，可以了。
當然，作為聊天室，我這寫的也過于簡陋了，界面大家自己可以寫的好看一些(因為我懶的寫界面)
還有，每次的發(fā)送聊天的記錄，應該存起來，這樣，如果有新的連接連過來的時候，先把以前的聊天記錄發(fā)過去，這樣，我想體驗更好一些
然后，大家可以愉快的聊天了。哈哈
