首頁 後端開發 php教程 php中如何使用websocket(聊天室實例詳解)

php中如何使用websocket(聊天室實例詳解)

Nov 23, 2019 pm 04:38 PM
php websocket

php中如何使用websocket(聊天室實例詳解)

在PHP中,开发者需要考虑的东西比较多,从socket的连接、建立、绑定、监听等都需要开发者自己去操作完成,对于初学者来说,难度方面也挺大的,所以本文的思路如下:

1、socket协议的简介

2、介绍client与server之间的连接原理

3、PHP中建立socket的过程讲解

4、用一个聊天室作为实例详细讲解在PHP中如何使用socket

一、socket协议的简介

WebSocket是一个持久化的协议,这是相对于http非持久化来说的。

举个简单的例子,http1.0的生命周期是以request作为界定的,也就是一个request,一个response,对于http来说,本次client与server的会话到此结束;而在http1.1中,稍微有所改进,即添加了keep-alive,也就是在一个http连接中可以进行多个request请求和多个response接受操作。然而在实时通信中,并没有多大的作用,http只能由client发起请求,server才能返回信息,即server不能主动向client推送信息,无法满足实时通信的要求。而WebSocket可以进行持久化连接,即client只需进行一次握手,成功后即可持续进行数据通信,值得关注的是WebSocket实现client与server之间全双工通信,即server端有数据更新时可以主动推送给client端。

二、介绍client与server之间的socket连接原理

1、下面是一个演示client和server之间建立WebSocket连接时握手部分

  

2、client与server建立socket时握手的会话内容,即request与response

a、client建立WebSocket时向服务器端请求的信息

  GET /chat HTTP/1.1 
      Host: server.example.com 
      Upgrade: websocket            //告诉服务器现在发送的是WebSocket协议
      Connection: Upgrade 
      Sec-WebSocket-Key: x3JJHMbDL1EzLkh9GBhXDw==   //是一个Base64 encode的值,这个是浏览器随机生成的,用于验证服务器端返回数据是否是WebSocket助理
      Sec-WebSocket-Protocol: chat, superchat 
      Sec-WebSocket-Version: 13 
      Origin: http://example.com
登入後複製

b、服务器获取到client请求的信息后,根据WebSocket协议对数据进行处理并返回,其中要对Sec-WebSocket-Key进行加密等操作

 HTTP/1.1 101 Switching Protocols 
  Upgrade: websocket //依然是固定的,告诉客户端即将升级的是Websocket协议,而不是mozillasocket,lurnarsocket或者shitsocket
  Connection: Upgrade 
  Sec-WebSocket-Accept: HSmrc0sMlYUkAGmm5OPpG2HaGWk= //这个则是经过服务器确认,并且加密过后的 Sec-WebSocket-Key,也就是client要求建立WebSocket验证的凭证
  Sec-WebSocket-Protocol: chat
登入後複製

3、socket建立连接原理图:(推荐学习:PHP视频教程

  

三、PHP中建立socket的过程讲解

1、在PHP中,client与server之间建立socket通信,首先在PHP中创建socket并监听端口信息,代码如下:

    //传相应的IP与端口进行创建socket操作
	function WebSocket($address,$port){
		$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
		socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);//1表示接受所有的数据包
		socket_bind($server, $address, $port);
		socket_listen($server);
		return $server;
	}
登入後複製

