当前位置：Gxlcms > PHP教程 > php怎么实现聊天功能

php怎么实现聊天功能

时间：2021-07-01 10:21:17 帮助过：32人阅读

php怎么实现聊天功能

1、在前端使用Ajax定时轮询访问php脚本，php再进行查询聊天数据进行返回给前端，最后前端将其进行渲染；

代码示例：

  1. <html>
  2. <head>
  3. <title>聊天室</title>
  4. <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
  5. <script src="../jquery.min.js"></script>
  6. <script>
  7. $(function(){
  8.     $("#post").click(function(){
  9.         
  10.     var content=$("#content").val();
  11.     if(!$.trim(content)){
  12.        alert('请填写内容');
  13.        return false;
  14.     }
  15.     $("#content").val("");
  16.     $.post("ajax.php", {content:content});});
  17. })
  18.     
  19.     function getData(msg){
  20.         if(msg == undefined)
  21.         {
  22.             msg = '';    
  23.         }
  24.         $.post("get.php",{"msg":msg},function(data){
  25.             //var myjson = eval("("+data+")");
  26.             if(data){
  27.                 var chatcontent = '';
  28.                 var obj = eval('('+data+')');
  29.                 $.each(obj,function(key,val){
  30.                     chatcontent += "<div class='username'>"+val['username']+" 说:</div>";
  31.                     chatcontent += "<div class='content'>"+val['content']+"</div>";
  32.                 })
  33.                 $("#chatshow").html(chatcontent);
  34.             }
  35.             
  36.             getData();    
  37.         })    
  38.     }
  39.     
  40.     // function getUser(msg){
  41.     //     if(msg == undefined){
  42.     //         msg = '';    
  43.     //     }
  44.     //     $.post("getuser.php",{"msg":msg},function(data){
  45.     //         //var myjson = eval("("+data+")");
  46.     //         if(data){
  47.     //             var chatcontent = '';
  48.     //             var obj = eval('('+data+')');
  49.     //             $.each(obj,function(key,val){
  50.     //                 chatcontent += "<div class='username'>"+val['username']+" 说:</div>";
  51.     //                 chatcontent += "<div class='content'>"+val['content']+"</div>";
  52.     //             })
  53.     //             $("#chatshow").html(chatcontent);
  54.     //         }
  55.     //         getData();    
  56.     //     })    
  57.     // }
  58.     
  59.     getData("one");
  60.     
  61.     
  62.     // $(function(){
  63.     //     $("#userlist p").click(function(){
  64.     //         $("#content").val("@"+$(this).text()+" ");    
  65.     //     })    
  66.     // })
  67.     
  68.     // $(function(){
  69.     //     $(document).keypress(function(e){
  70.     //         if(e.ctrlKey && e.which == 13 || e.which == 10) { 
  71.                    
  72.     //             var content=$("#content").val();
  73.     //             if(!$.trim(content)){
  74.     //                alert('请填写内容');
  75.     //                return false;
  76.     //             }
  77.     //             $("#content").val("");    
  78.     //             $.post("ajax.php", {content:content});
  79.     //         }      
  80.     //     })
  81.     //     //alert(event.clientX+document.body.clientWidth);
  82.     // })
  83.     
  84.     /*window.onbeforeunload=function (){ 
  85.         //return("===onbeforeunload==="); 
  86.         if(event.clientX>document.body.clientWidth && event.clientY < 0 || event.altKey){ 
  87.             return("你关闭了浏览器"); 
  88.         }else{ 
  89.             return(document.body.clientWidth); 
  90.         } 
  91.     } */
  92.     
  93. </script>
  94. <style>
  95. #chat{margin:0 auto;}
  96. #chatshow{width:500px;height:400px;overflow:auto;border:1px solid #ccc;float:left;}
  97. #userlist{width:100px;height:400px;overflow:auto;border:1px solid #ccc;float:left;margin-right:2px;}
  98. #userlist p{color:#0F0; cursor:pointer;}
  99. .clearboth{clear:both;}
  100. .username{font-weight:bold;color:#00F;font-size:12px;margin-bottom:3px;margin-top:8px;}
  101. </style>
  102. </head>
  103. <body>
  104. <div id="chat">
  105. <div id="userlist">
  106. <div style="font-size:12px;font-weight:bold;">在线用户列表</div>
  107. <div class="userlist">
  108. <?php 
  109.     // $dsn = "mysql:host=localhost;dbname=test;charset=utf8'";
  110.  //    $db = new PDO($dsn, 'root', 'root');
  111.     $db = new PDO('mysql:dbname=test;host=127.0.0.1;charset=utf8', 'root', 'adminroot');
  112.     $rs = $db->prepare("select * from chat where is_login = '1'");
  113.     $rs->execute();
  114.     while($row = $rs->fetch()){
  115.         echo '<p>'.$row['username'].'</p>';    
  116.     }
  117. ?>
  118. </div>
  119. </div>
  120. <div id="chatshow"></div>
  121. </div>
  122. <div class="clearboth"></div>
  123. <div>
  124. <textarea name="content" id="content" style="width:600px;height:100px"></textarea>
  125. <input type='button' name='tj' id="post" value='发布' >
  126. </div>
  127. </body>
  128. </html>
  1. <?php
  2. /*session_start();
  3. $mem = new Memcache;
  4. $mem->connect("localhost",11211);
  5. if(isset($_POST['content'])){
  6.     $con['username'] = $_SESSION["username"];
  7.     $con['content'] = $_POST["content"];
  8.     
  9.     $data = $mem->get('chat');
  10.     $data[] = $con;
  11.     $mem->set("chat",$data,0,0);    
  12. }
  13. $mem->close();
  14. */
  15.     if(isset($_POST['content'])){
  16.         session_start();
  17.         $filename = date("Ymd",time()).".txt";
  18.         if(file_exists($filename)){
  19.             $content = file_get_contents($filename);
  20.             $data = json_decode($content,true);        
  21.             $con['username'] = $_SESSION["username"];
  22.             $con['content'] = $_POST["content"];
  23.             $data[] = $con;
  24.             $file = fopen($filename,"w");
  25.             fwrite($file,json_encode($data));
  26.             fclose($file);    
  27.         }else{
  28.             $file = fopen($filename,"w");
  29.             $con['username'] = $_SESSION["username"];
  30.             $con['content'] = $_POST["content"];
  31.             $data[] = $con;
  32.             fwrite($file,json_encode($data));
  33.             fclose($file);    
  34.         }
  35.             
  36.     }
  37. ?>
  1. <?php 
  2. /*require 'conn.inc';
  3. function getData(){
  4.     $sql="SELECT count(*) FROM  `talkroom`";
  5.     $res=mysql_query($sql);
  6.     $count = mysql_fetch_row($res);
  7.     
  8.     return $count;    
  9. }
  10. $old = getData();
  11. while(true){
  12.     $new = getData();
  13.     if($new[0]>$old[0]){
  14.         //echo json_encode($new['data']);
  15.         //print_r($new);
  16.         echo '2222222222'.'<br/>';
  17.     }
  18.     //echo '<br />11111111111111111111111111111111111111111111111111111111111111111111';
  19.     usleep(1000);
  20. }
  21. */
  22. /*set_time_limit(0);
  23. $mem = new Memcache;
  24. $mem->connect("localhost",11211);
  25. $count = count($mem->get("chat"));
  26. $com = true;
  27. //$mem->delete('chat');
  28. if($_POST['msg'] == "one"){
  29.     exit(json_encode($mem->get("chat")));    
  30. }
  31. if($_POST['msg'] == "break"){
  32.     $com = false;    
  33. }
  34. $time1 = time();
  35. while(true){
  36.     if($com){
  37.         $data = $mem->get("chat");
  38.         if(count($data)>$count){
  39.             echo json_encode($data);
  40.             break;
  41.         }
  42.         usleep(300);
  43.     }else{
  44.         break;    
  45.     }
  46. }
  47. $mem->close();*/
  48. set_time_limit(0);
  49. $filename = date("Ymd",time()).".txt";
  50. if(file_exists($filename)){
  51.     $content = file_get_contents($filename);
  52.     $data = json_decode($content,true);        
  53.     $count = count($data);
  54.     // echo $count;die;
  55.     if($_POST['msg'] == "one"){
  56.         exit(json_encode($data));    
  57.     }
  58.     
  59.     while(true){
  60.         
  61.         $contents = file_get_contents($filename);
  62.         $datas = json_decode($contents,true);
  63.         $counts = count($datas);    
  64.         if($counts>$count){
  65.             echo json_encode($datas);
  66.             break;
  67.         }
  68.         usleep(300);
  69.     }
  70. }else{
  71.     $file = fopen($filename,"w");
  72.     $con['username'] = "系统消息";
  73.     $con['content'] = "欢迎来到EPGO聊天室";
  74.     $data[] = $con;
  75.     fwrite($file,json_encode($data));
  76.     fclose($file);
  77.     
  78.     exit(json_encode($data));    
  79.     
  80. }
  81. ?>

2、使用WebSocket和服务器进行长连接，来实现聊天功能。

客户端代码：

  1. <!DOCTYPE html>
  2. <html>
  3. <head>
  4.     <meta charset="UTF-8">
  5.     <meta name="viewport" content="width=device-width, initial-scale=1">
  6.     <title>websocket聊天室</title>
  7.     <link href="https://fonts.googleapis.com/css?family=Source+Sans+Pro:400,600" rel="stylesheet">
  8.     <link rel="stylesheet" href="css/reset.min.css">
  9.     <link rel="stylesheet" href="css/style.css">
  10.     <style>
  11.         .message img {
  12.             float: left;
  13.             width: 40px;
  14.             height: 40px;
  15.             margin-right: 12px;
  16.             border-radius: 50%;
  17.         }
  18.         .you {
  19.             margin-left: 60px;
  20.             margin-top: -39px;
  21.         }
  22.         .me-header {
  23.             float: right !important;
  24.             margin-right: 0 !important;
  25.         }
  26.         .me {
  27.             margin-right: 60px;
  28.             margin-top: -39px;
  29.         }
  30.         .active-chat::-webkit-scrollbar, .left::-webkit-scrollbar {
  31.             width: 2px;
  32.         }
  33.     </style>
  34. </head>
  35. <body>
  36. <div>
  37.     <div>
  38.         <div>
  39.             <div style="padding: 20px 29px;height: auto;">
  40.                 <div class="" style="font: 400 13.3333px Arial;font-weight: 400;">在线人数：<span id="numbers">0</span> 人
  41.                 </div>
  42.             </div>
  43.             <ul>
  44.             </ul>
  45.         </div>
  46.         <div>
  47.             <div><span>Tips: <span>PHP之websocket聊天室</span></span></div>
  48.             <div class="chat active-chat" data-chat="person1"
  49.                  style="height: auto;border-width: 0px;padding: 10px;height: 483px; padding: 10px;overflow-y: auto;scrollTop: 100px">
  50.             </div>
  51.             <div>
  52.                 <a href="javascript:;" class="write-link attach"></a>
  53.                 <input type="text" id="input-value" onkeydown="confirm(event)"/>
  54.                 <a href="javascript:;" class="write-link smiley"></a>
  55.                 <a href="javascript:;" class="write-link send" onclick="send()"></a>
  56.             </div>
  57.         </div>
  58.     </div>
  59. </div>
  60. <script src="js/index.js"></script>
  61. <script>
  62.     var uname = prompt('请输入用户名', 'user' + uuid(8, 16));
  63.     var avatar = ['bo-jackson.jpg', 'dog.png', 'drake.jpg', 'louis-ck.jpeg', 'michael-jordan.jpg', 'thomas.jpg'];
  64.     if (avatar[Math.round(Math.random() * 10)]) {
  65.         var headerimg = "img/" + avatar[Math.round(Math.random() * 10)];
  66.     } else {
  67.         var headerimg = "img/" + avatar[0];
  68.     }
  69.     // 创建一个 websocket 连接
  70.     var ws = new WebSocket("ws://127.0.0.1:1238");
  71.     // websocket 创建成功事件
  72.     ws.onopen = function () {
  73.         var data = "系统消息：建立连接成功";
  74.         console.log(data);
  75.     };
  76.     // websocket 接收到消息事件
  77.     ws.onmessage = function (e) {
  78.         var data = JSON.parse(e.data);
  79.         switch (data.type) {
  80.             case 'handShake':
  81.                 console.log(data.msg);
  82.                 //发送用户登录
  83.                 var user_info = {'type': 'login', 'msg': uname, 'headerimg': headerimg};
  84.                 sendMsg(user_info);
  85.                 break;
  86.             case 'login':
  87.                 userList(data.user_list);
  88.                 systemMessage('系统消息: ' + data.msg + ' 已上线');
  89.                 break;
  90.             case 'logout':
  91.                 userList(data.user_list);
  92.                 if (data.msg.length > 0) {
  93.                     systemMessage('系统消息: ' + data.msg + ' 已下线');
  94.                 }
  95.                 break;
  96.             case 'user':
  97.                 messageList(data);
  98.                 break;
  99.             case 'system':
  100.                 systemMessage();
  101.                 break;
  102.         }
  103.     }
  104.     // websocket 错误事件
  105.     ws.onerror = function () {
  106.         var data = "系统消息 : 出错了,请退出重试.";
  107.         alert(data);
  108.     };
  109.     function confirm(event) {
  110.         var key_num = event.keyCode;
  111.         if (13 == key_num) {
  112.             send();
  113.         } else {
  114.             return false;
  115.         }
  116.     }
  117.     function systemMessage(msg) {
  118.         var html = `<div>
  119.             <span>` + msg + `</span>
  120.         </div>`;
  121.         var active_chat = document.querySelector('div.active-chat');
  122.         var oldHtml = active_chat.innerHTML;
  123.         active_chat.innerHTML = oldHtml + html;
  124.         active_chat.scrollTop = active_chat.scrollHeight;
  125.     }
  126.     function send() {
  127.         var msg = document.querySelector("input#input-value").value;
  128.         var reg = new RegExp("\r\n", "g");
  129.         msg = msg.replace(reg, "");
  130.         sendMsg({type: "user", msg: msg});
  131.         document.querySelector("input#input-value").value = "";
  132.     }
  133.     function sendMsg(msg) {
  134.         var data = JSON.stringify(msg);
  135.         ws.send(data);
  136.     }
  137.     function userList(user) {
  138.         var html = '';
  139.         for (var i = 0; i < user.length; i++) {
  140.             html += `<li data-chat="person1">
  141.                     <img src="` + user[i].headerimg + `" alt=""/>
  142.                     <span>` + user[i].username + `</span>
  143.                     <span>` + user[i].login_time + `</span>
  144.                     <span style="color: green;font-size: 7px;">在线</span>
  145.                 </li>`;
  146.         }
  147.         document.querySelector('ul.people').innerHTML = html;
  148.         document.querySelector('span#numbers').innerHTML = user.length;
  149.     }
  150.     function messageList(data) {
  151.         if (data.from == uname) {
  152.             var html = `<div>
  153.                     <img src="` + data.headerimg + `" alt=""/>
  154.                     <div class="bubble me">` + data.msg + `</div>
  155.                 </div>`;
  156.         } else {
  157.             var html = `<div>
  158.                     <img src="` + data.headerimg + `" alt=""/>
  159.                     <div class="bubble you">` + data.msg + `</div>
  160.                 </div>`;
  161.         }
  162.         var active_chat = document.querySelector('div.active-chat');
  163.         var oldHtml = active_chat.innerHTML;
  164.         active_chat.innerHTML = oldHtml + html;
  165.         active_chat.scrollTop = active_chat.scrollHeight;
  166.     }
  167.     /**
  168.      * 生产一个全局唯一ID作为用户名的默认值;
  169.      *
  170.      * @param len
  171.      * @param radix
  172.      * @returns {string}
  173.      */
  174.     function uuid(len, radix) {
  175.         var chars = '0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz'.split('');
  176.         var uuid = [], i;
  177.         radix = radix || chars.length;
  178.         if (len) {
  179.             for (i = 0; i < len; i++) uuid[i] = chars[0 | Math.random() * radix];
  180.         } else {
  181.             var r;
  182.             uuid[8] = uuid[13] = uuid[18] = uuid[23] = '-';
  183.             uuid[14] = '4';
  184.             for (i = 0; i < 36; i++) {
  185.                 if (!uuid[i]) {
  186.                     r = 0 | Math.random() * 16;
  187.                     uuid[i] = chars[(i == 19) ? (r & 0x3) | 0x8 : r];
  188.                 }
  189.             }
  190.         }
  191.         return uuid.join('');
  192.     }
  193. </script>
  194. </body>
  195. </html>

服务端代码：

  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: 25754
  5.  * Date: 2019/4/23
  6.  * Time: 14:13
  7.  */
  8. class socketServer
  9. {
  10.     const LISTEN_SOCKET_NUM = 9;
  11.     const LOG_PATH = "./log/";
  12.     private $_ip = "127.0.0.1";
  13.     private $_port = 1238;
  14.     private $_socketPool = array();
  15.     private $_master = null;
  16.     public function __construct()
  17.     {
  18.         $this->initSocket();
  19.     }
  20.     private function initSocket()
  21.     {
  22.         try {
  23.             //创建socket套接字
  24.             $this->_master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
  25.             // 设置IP和端口重用,在重启服务器后能重新使用此端口;
  26.             socket_set_option($this->_master, SOL_SOCKET, SO_REUSEADDR, 1);
  27.             //绑定地址与端口
  28.             socket_bind($this->_master, $this->_ip, $this->_port);
  29.             //listen函数使用主动连接套接口变为被连接套接口，使得一个进程可以接受其它进程的请求，从而成为一个服务器进程。在TCP服务器编程中listen函数把进程变为一个服务器，并指定相应的套接字变为被动连接,其中的能存储的请求不明的socket数目。
  30.             socket_listen($this->_master, self::LISTEN_SOCKET_NUM);
  31.         } catch (Exception $e) {
  32.             $this->debug(array("code: " . $e->getCode() . ", message: " . $e->getMessage()));
  33.         }
  34.         //将socket保存到socket池中
  35.         $this->_socketPool[0] = array('resource' => $this->_master);
  36.         $pid = getmypid();
  37.         $this->debug(array("server: {$this->_master} started,pid: {$pid}"));
  38.         while (true) {
  39.             try {
  40.                 $this->run();
  41.             } catch (Exception $e) {
  42.                 $this->debug(array("code: " . $e->getCode() . ", message: " . $e->getMessage()));
  43.             }
  44.         }
  45.     }
  46.     private function run()
  47.     {
  48.         $write = $except = NULL;
  49.         $sockets = array_column($this->_socketPool, 'resource');
  50.         $read_num = socket_select($sockets, $write, $except, NULL);
  51.         if (false === $read_num) {
  52.             $this->debug(array('socket_select_error', $err_code = socket_last_error(), socket_strerror($err_code)));
  53.             return;
  54.         }
  55.         foreach ($sockets as $socket) {
  56.             if ($socket == $this->_master) {
  57.                 $client = socket_accept($this->_master);
  58.                 if ($client === false) {
  59.                     $this->debug(['socket_accept_error', $err_code = socket_last_error(), socket_strerror($err_code)]);
  60.                     continue;
  61.                 }
  62.                 //连接
  63.                 $this->connection($client);
  64.             } else {
  65.                 //接受数据
  66.                 $bytes = @socket_recv($socket, $buffer, 2048, 0);
  67.                 if ($bytes == 0) {
  68.                     $recv_msg = $this->disconnection($socket);
  69.                 } else {
  70.                     if ($this->_socketPool[(int)$socket]['handShake'] == false) {
  71.                         $this->handShake($socket, $buffer);
  72.                         continue;
  73.                     } else {
  74.                         $recv_msg = $this->parse($buffer);
  75.                     }
  76.                 }
  77.                 $msg = $this->doEvents($socket, $recv_msg);
  78.                 echo($msg);
  79.                 socket_getpeername ( $socket  , $address ,$port );
  80.                 $this->debug(array(
  81.                     'send_success',
  82.                     json_encode($recv_msg),
  83.                     $address,
  84.                     $port
  85.                 ));
  86.                 $this->broadcast($msg);
  87.             }
  88.         }
  89.     }
  90.     /**
  91.      * 数据广播
  92.      * @param $data
  93.      */
  94.     private function broadcast($data)
  95.     {
  96.         foreach ($this->_socketPool as $socket) {
  97.             if ($socket['resource'] == $this->_master) {
  98.                 continue;
  99.             }
  100.             socket_write($socket['resource'], $data, strlen($data));
  101.         }
  102.     }
  103.     /**
  104.      * 业务处理
  105.      * @param $socket
  106.      * @param $recv_msg
  107.      * @return string
  108.      */
  109.     private function doEvents($socket, $recv_msg)
  110.     {
  111.         //联系我
  112.     }
  113.     /**
  114.      * socket握手
  115.      * @param $socket
  116.      * @param $buffer
  117.      * @return bool
  118.      */
  119.     public function handShake($socket, $buffer)
  120.     {
  121.         $acceptKey = $this->encry($buffer);
  122.         $upgrade = "HTTP/1.1 101 Switching Protocols\r\n" .
  123.             "Upgrade: websocket\r\n" .
  124.             "Connection: Upgrade\r\n" .
  125.             "Sec-WebSocket-Accept: " . $acceptKey . "\r\n\r\n";
  126.         // 写入socket
  127.         socket_write($socket, $upgrade, strlen($upgrade));
  128.         // 标记握手已经成功，下次接受数据采用数据帧格式
  129.         $this->_socketPool[(int)$socket]['handShake'] = true;
  130.         socket_getpeername ( $socket  , $address ,$port );
  131.         $this->debug(array(
  132.             'hand_shake_success',
  133.             $socket,
  134.             $address,
  135.             $port
  136.         ));
  137.         //发送消息通知客户端握手成功
  138.         $msg = array('type' => 'handShake', 'msg' => '握手成功');
  139.         $msg = $this->frame(json_encode($msg));
  140.         socket_write($socket, $msg, strlen($msg));
  141.         return true;
  142.     }
  143.     /**
  144.      * 帧数据封装
  145.      * @param $msg
  146.      * @return string
  147.      */
  148.     private function frame($msg)
  149.     {
  150.         $frame = [];
  151.         $frame[0] = '81';
  152.         $len = strlen($msg);
  153.         if ($len < 126) {
  154.             $frame[1] = $len < 16 ? '0' . dechex($len) : dechex($len);
  155.         } else if ($len < 65025) {
  156.             $s = dechex($len);
  157.             $frame[1] = '7e' . str_repeat('0', 4 - strlen($s)) . $s;
  158.         } else {
  159.             $s = dechex($len);
  160.             $frame[1] = '7f' . str_repeat('0', 16 - strlen($s)) . $s;
  161.         }
  162.         $data = '';
  163.         $l = strlen($msg);
  164.         for ($i = 0; $i < $l; $i++) {
  165.             $data .= dechex(ord($msg{$i}));
  166.         }
  167.         $frame[2] = $data;
  168.         $data = implode('', $frame);
  169.         return pack("H*", $data);
  170.     }
  171.     /**
  172.      * 接受数据解析
  173.      * @param $buffer
  174.      * @return mixed
  175.      */
  176.     private function parse($buffer)
  177.     {
  178.         $decoded = '';
  179.         $len = ord($buffer[1]) & 127;
  180.         if ($len === 126) {
  181.             $masks = substr($buffer, 4, 4);
  182.             $data = substr($buffer, 8);
  183.         } else if ($len === 127) {
  184.             $masks = substr($buffer, 10, 4);
  185.             $data = substr($buffer, 14);
  186.         } else {
  187.             $masks = substr($buffer, 2, 4);
  188.             $data = substr($buffer, 6);
  189.         }
  190.         for ($index = 0; $index < strlen($data); $index++) {
  191.             $decoded .= $data[$index] ^ $masks[$index % 4];
  192.         }
  193.         return json_decode($decoded, true);
  194.     }
  195.     // 提取 Sec-WebSocket-Key 信息
  196.     private function getKey($req)
  197.     {
  198.         $key = null;
  199.         if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $req, $match)) {
  200.             $key = $match[1];
  201.         }
  202.         return $key;
  203.     }
  204.     //加密 Sec-WebSocket-Key
  205.     private function encry($req)
  206.     {
  207.         $key = $this->getKey($req);
  208.         return base64_encode(sha1($key . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
  209.     }
  210.     /**
  211.      * 连接socket
  212.      * @param $client
  213.      */
  214.     public function connection($client)
  215.     {
  216.         socket_getpeername ( $client  , $address ,$port );
  217.         $info = array(
  218.             'resource' => $client,
  219.             'userInfo' => '',
  220.             'handShake' => false,
  221.             'ip' => $address,
  222.             'port' => $port,
  223.         );
  224.         $this->_socketPool[(int)$client] = $info;
  225.         $this->debug(array_merge(['socket_connect'], $info));
  226.     }
  227.     /**
  228.      * 断开连接
  229.      * @param $socket
  230.      * @return array
  231.      */
  232.     public function disconnection($socket)
  233.     {
  234.         $recv_msg = array(
  235.             'type' => 'logout',
  236.             'msg' => @$this->_socketPool[(int)$socket]['username'],
  237.         );
  238.         unset($this->_socketPool[(int)$socket]);
  239.         return $recv_msg;
  240.     }
  241.     /**
  242.      * 日志
  243.      * @param array $info
  244.      */
  245.     private function debug(array $info)
  246.     {
  247.         $time = date('Y-m-d H:i:s');
  248.         array_unshift($info, $time);
  249.         $info = array_map('json_encode', $info);
  250.         file_put_contents(self::LOG_PATH . 'websocket_debug.log', implode(' | ', $info) . "\r\n", FILE_APPEND);
  251.     }
  252. }
  253. new socketServer();

推荐教程：《PHP教程》

以上就是php怎么实现聊天功能的详细内容，更多请关注Gxlcms其它相关文章！

人气教程排行

本站所有资源全部来源于网络，若本站发布的内容侵害到您的隐私或者利益，请联系我们删除！