如何用webSocket与Swoole打造一个小型聊天室

JS 代码：

在服务器信息回执时，会有第一次连接回执，还是服务端发送消息回执的状态区别，通过 msgType 来分辨，如果是第一次连接的回执消息，则把 FD 做一个页面留存，并不显示在聊天消息区，如果收到的是消息回执，就直接显示到聊天消息区。

还有就是，前后端相互通信发送的东西，都是字符串性质最优，我前端处理的方法是先组合成一个对象，然后转 JSON 串。

服务端代码
协程，都需要在 Co\run(function () {}) 里。

set([            
'heartbeat_idle_time'      => 600, 
// 表示一个连接如果600秒内未向服务器发送任何数据，此连接将被强制关闭            
'heartbeat_check_interval' => 60,  // 表示每60秒遍历一次        ]);        
$server->handle('/websocket', function ($request, $ws) {            
$ws->upgrade();            
global $wsObjects;            
$objectId = getObjectId($ws);            
$wsObjects[$objectId] = $ws;            
while (true) {                
$frame = $ws->recv();                
if ($frame === '') {                    
unset($wsObjects[$objectId]);                    
$ws->close();                    
break;                
} else if ($frame === false) {                    
echo 'error : ' . swoole_last_error() . "\n";                    
break;                } 
else {                    
if ($frame->data == 'close' || get_class($frame) === Swoole\WebSocket\CloseFrame::class) 
{                        
unset($wsObjects[$objectId]);                        
$ws->close();                        
return;                    
}                    
//格式化接收到json                    
$data = json_decode($frame->data);                    
switch ($data->msgType){                        
case 'open':                            
//链接第一次                            
$data = json_encode([                                
'fd' => $objectId,                                
'msgType' => 1  
//代表第一次连接，前端处理fd                            
]);                            
$ws->push($data);                            
break;                        
case 'ping':                            
//接收到心跳 不作回复//                            
echo  $data->msgType;                            
break;                        
default :                            
// 原基础上不动，增加一些自定义                            
$data->msgType = 2; //代表服务器端回复                            
$data->time = date('Y-m-d H-i-s');                            
$data = json_encode($data);                            
foreach ($wsObjects as $obj) {                                
$obj->push($data);                            
}                    }                
}            }        
});        
$server->start();    });

代码齐全之后，接下来就只需要在控制台执行以下 PHP 文件就行。

然后前台直接访问你的网站地址，我的是本地 127.0.0.1

多开几个窗口模拟多个用户，然后发送消息测试即可

关于“如何用webSocket与Swoole打造一个小型聊天室”这篇文章的内容就介绍到这里，感谢各位的阅读！相信大家对“如何用webSocket与Swoole打造一个小型聊天室”知识都有一定的了解，大家如果还想学习更多知识，欢迎关注创新互联行业资讯频道。