ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例详解

swoole  /  管理员 发布于 5年前   689

本文实例讲述了ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例。分享给大家供大家参考，具体如下：

ThinkPHP使用Swoole需要安装 think-swoole Composer包，前提系统已经安装好了Swoole PECL 拓展（相关文章：Linux下源码包安装使用Swoole扩展）

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

composer require topthink/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  ];  //建立连接时回调函数  public function onOpen($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";  }  //接收数据时回调函数  public function onMessage($server,$frame)  {    $fd = $frame->fd;    $message = $frame->data;    //省略通过fd查询用户uid逻辑......    $uid = 666;    $data['uid'] = $uid;    $data['message'] = '用户'.$uid.'发送了:'.$message;    $data['post_time'] = date("m/d H:i",time());    $arr = array('status'=>1,'message'=>'success','data'=>$data);    //仅推送给当前连接用户    //$server->push($fd, json_encode($arr));        //推送给全部连接用户    foreach($server->connections as $fd) {      $server->push($fd, json_encode($arr));    }   }  //连接关闭时回调函数  public function onClose($server,$fd)  {    echo "标识{$fd}关闭了连接\n";  }}

前端演示页面：

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

  
        
在线聊天
    
退出  
  
       
                
发送
    

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

php public/index.php Websocket/start

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

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

lsof -i:9501

 演示效果如下：

服务器监听如下：

用户每刷新重连一次，fd标识都会改变。

更多关于thinkPHP相关内容感兴趣的读者可查看本站专题：《ThinkPHP入门教程》、《thinkPHP模板操作技巧总结》、《ThinkPHP常用方法总结》、《codeigniter入门教程》、《CI(CodeIgniter)框架进阶教程》、《Zend FrameWork框架入门教程》及《PHP模板技术总结》。

希望本文所述对大家基于ThinkPHP框架的PHP程序设计有所帮助。

您可能感兴趣的文章:

• 详解thinkphp5+swoole实现异步邮件群发（SMTP方式）
• php异步多线程swoole用法实例
• Linux下源码包安装Swoole及基本使用操作图文详解
• php安装swoole扩展的方法
• 使用swoole扩展php websocket示例
• PHP的swoole扩展安装方法详细教程
• PHP+swoole实现简单多人在线聊天群发
• Swoole实现异步投递task任务案例详解