PHP用swoole+websocket和redis实现web一对一聊天

Redis  /  管理员 发布于 5年前   598

Redis 实现每个连接websocket的服务都唯一绑定一个用户。通过 用户账号 = websocket fd 存到redis中。

Mysql 实现离线消息池。如果一个用户不在线，则其他用户发送给他的消息暂时存储在mysql。待该用户上线时，再从离线消息池取出发送。

具体参考代码和相应注释：

connect('127.0.0.1', 6379);$db = new mysqli('127.0.0.1', 'test', 'test', 'thinkphp5');$server->on('open', function (swoole_websocket_server $server, $request) { echo "server: handshake success with fd{$request->fd}\n";//$request->fd 是客户端id});$server->on('message', function (swoole_websocket_server $server, $frame) { $data = json_decode($frame->data,true);  if($data['flag'] == 'init'){  //用户刚连接的时候初始化，每个用户登录时记录该用户对应的fd  $GLOBALS['redis']->set($data['from'], $frame->fd);  //处理发给该用户的离线消息  $sql = "SELECT `from`,content FROM thinkphp5.app_offline WHERE `to`='{$data['from']}' AND `from`='{$data['to']}' AND `status`='0' ORDER BY addtime ASC;";  if ($result = $GLOBALS['db']->query($sql)) {   $re = array();   while ($row = $result->fetch_assoc()) {    array_push($re, $row);   }   $result->free();   foreach($re as $content){    $content = json_encode($content);    $server->push($frame->fd , $content);   }   //设置消息池中的消息为已发送   $sql = "UPDATE thinkphp5.app_offline SET `status`=1 WHERE `to`='{$data['from']}' AND `from`='{$data['to']}';";   $GLOBALS['db']->query($sql);  } }else if($data['flag'] == 'msg'){  //非初始化的信息发送，一对一聊天，根据每个用户对应的fd发给特定用户  $tofd = $GLOBALS['redis']->get($data['to']); //消息要发给谁  $fds = []; //所有在线的用户(打开聊天窗口的用户)  foreach($server->connections as $fd){   array_push($fds, $fd);  }  if(in_array($tofd,$fds)){   $tmp['from'] = $data['from']; //消息来自于谁   $tmp['content'] = $data['content']; //消息内容   $re = json_encode($tmp);   $server->push($tofd , $re);  }else{   //该玩家不在线(不在聊天室内)，将信息发送到离线消息池   $time = time();   $sql = "INSERT INTO thinkphp5.app_offline (`to`,`from`,`content`,`status`,`addtime`) VALUES ('{$data['to']}','{$data['from']}','{$data['content']}','0','{$time}');";   $GLOBALS['db']->query($sql);  } }else if($data['flag'] == 'group'){  //todo 群聊   }else if($data['flag'] == 'all'){  //全站广播  foreach($server->connections as $fd){   $server->push($fd , $data);  } } });$server->on('close', function ($ser, $fd) { echo "client {$fd} closed\n";});$server->start();

客户端代码：

          　　
  
        
      
与 {$tonickname} 的聊天      
          
 
 
 
 
  
   
   发送  

数据表结构：

CREATE TABLE `app_offline` ( `id` int(11) NOT NULL AUTO_INCREMENT, `from` varchar(50) DEFAULT NULL COMMENT '离线发送方', `to` varchar(50) DEFAULT NULL COMMENT '离线接收方', `content` varchar(1000) DEFAULT NULL COMMENT '发送的离线内容', `status` tinyint(4) DEFAULT '0' COMMENT '发送状态：0-未发送,1-已发送', `addtime` int(11) DEFAULT NULL COMMENT '发送方发送时间', PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8

具体效果：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

您可能感兴趣的文章:

• ThinkPHP5.0框架结合Swoole开发实现WebSocket在线聊天案例详解
• php redis 处理websocket聊天记录的实例代码
• php+webSoket实现聊天室示例代码（附源码）
• php基于websocket搭建简易聊天室实践
• 基于Swoole实现PHP与websocket聊天室
• php+html5基于websocket实现聊天室的方法