2、设计一个循环挂起WebSocket通道,进行数据的接收、处理和发送

    //对创建的socket循环进行监听,处理数据	
	function run(){
        //死循环,直到socket断开
		while(true){
			$changes=$this->sockets;
			$write=NULL;
			$except=NULL;
            
            /*
            //这个函数是同时接受多个连接的关键,我的理解它是为了阻塞程序继续往下执行。
            socket_select ($sockets, $write = NULL, $except = NULL, NULL);

            $sockets可以理解为一个数组,这个数组中存放的是文件描述符。当它有变化(就是有新消息到或者有客户端连接/断开)时,socket_select函数才会返回,继续往下执行。 
            $write是监听是否有客户端写数据,传入NULL是不关心是否有写变化。 
            $except是$sockets里面要被排除的元素,传入NULL是”监听”全部。 
            最后一个参数是超时时间 
            如果为0:则立即结束 
            如果为n>1: 则最多在n秒后结束,如遇某一个连接有新动态,则提前返回 
            如果为null:如遇某一个连接有新动态,则返回
            */
			socket_select($changes,$write,$except,NULL);
			foreach($changes as $sock){
                
                //如果有新的client连接进来,则
				if($sock==$this->master){

                    //接受一个socket连接
					$client=socket_accept($this->master);

                    //给新连接进来的socket一个唯一的ID
					$key=uniqid();
					$this->sockets[]=$client;  //将新连接进来的socket存进连接池
					$this->users[$key]=array(
						'socket'=>$client,  //记录新连接进来client的socket信息
						'shou'=>false       //标志该socket资源没有完成握手
					);
                //否则1.为client断开socket连接,2.client发送信息
				}else{
					$len=0;
					$buffer='';
                    //读取该socket的信息,注意:第二个参数是引用传参即接收数据,第三个参数是接收数据的长度
					do{
						$l=socket_recv($sock,$buf,1000,0);
						$len+=$l;
						$buffer.=$buf;
					}while($l==1000);

                    //根据socket在user池里面查找相应的$k,即健ID
					$k=$this->search($sock);

                    //如果接收的信息长度小于7,则该client的socket为断开连接
					if($len<7){
                        //给该client的socket进行断开操作,并在$this->sockets和$this->users里面进行删除
						$this->send2($k);
						continue;
					}
                    //判断该socket是否已经握手
					if(!$this->users[$k][&#39;shou&#39;]){
                        //如果没有握手,则进行握手处理
						$this->woshou($k,$buffer);
					}else{
                        //走到这里就是该client发送信息了,对接受到的信息进行uncode处理
						$buffer = $this->uncode($buffer,$k);
						if($buffer==false){
							continue;
						}
                        //如果不为空,则进行消息推送操作
						$this->send($k,$buffer);
					}
				}
			}
			
		}
		
	}
登入後複製

3、以上服务器端完成的WebSocket的前期工作后,就等着client连接进行,client创建WebSocket很简单,代码如下:

var ws = new WebSocket("ws://IP:端口");
//握手监听函数
ws.onopen=function(){
     //状态为1证明握手成功,然后把client自定义的名字发送过去
    if(so.readyState==1){
         //握手成功后对服务器发送信息
	 so.send(&#39;type=add&ming=&#39;+n);
    }
}
//错误返回信息函数
ws.onerror = function(){
    console.log("error");
};
//监听服务器端推送的消息
ws.onmessage = function (msg){
    console.log(msg);
}

//断开WebSocket连接
ws.onclose = function(){
    ws = false;
}
登入後複製

四、聊天室实例代码

1、PHP部分

run();

//下面是sock类
class Sock{
	public $sockets; //socket的连接池,即client连接进来的socket标志
	public $users;   //所有client连接进来的信息,包括socket、client名字等
	public $master;  //socket的resource,即前期初始化socket时返回的socket资源
	
	private $sda=array();   //已接收的数据
	private $slen=array();  //数据总长度
	private $sjen=array();  //接收数据的长度
	private $ar=array();    //加密key
	private $n=array();
	
	public function __construct($address, $port){

        //创建socket并把保存socket资源在$this->master
		$this->master=$this->WebSocket($address, $port);

        //创建socket连接池
		$this->sockets=array($this->master);
	}
	
    //对创建的socket循环进行监听,处理数据	
	function run(){
        //死循环,直到socket断开
		while(true){
			$changes=$this->sockets;
			$write=NULL;
			$except=NULL;
            
            /*
            //这个函数是同时接受多个连接的关键,我的理解它是为了阻塞程序继续往下执行。
            socket_select ($sockets, $write = NULL, $except = NULL, NULL);

            $sockets可以理解为一个数组,这个数组中存放的是文件描述符。当它有变化(就是有新消息到或者有客户端连接/断开)时,socket_select函数才会返回,继续往下执行。 
            $write是监听是否有客户端写数据,传入NULL是不关心是否有写变化。 
            $except是$sockets里面要被排除的元素,传入NULL是”监听”全部。 
            最后一个参数是超时时间 
            如果为0:则立即结束 
            如果为n>1: 则最多在n秒后结束,如遇某一个连接有新动态,则提前返回 
            如果为null:如遇某一个连接有新动态,则返回
            */
			socket_select($changes,$write,$except,NULL);
			foreach($changes as $sock){
                
                //如果有新的client连接进来,则
				if($sock==$this->master){

                    //接受一个socket连接
					$client=socket_accept($this->master);

                    //给新连接进来的socket一个唯一的ID
					$key=uniqid();
					$this->sockets[]=$client;  //将新连接进来的socket存进连接池
					$this->users[$key]=array(
						&#39;socket&#39;=>$client,  //记录新连接进来client的socket信息
						&#39;shou&#39;=>false       //标志该socket资源没有完成握手
					);
                //否则1.为client断开socket连接,2.client发送信息
				}else{
					$len=0;
					$buffer=&#39;&#39;;
                    //读取该socket的信息,注意:第二个参数是引用传参即接收数据,第三个参数是接收数据的长度
					do{
						$l=socket_recv($sock,$buf,1000,0);
						$len+=$l;
						$buffer.=$buf;
					}while($l==1000);

                    //根据socket在user池里面查找相应的$k,即健ID
					$k=$this->search($sock);

                    //如果接收的信息长度小于7,则该client的socket为断开连接
					if($len<7){
                        //给该client的socket进行断开操作,并在$this->sockets和$this->users里面进行删除
						$this->send2($k);
						continue;
					}
                    //判断该socket是否已经握手
					if(!$this->users[$k][&#39;shou&#39;]){
                        //如果没有握手,则进行握手处理
						$this->woshou($k,$buffer);
					}else{
                        //走到这里就是该client发送信息了,对接受到的信息进行uncode处理
						$buffer = $this->uncode($buffer,$k);
						if($buffer==false){
							continue;
						}
                        //如果不为空,则进行消息推送操作
						$this->send($k,$buffer);
					}
				}
			}
			
		}
		
	}
    
    //指定关闭$k对应的socket
	function close($k){
        //断开相应socket
		socket_close($this->users[$k]['socket']);
        //删除相应的user信息
		unset($this->users[$k]);
        //重新定义sockets连接池
		$this->sockets=array($this->master);
		foreach($this->users as $v){
			$this->sockets[]=$v['socket'];
		}
        //输出日志
		$this->e("key:$k close");
	}
    
    //根据sock在users里面查找相应的$k
	function search($sock){
		foreach ($this->users as $k=>$v){
			if($sock==$v['socket'])
			return $k;
		}
		return false;
	}
	
    //传相应的IP与端口进行创建socket操作
	function WebSocket($address,$port){
		$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
		socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);//1表示接受所有的数据包
		socket_bind($server, $address, $port);
		socket_listen($server);
		$this->e('Server Started : '.date('Y-m-d H:i:s'));
		$this->e('Listening on   : '.$address.' port '.$port);
		return $server;
	}
	
	
    /*
    * 函数说明:对client的请求进行回应,即握手操作
    * @$k clien的socket对应的健,即每个用户有唯一$k并对应socket
    * @$buffer 接收client请求的所有信息
    */
	function woshou($k,$buffer){

        //截取Sec-WebSocket-Key的值并加密,其中$key后面的一部分258EAFA5-E914-47DA-95CA-C5AB0DC85B11字符串应该是固定的
		$buf  = substr($buffer,strpos($buffer,'Sec-WebSocket-Key:')+18);
		$key  = trim(substr($buf,0,strpos($buf,"\r\n")));
		$new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
		
        //按照协议组合信息进行返回
		$new_message = "HTTP/1.1 101 Switching Protocols\r\n";
		$new_message .= "Upgrade: websocket\r\n";
		$new_message .= "Sec-WebSocket-Version: 13\r\n";
		$new_message .= "Connection: Upgrade\r\n";
		$new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";
		socket_write($this->users[$k]['socket'],$new_message,strlen($new_message));

        //对已经握手的client做标志
		$this->users[$k]['shou']=true;
		return true;
		
	}
	
    //解码函数
	function uncode($str,$key){
		$mask = array();  
		$data = '';  
		$msg = unpack('H*',$str);
		$head = substr($msg[1],0,2);  
		if ($head == '81' && !isset($this->slen[$key])) {  
			$len=substr($msg[1],2,2);
			$len=hexdec($len);//把十六进制的转换为十进制
			if(substr($msg[1],2,2)=='fe'){
				$len=substr($msg[1],4,4);
				$len=hexdec($len);
				$msg[1]=substr($msg[1],4);
			}else if(substr($msg[1],2,2)=='ff'){
				$len=substr($msg[1],4,16);
				$len=hexdec($len);
				$msg[1]=substr($msg[1],16);
			}
			$mask[] = hexdec(substr($msg[1],4,2));  
			$mask[] = hexdec(substr($msg[1],6,2));  
			$mask[] = hexdec(substr($msg[1],8,2));  
			$mask[] = hexdec(substr($msg[1],10,2));
			$s = 12;
			$n=0;
		}else if($this->slen[$key] > 0){
			$len=$this->slen[$key];
			$mask=$this->ar[$key];
			$n=$this->n[$key];
			$s = 0;
		}
		
		$e = strlen($msg[1])-2;
		for ($i=$s; $i<= $e; $i+= 2) {  
			$data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2)));  
			$n++;  
		}  
		$dlen=strlen($data);
		
		if($len > 255 && $len > $dlen+intval($this->sjen[$key])){
			$this->ar[$key]=$mask;
			$this->slen[$key]=$len;
			$this->sjen[$key]=$dlen+intval($this->sjen[$key]);
			$this->sda[$key]=$this->sda[$key].$data;
			$this->n[$key]=$n;
			return false;
		}else{
			unset($this->ar[$key],$this->slen[$key],$this->sjen[$key],$this->n[$key]);
			$data=$this->sda[$key].$data;
			unset($this->sda[$key]);
			return $data;
		}
		
	}
	
    //与uncode相对
	function code($msg){
		$frame = array();  
		$frame[0] = '81';  
		$len = strlen($msg);
		if($len < 126){
			$frame[1] = $len<16?'0'.dechex($len):dechex($len);
		}else if($len < 65025){
			$s=dechex($len);
			$frame[1]='7e'.str_repeat('0',4-strlen($s)).$s;
		}else{
			$s=dechex($len);
			$frame[1]='7f'.str_repeat('0',16-strlen($s)).$s;
		}
		$frame[2] = $this->ord_hex($msg); 
		$data = implode('',$frame);  
		return pack("H*", $data);  
	}
	
	function ord_hex($data)  {  
		$msg = '';  
		$l = strlen($data);  
		for ($i= 0; $i<$l; $i++) {  
			$msg .= dechex(ord($data{$i}));  
		}  
		return $msg;  
	}
	
	//用户加入或client发送信息
	function send($k,$msg){
        //将查询字符串解析到第二个参数变量中,以数组的形式保存如:parse_str("name=Bill&age=60",$arr)
		parse_str($msg,$g);
		$ar=array();

		if($g['type']=='add'){
            //第一次进入添加聊天名字,把姓名保存在相应的users里面
			$this->users[$k]['name']=$g['ming'];
			$ar['type']='add';
			$ar['name']=$g['ming'];
			$key='all';
		}else{
            //发送信息行为,其中$g['key']表示面对大家还是个人,是前段传过来的信息
			$ar['nrong']=$g['nr'];
			$key=$g['key'];
		}
        //推送信息
		$this->send1($k,$ar,$key);
	}
	
    //对新加入的client推送已经在线的client
	function getusers(){
		$ar=array();
		foreach($this->users as $k=>$v){
			$ar[]=array('code'=>$k,'name'=>$v['name']);
		}
		return $ar;
	}
	
	//$k 发信息人的socketID $key接受人的 socketID ,根据这个socketID可以查找相应的client进行消息推送,即指定client进行发送
	function send1($k,$ar,$key='all'){
		$ar['code1']=$key;
		$ar['code']=$k;
		$ar['time']=date('m-d H:i:s');
        //对发送信息进行编码处理
		$str = $this->code(json_encode($ar));
        //面对大家即所有在线者发送信息
		if($key=='all'){
			$users=$this->users;
            //如果是add表示新加的client
			if($ar['type']=='add'){
				$ar['type']='madd';
				$ar['users']=$this->getusers();        //取出所有在线者,用于显示在在线用户列表中
				$str1 = $this->code(json_encode($ar)); //单独对新client进行编码处理,数据不一样
                //对新client自己单独发送,因为有些数据是不一样的
				socket_write($users[$k]['socket'],$str1,strlen($str1));
                //上面已经对client自己单独发送的,后面就无需再次发送,故unset
				unset($users[$k]);
			}
            //除了新client外,对其他client进行发送信息。数据量大时,就要考虑延时等问题了
			foreach($users as $v){
				socket_write($v['socket'],$str,strlen($str));
			}
		}else{
            //单独对个人发送信息,即双方聊天
			socket_write($this->users[$k]['socket'],$str,strlen($str));
			socket_write($this->users[$key]['socket'],$str,strlen($str));
		}
	}
	
	//用户退出向所用client推送信息
	function send2($k){
		$this->close($k);
		$ar['type']='rmove';
		$ar['nrong']=$k;
		$this->send1(false,$ar,'all');
	}
    
    //记录日志
	function e($str){
		//$path=dirname(__FILE__).'/log.txt';
		$str=$str."\n";
		//error_log($str,3,$path);
        //编码处理
		echo iconv('utf-8','gbk//IGNORE',$str);
	}
}
?>
登入後複製

