由于本文的能力有限,有好多聊天逻辑的细节没有实现,只实现了群发,具体代码如下所示:
php代码:
$serv = new swoole_websocket_server("127.0.0.1",3999); //服务的基本设置 $serv->set(array( 'worker_num' => 2, 'reactor_num'=>8, 'task_worker_num'=>1, 'dispatch_mode' => 2, 'debug_mode'=> 1, 'daemonize' => true, 'log_file' => __DIR__.'/log/webs_swoole.log', 'heartbeat_check_interval' => 60, 'heartbeat_idle_time' => 600, )); $serv->on('connect', function ($serv,$fd){ // echo "client:$fd Connect.".PHP_EOL; }); //测试receive $serv->on("receive",function(swoole_server $serv,$fd,$from_id,$data){ // echo "receive#{$from_id}: receive $data ".PHP_EOL; }); $serv->on('open', function($server, $req) { // echo "server#{$server->worker_pid}: handshake success with fd#{$req->fd}".PHP_EOL;; // echo PHP_EOL; }); $serv->on('message',function($server,$frame) { // echo "message: ".$frame->data.PHP_EOL; $msg=json_decode($frame->data,true); switch ($msg['type']){ case 'login': $server->push($frame->fd,"欢迎欢迎~"); break; default: break; } $msg['fd']=$frame->fd; $server->task($msg); }); $serv->on("workerstart",function($server,$workerid){ // echo "workerstart: ".$workerid.PHP_EOL; // echo PHP_EOL; }); $serv->on("task","on_task"); $serv->on("finish",function($serv,$task_id,$data){ return ; }); $serv->on('close', function($server,$fd,$from_id) { // echo "connection close: ".$fd.PHP_EOL; // echo PHP_EOL; }); $serv->start(); function on_task($serv,$task_id,$from_id,$data) { switch ($data['type']){ case 'login': $send_msg="说:我来了~"; break; default: $send_msg="说:{$data['msg']['speak']}"; break; } foreach ($serv->connections as $conn){ if ($conn!=$data['fd']){ if (strpos($data['msg']['name'],"游客")===0){ $name=$data['msg']['name']."_".$data['fd']; }else{ $name=$data['msg']['name']; } }else{ $name="我"; } $serv->push($conn,$name.$send_msg); } return; } function on_finish($serv,$task_id,$data){ return true; }
前端代码:
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> <title>WebSocket测试</title> <script language="javascript"type="text/javascript" src="/UploadFiles/2021-04-02/jquery-1.12.0.min.js">推荐文章:php安装swoole扩展的方法 使用swoole扩展php websocket示例
以上代码给大家分享了PHP+swoole实现简单多人在线聊天群发的相关代码,希望本文所述对大家有所帮助。
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件!
如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
狼山资源网 Copyright www.pvsay.com
暂无“PHP+swoole实现简单多人在线聊天群发”评论...
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?