微客导航 » 文章资讯 » PHP框架实现WebSocket在线聊天通讯系统

PHP框架实现WebSocket在线聊天通讯系统

2023-08-08 12:21:06 275

ThinkPHP使用Swoole需要安装think-swooleComposer包，前提系统已经安装好了SwoolePECL拓展

tp5的项目根目录下执行composer命令安装think-swoole：

composerrequiretopthink/think-swoole

话不多说，直接上代码：

新建WebSocket.php控制器：

（监听端口要确认服务器放行，宝塔环境还需要添加安全组规则）

4,//设置启动的Worker进程数
'daemonize'=>false,//守护进程化（上线改为true）
'backlog'=>128,//Listen队列长度
'dispatch_mode'=>2,//固定模式，保证同一个连接发来的数据只会被同一个worker处理
//心跳检测：每60秒遍历所有连接，强制关闭10分钟内没有向服务器发送任何数据的连接
'heartbeat_check_interval'=>60,
'heartbeat_idle_time'=>600
];
//建立连接时回调函数
publicfunctiononOpen($server,$req)
{
$fd=$req->fd;//客户端标识
$uid=$req->get['uid'];//客户端传递的用户id
$token=$req->get['token'];//客户端传递的用户登录token
//省略token验证逻辑......
if(!$token){
$arr=array('status'=>2,'message'=>'token已过期');
$server->push($fd,json_encode($arr));
$server->close($fd);
return;
}
//省略给用户绑定fd逻辑......
echo"用户{$uid}建立了连接,标识为{$fd}\n";
}
//接收数据时回调函数
publicfunctiononMessage($server,$frame)
{
$fd=$frame->fd;
$message=$frame->data;
//省略通过fd查询用户uid逻辑......
$uid=666;
$data['uid']=$uid;
$data['message']='用户'.$uid.'发送了:'.$message;
$data['post_time']=date("m/dH:i",time());
$arr=array('status'=>1,'message'=>'success','data'=>$data);
//仅推送给当前连接用户
//$server->push($fd,json_encode($arr));
//推送给全部连接用户
foreach($server->connectionsas$fd){
$server->push($fd,json_encode($arr));
}
}
//连接关闭时回调函数
publicfunctiononClose($server,$fd)
{
echo"标识{$fd}关闭了连接\n";
}
}

前端演示页面：

（省略控制器判断登录状态、分配数据逻辑......）







Chat







在线聊天
退出

发送

$(function(){ varuid=666;//当前用户id vartoken='abcdefg';//用户token //判断浏览器是否支持WebSocket varsupportsWebSockets='WebSocket'inwindow||'MozWebSocket'inwindow; if(supportsWebSockets){ //建立WebSocket连接（ip地址换成自己主机ip） varws=newWebSocket("ws://127.0.0.1:9501?uid="+uid+"&token="+token); ws.onopen=function(){ layer.msg('服务器连接成功',{shade:0.1,icon:1,time:600}); }; ws.onerror=function(){ layer.msg('服务器连接失败',{shade:0.1,icon:2,time:600}); }; ws.onmessage=function(evt){ vardata=$.parseJSON(evt.data); //错误提示 if(data.status!=1){ layer.alert(data.message,{icon:2}); return; } //消息返回 if(data.status==1&&data.data.message!=''){ varhtml=""; if(data.data.uid==uid){ html+=""+data.data.post_time+"

"+data.data.message+"

"; }else{ html+=""+data.data.post_time+"

"+data.data.message+"

"; } } $(".message").append(html); setTimeout(function(){ ($('.message').children("div:last-child")[0]).scrollIntoView();//向上滚动 },100); }; ws.onclose=function(res){ }; //按钮发送 $("#sendBtn").click(function(){ varcontents=$("#msg").val().trim(); if(contents==null||contents==""){ layer.msg('内容为空',{shade:0.1,icon:2,time:600}); returnfalse; }else{ ws.send(contents); $("#msg").val(""); } }); //回车发送 $("#msg").keydown(function(evel){ varthat=$(this); if(evel.keyCode==13){ evel.cancelBubble=true; evel.preventDefault(); evel.stopPropagation(); varcontents=that.val().trim(); if(contents==null||contents==""){ layer.msg('内容为空',{shade:0.1,icon:2,time:600}); returnfalse; }else{ ws.send(contents); that.val(""); } } }); }else{ layer.alert("您的浏览器不支持WebSocket!"); } });

服务器移到项目根目录开启服务：

phppublic/index.phpWebsocket/start

这里的路径，是因为我绑定了home模块为默认模块，tp5默认情况是：phppublic/index.phpindex/Websocket/start）

开启成功，查看端口已经被监听：

lsof-i:9501

很多PHPer在进阶的时候总会遇到一些问题和瓶颈，业务代码写多了没有方向感，不知道该从那里入手去提升，对此我整理了一些资料，包括但不限于：分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家，需要请戳这里

总结

以上所述是小编给大家介绍的PHP框架实现WebSocket在线聊天通讯系统，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持！
如果你觉得本文对你有帮助，欢迎转载，烦请注明出处，谢谢！

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

返回顶部
3162201930
czq8825@qq.com

PHP框架实现WebSocket在线聊天通讯系统

热门推荐

随机推荐