編碼的世界 / 優質文選 / 文明

使用php的swoole框架,實現高性能長連接websocket


2022年5月24日
-   

swoole的官網請見:http://www.swoole.com/ swoole-git:https://github.com/swoole/swoole-src
一.服務器端:
1. 編輯server.php文件內容如下:
<?php
$reqs=array(); //保持客戶端的長連接在這個數組裏
$serv = new swoole_websocket_server("192.168.2.115", 9502);
//如下可以設置多端口監聽
//$server = new swoole_websocket_server("0.0.0.0", 9501, SWOOLE_BASE);
//$server->addlistener('0.0.0.0', 9502, SWOOLE_SOCK_UDP);
//$server->set(['worker_num' => 4]);
$serv->on('Open', function($server, $req) {
global $reqs;
$reqs[]=$req->fd;
echo "connection open: ".$req->fd."
";
var_dump(count($reqs));//輸出長連接數
});
$serv->on('Message', function($server, $frame) {
global $reqs;
echo "message: ".$frame->data."
";
foreach($reqs as $fd){
$server->push($fd, $frame->data);
}
});
$serv->on('Close', function($server, $fd) {
echo "connection close: ".$fd."
";
});
$serv->start();

2. 啟動上面實現的websocket服務代碼
[songaimin@localhost Tests]$/usr/bin/php server.php

客戶端-同事打開兩個瀏覽器模擬多client:
3. 在瀏覽器console裏運行:
var wsl= 'ws://192.168.2.115:9502'
ws = new WebSocket(wsl);//新建立一個連接
//如下指定事件處理
ws.onopen = function(){ws.send('Test!'); };
ws.onmessage = function(evt){console.log(evt.data);/*ws.close();*/};
ws.onclose = function(evt){console.log('WebSocketClosed!');};
ws.onerror = function(evt){console.log('WebSocketError!');};

4. 在任意瀏覽器console裏手動執行:
ws.send(888);
//看每個瀏覽器的內容console輸出應該是一樣的就實驗在成功了
ws.close();//關閉連接

相關推薦文章: swoole實現的實時聊天室 http://segmentfault.com/a/1190000003057118

熱門文章