2、client部分

<!doctype html>
<html>
<head>
<meta charset="utf-8">
<meta name="viewport" content="width=device-width, initial-scale=1, user-scalable=no"/>
<title>HTML5 websocket 网页聊天室 javascript php</title>
<style type="text/css">
body,p{margin:0px; padding:0px; font-size:14px; color:#333; font-family:Arial, Helvetica, sans-serif;}
#ltian,.rin{width:98%; margin:5px auto;}
#ltian{border:1px #ccc solid;overflow-y:auto; overflow-x:hidden; position:relative;}
#ct{margin-right:111px; height:100%;overflow-y:auto;overflow-x: hidden;}
#us{width:110px; overflow-y:auto; overflow-x:hidden; float:right; border-left:1px #ccc solid; height:100%; background-color:#F1F1F1;}
#us p{padding:3px 5px; color:#08C; line-height:20px; height:20px; cursor:pointer; overflow:hidden; white-space:nowrap; text-overflow:ellipsis;}
#us p:hover,#us p:active,#us p.ck{background-color:#069; color:#FFF;}
#us p.my:hover,#us p.my:active,#us p.my{color:#333;background-color:transparent;}
button{float:right; width:80px; height:35px; font-size:18px;}
input{width:100%; height:30px; padding:2px; line-height:20px; outline:none; border:solid 1px #CCC;}
.rin p{margin-right:160px;}
.rin span{float:right; padding:6px 5px 0px 5px; position:relative;}
.rin span img{margin:0px 3px; cursor:pointer;}
.rin span form{position:absolute; width:25px; height:25px; overflow:hidden; opacity:0; top:5px; right:5px;}
.rin span input{width:180px; height:25px; margin-left:-160px; cursor:pointer}

#ct p{padding:5px; line-height:20px;}
#ct a{color:#069; cursor:pointer;}
#ct span{color:#999; margin-right:10px;}
.c2{color:#999;}
.c3{background-color:#DBE9EC; padding:5px;}
.qp{position:absolute; font-size:12px; color:#666; top:5px; right:130px; text-decoration:none; color:#069;}
#ems{position:absolute; z-index:5; display:none; top:0px; left:0px; max-width:230px; background-color:#F1F1F1; border:solid 1px #CCC; padding:5px;}
#ems img{width:44px; height:44px; border:solid 1px #FFF; cursor:pointer;}
#ems img:hover,#ems img:active{border-color:#A4B7E3;}
#ems a{color:#069; border-radius:2px; display:inline-block; margin:2px 5px; padding:1px 8px; text-decoration:none; background-color:#D5DFFD;}
#ems a:hover,#ems a:active,#ems a.ck{color:#FFF; background-color:#069;}
.tc{text-align:center; margin-top:5px;}
</style>
</head>

<body>
<p id="ltian">
	<p id="us" class="jb"></p>
	<p id="ct"></p>
    <a href="javascript:;" class="qp" onClick="this.parentNode.children[1].innerHTML=&#39;&#39;">清屏</a>
</p>
<p class="rin">
    <button id="sd">发送</button>
    <span><img src="http://www.yxsss.com/ui/sk/t.png" title="表情" id="imgbq"><img src="http://www.yxsss.com/ui/sk/e.png" title="上传图片"><form><input type="file" title="上传图片" id="upimg"></form></span>
    <p><input id="nrong"></p>
</p>
<p id="ems"><p></p><p class="tc"></p></p>
<script>
if(typeof(WebSocket)==&#39;undefined&#39;){
	alert(&#39;你的浏览器不支持 WebSocket ,推荐使用Google Chrome 或者 Mozilla Firefox&#39;);	
}
</script>
<script src="http://www.yxsss.com/ui/p/a.js" type="text/javascript"></script>
<script>
(function(){
	var key=&#39;all&#39;,mkey;
	var users={};
	var url=&#39;ws://127.0.0.1:8000&#39;;
	var so=false,n=false;
	var lus=A.$(&#39;us&#39;),lct=A.$(&#39;ct&#39;);
	function st(){
		n=prompt(&#39;请给自己取一个响亮的名字:&#39;);
		n=n.substr(0,16);
		if(!n){
			return ;	
		}
        //创建socket,注意URL的格式:ws://ip:端口
		so=new WebSocket(url);
        //握手监听函数
		so.onopen=function(){
            //状态为1证明握手成功,然后把client自定义的名字发送过去
			if(so.readyState==1){
				so.send(&#39;type=add&ming=&#39;+n);
			}
		}
	    
        //握手失败或者其他原因连接socket失败,则清除so对象并做相应提示操作
		so.onclose=function(){
			so=false;
			lct.appendChild(A.$$(&#39;<p class="c2">退出聊天室</p>&#39;));
		}
		
        //数据接收监听,接收服务器推送过来的信息,返回的数据给msg,然后进行显示
		so.onmessage=function(msg){
			eval(&#39;var da=&#39;+msg.data);
			var obj=false,c=false;
			if(da.type==&#39;add&#39;){
				var obj=A.$$(&#39;<p>&#39;+da.name+&#39;</p>&#39;);
				lus.appendChild(obj);
				cuser(obj,da.code);
				obj=A.$$(&#39;<p><span>[&#39;+da.time+&#39;]</span>欢迎<a>&#39;+da.name+&#39;</a>加入</p>&#39;);
				c=da.code;
			}else if(da.type==&#39;madd&#39;){
				mkey=da.code;
				da.users.unshift({&#39;code&#39;:&#39;all&#39;,&#39;name&#39;:&#39;大家&#39;});
				for(var i=0;i<da.users.length;i++){
					var obj=A.$$(&#39;<p>&#39;+da.users[i].name+&#39;</p>&#39;);
					lus.appendChild(obj);
					if(mkey!=da.users[i].code){
						cuser(obj,da.users[i].code);
					}else{
						obj.className=&#39;my&#39;;
						document.title=da.users[i].name;
					}
				}
				obj=A.$$(&#39;<p><span>[&#39;+da.time+&#39;]</span>欢迎&#39;+da.name+&#39;加入</p>&#39;);
				users.all.className=&#39;ck&#39;;
			}
			
			if(obj==false){
				if(da.type==&#39;rmove&#39;){
					var obj=A.$$(&#39;<p class="c2"><span>[&#39;+da.time+&#39;]</span>&#39;+users[da.nrong].innerHTML+&#39;退出聊天室</p>&#39;);
					lct.appendChild(obj);
					users[da.nrong].del();
					delete users[da.nrong];
				}else{
					da.nrong=da.nrong.replace(/{\\(\d+)}/g,function(a,b){
						return &#39;<img src="sk/&#39;+b+&#39;.gif">&#39;;
					}).replace(/^data\:image\/png;base64\,.{50,}$/i,function(a){
						return &#39;<img src="&#39;+a+&#39;">&#39;;
					});
					//da.code 发信息人的code
					if(da.code1==mkey){
						obj=A.$$(&#39;<p class="c3"><span>[&#39;+da.time+&#39;]</span><a>&#39;+users[da.code].innerHTML+&#39;</a>对我说:&#39;+da.nrong+&#39;</p>&#39;);
						c=da.code;
					}else if(da.code==mkey){
						if(da.code1!=&#39;all&#39;)
						obj=A.$$(&#39;<p class="c3"><span>[&#39;+da.time+&#39;]</span>我对<a>&#39;+users[da.code1].innerHTML+&#39;</a>说:&#39;+da.nrong+&#39;</p>&#39;);
						else
						obj=A.$$(&#39;<p><span>[&#39;+da.time+&#39;]</span>我对<a>&#39;+users[da.code1].innerHTML+&#39;</a>说:&#39;+da.nrong+&#39;</p>&#39;);
						c=da.code1;
					}else if(da.code==false){
						obj=A.$$(&#39;<p><span>[&#39;+da.time+&#39;]</span>&#39;+da.nrong+&#39;</p>&#39;);
					}else if(da.code1){
						obj=A.$$(&#39;<p><span>[&#39;+da.time+&#39;]</span><a>&#39;+users[da.code].innerHTML+&#39;</a>对&#39;+users[da.code1].innerHTML+&#39;说:&#39;+da.nrong+&#39;</p>&#39;);
						c=da.code;
					}
				}
			}
			if(c){
					obj.children[1].onclick=function(){
						users[c].onclick();
					}
				}
			lct.appendChild(obj);
			lct.scrollTop=Math.max(0,lct.scrollHeight-lct.offsetHeight);
            
		}
	}
	A.$(&#39;sd&#39;).onclick=function(){
		if(!so){
			 return st();
		}
		var da=A.$(&#39;nrong&#39;).value.trim();
		if(da==&#39;&#39;){
			alert(&#39;内容不能为空&#39;);
			return false;	
		}
		A.$(&#39;nrong&#39;).value=&#39;&#39;;
		so.send(&#39;nr=&#39;+esc(da)+&#39;&key=&#39;+key);
	}
	A.$(&#39;nrong&#39;).onkeydown=function(e){
		var e=e||event;
		if(e.keyCode==13){
			A.$(&#39;sd&#39;).onclick();
		}
	}
	function esc(da){
		da=da.replace(/</g,&#39;<&#39;).replace(/>/g,&#39;>&#39;).replace(/\"/g,&#39;"&#39;);
		return encodeURIComponent(da);
	}
	function cuser(t,code){
		users[code]=t;
		t.onclick=function(){
			t.parentNode.children.rcss(&#39;ck&#39;,&#39;&#39;);
			t.rcss(&#39;&#39;,&#39;ck&#39;);
			key=code;
		}
	}
	A.$(&#39;ltian&#39;).style.height=(document.documentElement.clientHeight - 70)+&#39;px&#39;;
	st();
	

	var bq=A.$(&#39;imgbq&#39;),ems=A.$(&#39;ems&#39;);
	var l=80,r=4,c=5,s=0,p=Math.ceil(l/(r*c));
	var pt=&#39;sk/&#39;;
	bq.onclick=function(e){
		var e=e||event;
		if(!so){
			 return st();
		}
		ems.style.display=&#39;block&#39;;
		document.onclick=function(){
			gb();	
		}
		ct();
		try{e.stopPropagation();}catch(o){}
	}
	
	for(var i=0;i<p;i++){
		var a=A.$$(&#39;<a href="javascript:;">&#39;+(i+1)+&#39;</a>&#39;);
		ems.children[1].appendChild(a);
		ef(a,i);
	}
	ems.children[1].children[0].className=&#39;ck&#39;;
	
	function ct(){
		var wz=bq.weiz();
		with(ems.style){
			top=wz.y-242+&#39;px&#39;;
			left=wz.x+bq.offsetWidth-235+&#39;px&#39;;
		}
	}
		
	function ef(t,i){
		t.onclick=function(e){
			var e=e||event;
			s=i*r*c;
			ems.children[0].innerHTML=&#39;&#39;;
			hh();
			this.parentNode.children.rcss(&#39;ck&#39;,&#39;&#39;);
			this.rcss(&#39;&#39;,&#39;ck&#39;);
			try{e.stopPropagation();}catch(o){}
		}
	}
	
	function hh(){
		var z=Math.min(l,s+r*c);
		for(var i=s;i<z;i++){
			var a=A.$$(&#39;<img src="&#39;+pt+i+&#39;.gif">&#39;);
			hh1(a,i);
			ems.children[0].appendChild(a);
		}
		ct();
	}
	
	function hh1(t,i){
		t.onclick=function(e){
			var e=e||event;
			A.$(&#39;nrong&#39;).value+=&#39;{\\&#39;+i+&#39;}&#39;;
			if(!e.ctrlKey){
				gb();
			}
			try{e.stopPropagation();}catch(o){}
		}
	}
	
	function gb(){
		ems.style.display=&#39;&#39;;
		A.$(&#39;nrong&#39;).focus();
		document.onclick=&#39;&#39;;
	}
	hh();
	A.on(window,&#39;resize&#39;,function(){
		A.$(&#39;ltian&#39;).style.height=(document.documentElement.clientHeight - 70)+&#39;px&#39;;
		ct();
	})	

	var fimg=A.$(&#39;upimg&#39;);
	var img=new Image();
	var dw=400,dh=300;
	A.on(fimg,&#39;change&#39;,function(ev){
		if(!so){
			st();
			return false;
		}
		if(key==&#39;all&#39;){
			alert(&#39;由于资源限制 发图只能私聊&#39;);
			return false;	
		}
		var f=ev.target.files[0];
		if(f.type.match(&#39;image.*&#39;)){
			var r = new FileReader();
			r.onload = function(e){
				img.setAttribute(&#39;src&#39;,e.target.result);
		    };
			r.readAsDataURL(f);
		}
	});
	img.onload=function(){
		ih=img.height,iw=img.width;
		if(iw/ih > dw/dh && iw > dw){
			ih=ih/iw*dw;
			iw=dw;
		}else if(ih > dh){
			iw=iw/ih*dh;
			ih=dh;
		}
		var rc = A.$$(&#39;canvas&#39;);
		var ct = rc.getContext(&#39;2d&#39;);
		rc.width=iw;
		rc.height=ih;
		ct.drawImage(img,0,0,iw,ih);
		var da=rc.toDataURL();
		so.send(&#39;nr=&#39;+esc(da)+&#39;&key=&#39;+key);
	}
	
})();
</script>
</body>
</html>
登入後複製

以上是php中如何使用websocket(聊天室實例詳解)的詳細內容。更多資訊請關注PHP中文網其他相關文章!

本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Java教學
1657
14
CakePHP 教程
1415
52
Laravel 教程
1309
25
PHP教程
1257
29
C# 教程
1230
24
適用於 Ubuntu 和 Debian 的 PHP 8.4 安裝和升級指南 適用於 Ubuntu 和 Debian 的 PHP 8.4 安裝和升級指南 Dec 24, 2024 pm 04:42 PM

PHP 8.4 帶來了多項新功能、安全性改進和效能改進,同時棄用和刪除了大量功能。 本指南介紹如何在 Ubuntu、Debian 或其衍生版本上安裝 PHP 8.4 或升級到 PHP 8.4

您如何在PHP中解析和處理HTML/XML? 您如何在PHP中解析和處理HTML/XML? Feb 07, 2025 am 11:57 AM

本教程演示瞭如何使用PHP有效地處理XML文檔。 XML(可擴展的標記語言)是一種用於人類可讀性和機器解析的多功能文本標記語言。它通常用於數據存儲

在PHP API中說明JSON Web令牌(JWT)及其用例。 在PHP API中說明JSON Web令牌(JWT)及其用例。 Apr 05, 2025 am 12:04 AM

JWT是一種基於JSON的開放標準,用於在各方之間安全地傳輸信息,主要用於身份驗證和信息交換。 1.JWT由Header、Payload和Signature三部分組成。 2.JWT的工作原理包括生成JWT、驗證JWT和解析Payload三個步驟。 3.在PHP中使用JWT進行身份驗證時,可以生成和驗證JWT,並在高級用法中包含用戶角色和權限信息。 4.常見錯誤包括簽名驗證失敗、令牌過期和Payload過大,調試技巧包括使用調試工具和日誌記錄。 5.性能優化和最佳實踐包括使用合適的簽名算法、合理設置有效期、

解釋PHP中的晚期靜態綁定(靜態::)。 解釋PHP中的晚期靜態綁定(靜態::)。 Apr 03, 2025 am 12:04 AM

靜態綁定(static::)在PHP中實現晚期靜態綁定(LSB),允許在靜態上下文中引用調用類而非定義類。 1)解析過程在運行時進行,2)在繼承關係中向上查找調用類,3)可能帶來性能開銷。

php程序在字符串中計數元音 php程序在字符串中計數元音 Feb 07, 2025 pm 12:12 PM

字符串是由字符組成的序列,包括字母、數字和符號。本教程將學習如何使用不同的方法在PHP中計算給定字符串中元音的數量。英語中的元音是a、e、i、o、u,它們可以是大寫或小寫。 什麼是元音? 元音是代表特定語音的字母字符。英語中共有五個元音,包括大寫和小寫: a, e, i, o, u 示例 1 輸入:字符串 = "Tutorialspoint" 輸出:6 解釋 字符串 "Tutorialspoint" 中的元音是 u、o、i、a、o、i。總共有 6 個元

什麼是PHP魔術方法(__ -construct,__destruct,__call,__get,__ set等)並提供用例? 什麼是PHP魔術方法(__ -construct,__destruct,__call,__get,__ set等)並提供用例? Apr 03, 2025 am 12:03 AM

PHP的魔法方法有哪些? PHP的魔法方法包括:1.\_\_construct,用於初始化對象;2.\_\_destruct,用於清理資源;3.\_\_call,處理不存在的方法調用;4.\_\_get,實現動態屬性訪問;5.\_\_set,實現動態屬性設置。這些方法在特定情況下自動調用,提升代碼的靈活性和效率。

PHP和Python:比較兩種流行的編程語言 PHP和Python:比較兩種流行的編程語言 Apr 14, 2025 am 12:13 AM

PHP和Python各有優勢,選擇依據項目需求。 1.PHP適合web開發,尤其快速開發和維護網站。 2.Python適用於數據科學、機器學習和人工智能,語法簡潔,適合初學者。

PHP:網絡開發的關鍵語言 PHP:網絡開發的關鍵語言 Apr 13, 2025 am 12:08 AM

PHP是一種廣泛應用於服務器端的腳本語言,特別適合web開發。 1.PHP可以嵌入HTML,處理HTTP請求和響應,支持多種數據庫。 2.PHP用於生成動態網頁內容,處理表單數據,訪問數據庫等,具有強大的社區支持和開源資源。 3.PHP是解釋型語言,執行過程包括詞法分析、語法分析、編譯和執行。 4.PHP可以與MySQL結合用於用戶註冊系統等高級應用。 5.調試PHP時,可使用error_reporting()和var_dump()等函數。 6.優化PHP代碼可通過緩存機制、優化數據庫查詢和使用內置函數。 7

See all articles