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

2024-10-26 技术教程

这篇文章主要介绍了如何用webSocket与Swoole打造一个小型聊天室的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇如何用webSocket与Swoole打造一个小型聊天室文章都会有所收获，下面我们一起来看看吧。

前端页面代码：

<!DOCTYPEhtml><htmllang="en"><head><metacharset="UTF-8"><title>打工人聊天室</title></head><style>.content{height:400px;max-width:400px;overflow:auto;border-radius:5px;border:1pxsolid#f0f0f0;}</style><body><divid="content"class="content"><p>聊天区域</p></div>你好打工人：<sampid="nickname">昵称</samp><br>本次连接FD:<sampid="fd-samp"></samp><br><inputtype="text"id="msg"><inputtype="hidden"id="fd"value=""><buttonid="send"onclick="send()">发送</button></body></html>

JS 代码：

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

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

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

<?php//定义获取当前的id函数functiongetObjectId(\Swoole\Http\Response$response){if(PHP_VERSION_ID<70200){$id=spl_object_hash($response);}else{$id=spl_object_id($response);}return$id;}Co\run(function(){$server=newCo\Http\Server('127.0.0.1',9502,false);$server->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;}elseif($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-dH-i-s');$data=json_encode($data);foreach($wsObjectsas$obj){$obj->push($data);}}}}});$server->start();});

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

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

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

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