PHP+swoole实现简单多人在线聊天群发

php  /  管理员 发布于 3年前   255

由于本文的能力有限，有好多聊天逻辑的细节没有实现，只实现了群发，具体代码如下所示：

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;}

前端代码：

 
WebSocket Test
 昵称：  发送

 
 

推荐文章：php安装swoole扩展的方法    使用swoole扩展php websocket示例

以上代码给大家分享了PHP+swoole实现简单多人在线聊天群发的相关代码，希望本文所述对大家有所帮助。

您可能感兴趣的文章:

• PHP swoole和redis异步任务实现方法分析
• php异步多线程swoole用法实例
• 详解thinkphp5+swoole实现异步邮件群发（SMTP方式）
• PHP扩展Swoole实现实时异步任务队列示例
• php基于 swoole 实现的异步处理任务功能示例
• PHP Swoole异步MySQL客户端实现方法示例
• linux平台编译安装PHP7并安装Redis扩展与Swoole扩展实例教程
• docker搭建php+nginx+swoole+mysql+redis环境的方法
• php安装swoole扩展的方法
• 基于Swoole实现PHP与websocket聊天室
• PHP Swoole异步Redis客户端实现方法示例