php+websocket 实现的聊天室功能详解_php技巧_

 if(extension_loaded('sockets')){ echo "1"; }else{ echo "0"; }

在线人数：0 人 
Tips: PHP之websocket聊天室

initSocket(); } // 创建WebSocket连接 private function initSocket() { try { //创建socket套接字 $this->_master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); // 设置IP和端口重用,在重启服务器后能重新使用此端口; socket_set_option($this->_master, SOL_SOCKET, SO_REUSEADDR, 1); //绑定地址与端口 socket_bind($this->_master, $this->_ip, $this->_port); //listen函数使用主动连接套接口变为被连接套接口，使得一个进程可以接受其它进程的请求，从而成为一个服务器进程。在TCP服务器编程中listen函数把进程变为一个服务器，并指定相应的套接字变为被动连接,其中的能存储的请求不明的socket数目。 socket_listen($this->_master, self::LISTEN_SOCKET_NUM); } catch (Exception $e) { $this->debug(array("code: " . $e->getCode() . ", message: " . $e->getMessage())); } //将socket保存到socket池中 （将套接字放入数组）默认把当前用户放在第一个 $this->_socketPool[0] = array('resource' => $this->_master); $pid = getmypid(); $this->debug(array("server: {$this->_master} started,pid: {$pid}")); } // 挂起进程遍历套接字数组，对数据进行接收、处理、发送 public function run() { // 死循环 直到socket断开 while (true) { try { $write = $except = NULL; // 从数组中取出resource列 $sockets = array_column($this->_socketPool, 'resource'); /* $sockets 是一个存放文件描述符的数组。 $write 是监听是否客户端写数据，传入NULL是不关心是否有写变化 $except 是$sockets里面要派粗话的元素，传入null是监听全部 最后一个参数是超时时间，0立即结束 n>1则最多n秒后结束，如遇某一个连接有新动态，则提前返回 null如遇某一个连接有新动态，则返回 */ // 接收套接字数字，监听他们的状态就是有新消息到或有客户端连接/断开时，socket_select函数才会返回，继续往下执行 $read_num = socket_select($sockets, $write, $except, NULL); if (false === $read_num) { $this->debug(array('socket_select_error', $err_code = socket_last_error(), socket_strerror($err_code))); return; } // 遍历套接字数组 foreach ($sockets as $socket) { // 如果有新的连接进来 if ($socket == $this->_master) { // 接收一个socket连接 $client = socket_accept($this->_master); if ($client === false) { $this->debug(['socket_accept_error', $err_code = socket_last_error(), socket_strerror($err_code)]); continue; } //连接 并放到socket池中 $this->connection($client); } else { //接收已连接的socket数据，返回的是从socket中接收的字节数。 // 第一个参数：socket资源，第二个参数：存储接收的数据的变量，第三个参数：接收数据的长度 $bytes = @socket_recv($socket, $buffer, 2048, 0); // 如果接收的字节数为0 if ($bytes == 0) { // 断开连接 $recv_msg = $this->disconnection($socket); } else { // 判断有没有握手，没有握手进行握手，已经握手则进行处理 if ($this->_socketPool[(int)$socket]['handShake']
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：php+js实现的拖动滑块验证码验证表单操作示例【附源码下载】_php技巧_
                                                                
下一篇：PHP开发API接口签名生成及验证操作示例_php技巧_