PHP框架实现WebSocket在线聊天通讯系统
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 在线聊天 退出