纯粹copy来的哦。
要在php中使用socket，首先需要再php.ini中打开扩展，将extension=php_sockets.dll前的；去除。在PHPinfo（）中可以看到socket模块状态为enabled说明该模块可以启动。
创建一个聊天室。
client端代码：
1 <!doctype html> 2 <html> 3 <head> 4 <meta charset="utf-8"> 5 <meta name="viewport" content="width=device-width, initial-scale=1, user-scalable=no"/> 6 <title>HTML5 websocket 网页聊天室 javascript php</title> 7 <style type="text/css"> 8 body,p{margin:0px; padding:0px; font-size:14px; color:#333; font-family:Arial, Helvetica, sans-serif;} 9 #ltian,.rin{98%; margin:5px auto;} 10 #ltian{border:1px #ccc solid;overflow-y:auto; overflow-x:hidden; position:relative;} 11 #ct{margin-right:111px; height:100%;overflow-y:auto;overflow-x: hidden;} 12 #us{110px; overflow-y:auto; overflow-x:hidden; float:right; border-left:1px #ccc solid; height:100%; background-color:#F1F1F1;} 13 #us p{padding:3px 5px; color:#08C; line-height:20px; height:20px; cursor:pointer; overflow:hidden; white-space:nowrap; text-overflow:ellipsis;} 14 #us p:hover,#us p:active,#us p.ck{background-color:#069; color:#FFF;} 15 #us p.my:hover,#us p.my:active,#us p.my{color:#333;background-color:transparent;} 16 button{float:right; 80px; height:35px; font-size:18px;} 17 input{100%; height:30px; padding:2px; line-height:20px; outline:none; border:solid 1px #CCC;} 18 .rin p{margin-right:160px;} 19 .rin span{float:right; padding:6px 5px 0px 5px; position:relative;} 20 .rin span img{margin:0px 3px; cursor:pointer;} 21 .rin span form{position:absolute; 25px; height:25px; overflow:hidden; opacity:0; top:5px; right:5px;} 22 .rin span input{180px; height:25px; margin-left:-160px; cursor:pointer} 23 24 #ct p{padding:5px; line-height:20px;} 25 #ct a{color:#069; cursor:pointer;} 26 #ct span{color:#999; margin-right:10px;} 27 .c2{color:#999;} 28 .c3{background-color:#DBE9EC; padding:5px;} 29 .qp{position:absolute; font-size:12px; color:#666; top:5px; right:130px; text-decoration:none; color:#069;} 30 #ems{position:absolute; z-index:5; display:none; top:0px; left:0px; max-230px; background-color:#F1F1F1; border:solid 1px #CCC; padding:5px;} 31 #ems img{44px; height:44px; border:solid 1px #FFF; cursor:pointer;} 32 #ems img:hover,#ems img:active{border-color:#A4B7E3;} 33 #ems a{color:#069; border-radius:2px; display:inline-block; margin:2px 5px; padding:1px 8px; text-decoration:none; background-color:#D5DFFD;} 34 #ems a:hover,#ems a:active,#ems a.ck{color:#FFF; background-color:#069;} 35 .tc{text-align:center; margin-top:5px;} 36 </style> 37 </head> 38 39 <body> 40 <div id="ltian"> 41 <div id="us" class="jb"></div> 42 <div id="ct"></div> 43 <a href="javascript:;" class="qp" onClick="this.parentNode.children[1].innerHTML=''">清屏</a> 44 </div> 45 <div class="rin"> 46 <button id="sd">发送</button> 47 <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> 48 <p><input id="nrong"></p> 49 </div> 50 <div id="ems"><p></p><p class="tc"></p></div> 51 <script> 52 if(typeof(WebSocket)=='undefined'){ 53 alert('你的浏览器不支持 WebSocket ，推荐使用Google Chrome 或者 Mozilla Firefox'); 54 } 55 </script> 56 <script src="http://www.yxsss.com/ui/p/a.js" type="text/javascript"></script> 57 <script> 58 (function(){ 59 var key='all',mkey; 60 var users={}; 61 var url='ws://127.0.0.1:8000'; 62 var so=false,n=false; 63 var lus=A.$('us'),lct=A.$('ct'); 64 function st(){ 65 n=prompt('请给自己取一个响亮的名字：'); 66 n=n.substr(0,16); 67 if(!n){ 68 return ; 69 } 70 //创建socket，注意URL的格式：ws://ip:端口 71 so=new WebSocket(url); 72 //握手监听函数 73 so.onopen=function(){ 74 //状态为1证明握手成功，然后把client自定义的名字发送过去 75 if(so.readyState==1){ 76 so.send('type=add&ming='+n); 77 } 78 } 79 80 //握手失败或者其他原因连接socket失败，则清除so对象并做相应提示操作 81 so.onclose=function(){ 82 so=false; 83 lct.appendChild(A.$$('<p class="c2">退出聊天室</p>')); 84 } 85 86 //数据接收监听，接收服务器推送过来的信息，返回的数据给msg，然后进行显示 87 so.onmessage=function(msg){ 88 eval('var da='+msg.data); 89 var obj=false,c=false; 90 if(da.type=='add'){ 91 var obj=A.$$('<p>'+da.name+'</p>'); 92 lus.appendChild(obj); 93 cuser(obj,da.code); 94 obj=A.$$('<p><span>['+da.time+']</span>欢迎<a>'+da.name+'</a>加入</p>'); 95 c=da.code; 96 }else if(da.type=='madd'){ 97 mkey=da.code; 98 da.users.unshift({'code':'all','name':'大家'}); 99 for(var i=0;i<da.users.length;i++){ 100 var obj=A.$$('<p>'+da.users[i].name+'</p>'); 101 lus.appendChild(obj); 102 if(mkey!=da.users[i].code){ 103 cuser(obj,da.users[i].code); 104 }else{ 105 obj.className='my'; 106 document.title=da.users[i].name; 107 } 108 } 109 obj=A.$$('<p><span>['+da.time+']</span>欢迎'+da.name+'加入</p>'); 110 users.all.className='ck'; 111 } 112 113 if(obj==false){ 114 if(da.type=='rmove'){ 115 var obj=A.$$('<p class="c2"><span>['+da.time+']</span>'+users[da.nrong].innerHTML+'退出聊天室</p>'); 116 lct.appendChild(obj); 117 users[da.nrong].del(); 118 delete users[da.nrong]; 119 }else{ 120 da.nrong=da.nrong.replace(/{\(d+)}/g,function(a,b){ 121 return '<img src="sk/'+b+'.gif">'; 122 }).replace(/^data:image/png;base64\,.{50,}$/i,function(a){ 123 return '<img src="'+a+'">'; 124 }); 125 //da.code 发信息人的code 126 if(da.code1==mkey){ 127 obj=A.$$('<p class="c3"><span>['+da.time+']</span><a>'+users[da.code].innerHTML+'</a>对我说：'+da.nrong+'</p>'); 128 c=da.code; 129 }else if(da.code==mkey){ 130 if(da.code1!='all') 131 obj=A.$$('<p class="c3"><span>['+da.time+']</span>我对<a>'+users[da.code1].innerHTML+'</a>说：'+da.nrong+'</p>'); 132 else 133 obj=A.$$('<p><span>['+da.time+']</span>我对<a>'+users[da.code1].innerHTML+'</a>说：'+da.nrong+'</p>'); 134 c=da.code1; 135 }else if(da.code==false){ 136 obj=A.$$('<p><span>['+da.time+']</span>'+da.nrong+'</p>'); 137 }else if(da.code1){ 138 obj=A.$$('<p><span>['+da.time+']</span><a>'+users[da.code].innerHTML+'</a>对'+users[da.code1].innerHTML+'说：'+da.nrong+'</p>'); 139 c=da.code; 140 } 141 } 142 } 143 if(c){ 144 obj.children[1].onclick=function(){ 145 users[c].onclick(); 146 } 147 } 148 lct.appendChild(obj); 149 lct.scrollTop=Math.max(0,lct.scrollHeight-lct.offsetHeight); 150 151 } 152 } 153 A.$('sd').onclick=function(){ 154 if(!so){ 155 return st(); 156 } 157 var da=A.$('nrong').value.trim(); 158 if(da==''){ 159 alert('内容不能为空'); 160 return false; 161 } 162 A.$('nrong').value=''; 163 so.send('nr='+esc(da)+'&key='+key); 164 } 165 A.$('nrong').onkeydown=function(e){ 166 var e=e||event; 167 if(e.keyCode==13){ 168 A.$('sd').onclick(); 169 } 170 } 171 function esc(da){ 172 da=da.replace(/</g,'<').replace(/>/g,'>').replace(/"/g,'"'); 173 return encodeURIComponent(da); 174 } 175 function cuser(t,code){ 176 users[code]=t; 177 t.onclick=function(){ 178 t.parentNode.children.rcss('ck',''); 179 t.rcss('','ck'); 180 key=code; 181 } 182 } 183 A.$('ltian').style.height=(document.documentElement.clientHeight - 70)+'px'; 184 st(); 185 186 187 var bq=A.$('imgbq'),ems=A.$('ems'); 188 var l=80,r=4,c=5,s=0,p=Math.ceil(l/(r*c)); 189 var pt='sk/'; 190 bq.onclick=function(e){ 191 var e=e||event; 192 if(!so){ 193 return st(); 194 } 195 ems.style.display='block'; 196 document.onclick=function(){ 197 gb(); 198 } 199 ct(); 200 try{e.stopPropagation();}catch(o){} 201 } 202 203 for(var i=0;i<p;i++){ 204 var a=A.$$('<a href="javascript:;">'+(i+1)+'</a>'); 205 ems.children[1].appendChild(a); 206 ef(a,i); 207 } 208 ems.children[1].children[0].className='ck'; 209 210 function ct(){ 211 var wz=bq.weiz(); 212 with(ems.style){ 213 top=wz.y-242+'px'; 214 left=wz.x+bq.offsetWidth-235+'px'; 215 } 216 } 217 218 function ef(t,i){ 219 t.onclick=function(e){ 220 var e=e||event; 221 s=i*r*c; 222 ems.children[0].innerHTML=''; 223 hh(); 224 this.parentNode.children.rcss('ck',''); 225 this.rcss('','ck'); 226 try{e.stopPropagation();}catch(o){} 227 } 228 } 229 230 function hh(){ 231 var z=Math.min(l,s+r*c); 232 for(var i=s;i<z;i++){ 233 var a=A.$$('<img src="'+pt+i+'.gif">'); 234 hh1(a,i); 235 ems.children[0].appendChild(a); 236 } 237 ct(); 238 } 239 240 function hh1(t,i){ 241 t.onclick=function(e){ 242 var e=e||event; 243 A.$('nrong').value+='{\'+i+'}'; 244 if(!e.ctrlKey){ 245 gb(); 246 } 247 try{e.stopPropagation();}catch(o){} 248 } 249 } 250 251 function gb(){ 252 ems.style.display=''; 253 A.$('nrong').focus(); 254 document.onclick=''; 255 } 256 hh(); 257 A.on(window,'resize',function(){ 258 A.$('ltian').style.height=(document.documentElement.clientHeight - 70)+'px'; 259 ct(); 260 }) 261 262 var fimg=A.$('upimg'); 263 var img=new Image(); 264 var dw=400,dh=300; 265 A.on(fimg,'change',function(ev){ 266 if(!so){ 267 st(); 268 return false; 269 } 270 if(key=='all'){ 271 alert('由于资源限制 发图只能私聊'); 272 return false; 273 } 274 var f=ev.target.files[0]; 275 if(f.type.match('image.*')){ 276 var r = new FileReader(); 277 r.onload = function(e){ 278 img.setAttribute('src',e.target.result); 279 }; 280 r.readAsDataURL(f); 281 } 282 }); 283 img.onload=function(){ 284 ih=img.height,iw=img.width; 285 if(iw/ih > dw/dh && iw > dw){ 286 ih=ih/iw*dw; 287 iw=dw; 288 }else if(ih > dh){ 289 iw=iw/ih*dh; 290 ih=dh; 291 } 292 var rc = A.$$('canvas'); 293 var ct = rc.getContext('2d'); 294 rc.width=iw; 295 rc.height=ih; 296 ct.drawImage(img,0,0,iw,ih); 297 var da=rc.toDataURL(); 298 so.send('nr='+esc(da)+'&key='+key); 299 } 300 301 })(); 302 </script> 303 </body> 304 </html>
server端代码：
1 <?php 2 3 error_reporting(E_ALL ^ E_NOTICE); 4 ob_implicit_flush(); 5 date_default_timezone_set("Asia/Shanghai"); 6 7 //地址与接口，即创建socket时需要服务器的IP和端口 8 $sk=new Sock('127.0.0.1',8000); 9 10 //对创建的socket循环进行监听，处理数据 11 $sk->run(); 12 13 //下面是sock类 14 class Sock{ 15 public $sockets; //socket的连接池，即client连接进来的socket标志 16 public $users; //所有client连接进来的信息，包括socket、client名字等 17 public $master; //socket的resource，即前期初始化socket时返回的socket资源 18 19 private $sda=array(); //已接收的数据 20 private $slen=array(); //数据总长度 21 private $sjen=array(); //接收数据的长度 22 private $ar=array(); //加密key 23 private $n=array(); 24 25 public function __construct($address, $port){ 26 27 //创建socket并把保存socket资源在$this->master 28 $this->master=$this->WebSocket($address, $port); 29 30 //创建socket连接池 31 $this->sockets=array($this->master); 32 } 33 34 //对创建的socket循环进行监听，处理数据 35 function run(){ 36 //死循环，直到socket断开 37 while(true){ 38 $changes=$this->sockets; 39 $write=NULL; 40 $except=NULL; 41 42 /* 43 //这个函数是同时接受多个连接的关键，我的理解它是为了阻塞程序继续往下执行。 44 socket_select ($sockets, $write = NULL, $except = NULL, NULL); 45 46 $sockets可以理解为一个数组，这个数组中存放的是文件描述符。当它有变化（就是有新消息到或者有客户端连接/断开）时，socket_select函数才会返回，继续往下执行。 47 $write是监听是否有客户端写数据，传入NULL是不关心是否有写变化。 48 $except是$sockets里面要被排除的元素，传入NULL是”监听”全部。 49 最后一个参数是超时时间 50 如果为0：则立即结束 51 如果为n>1: 则最多在n秒后结束，如遇某一个连接有新动态，则提前返回 52 如果为null：如遇某一个连接有新动态，则返回 53 */ 54 socket_select($changes,$write,$except,NULL); 55 foreach($changes as $sock){ 56 57 //如果有新的client连接进来，则 58 if($sock==$this->master){ 59 60 //接受一个socket连接 61 $client=socket_accept($this->master); 62 63 //给新连接进来的socket一个唯一的ID 64 $key=uniqid(); 65 $this->sockets[]=$client; //将新连接进来的socket存进连接池 66 $this->users[$key]=array( 67 'socket'=>$client, //记录新连接进来client的socket信息 68 'shou'=>false //标志该socket资源没有完成握手 69 ); 70 //否则1.为client断开socket连接，2.client发送信息 71 }else{ 72 $len=0; 73 $buffer=''; 74 //读取该socket的信息，注意：第二个参数是引用传参即接收数据，第三个参数是接收数据的长度 75 do{ 76 $l=socket_recv($sock,$buf,1000,0); 77 $len+=$l; 78 $buffer.=$buf; 79 }while($l==1000); 80 81 //根据socket在user池里面查找相应的$k,即健ID 82 $k=$this->search($sock); 83 84 //如果接收的信息长度小于7，则该client的socket为断开连接 85 if($len<7){ 86 //给该client的socket进行断开操作，并在$this->sockets和$this->users里面进行删除 87 $this->send2($k); 88 continue; 89 } 90 //判断该socket是否已经握手 91 if(!$this->users[$k]['shou']){ 92 //如果没有握手，则进行握手处理 93 $this->woshou($k,$buffer); 94 }else{ 95 //走到这里就是该client发送信息了，对接受到的信息进行uncode处理 96 $buffer = $this->uncode($buffer,$k); 97 if($buffer==false){ 98 continue; 99 } 100 //如果不为空，则进行消息推送操作 101 $this->send($k,$buffer); 102 } 103 } 104 } 105 106 } 107 108 } 109 110 //指定关闭$k对应的socket 111 function close($k){ 112 //断开相应socket 113 socket_close($this->users[$k]['socket']); 114 //删除相应的user信息 115 unset($this->users[$k]); 116 //重新定义sockets连接池 117 $this->sockets=array($this->master); 118 foreach($this->users as $v){ 119 $this->sockets[]=$v['socket']; 120 } 121 //输出日志 122 $this->e("key:$k close"); 123 } 124 125 //根据sock在users里面查找相应的$k 126 function search($sock){ 127 foreach ($this->users as $k=>$v){ 128 if($sock==$v['socket']) 129 return $k; 130 } 131 return false; 132 } 133 134 //传相应的IP与端口进行创建socket操作 135 function WebSocket($address,$port){ 136 $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP); 137 socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);//1表示接受所有的数据包 138 socket_bind($server, $address, $port); 139 socket_listen($server); 140 $this->e('Server Started : '.date('Y-m-d H:i:s')); 141 $this->e('Listening on : '.$address.' port '.$port); 142 return $server; 143 } 144 145 146 /* 147 * 函数说明：对client的请求进行回应，即握手操作 148 * @$k clien的socket对应的健，即每个用户有唯一$k并对应socket 149 * @$buffer 接收client请求的所有信息 150 */ 151 function woshou($k,$buffer){ 152 153 //截取Sec-WebSocket-Key的值并加密，其中$key后面的一部分258EAFA5-E914-47DA-95CA-C5AB0DC85B11字符串应该是固定的 154 $buf = substr($buffer,strpos($buffer,'Sec-WebSocket-Key:')+18); 155 $key = trim(substr($buf,0,strpos($buf," "))); 156 $new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true)); 157 158 //按照协议组合信息进行返回 159 $new_message = "HTTP/1.1 101 Switching Protocols "; 160 $new_message .= "Upgrade: websocket "; 161 $new_message .= "Sec-WebSocket-Version: 13 "; 162 $new_message .= "Connection: Upgrade "; 163 $new_message .= "Sec-WebSocket-Accept: " . $new_key . " "; 164 socket_write($this->users[$k]['socket'],$new_message,strlen($new_message)); 165 166 //对已经握手的client做标志 167 $this->users[$k]['shou']=true; 168 return true; 169 170 } 171 172 //解码函数 173 function uncode($str,$key){ 174 $mask = array(); 175 $data = ''; 176 $msg = unpack('H*',$str); 177 $head = substr($msg[1],0,2); 178 if ($head == '81' && !isset($this->slen[$key])) { 179 $len=substr($msg[1],2,2); 180 $len=hexdec($len);//把十六进制的转换为十进制 181 if(substr($msg[1],2,2)=='fe'){ 182 $len=substr($msg[1],4,4); 183 $len=hexdec($len); 184 $msg[1]=substr($msg[1],4); 185 }else if(substr($msg[1],2,2)=='ff'){ 186 $len=substr($msg[1],4,16); 187 $len=hexdec($len); 188 $msg[1]=substr($msg[1],16); 189 } 190 $mask[] = hexdec(substr($msg[1],4,2)); 191 $mask[] = hexdec(substr($msg[1],6,2)); 192 $mask[] = hexdec(substr($msg[1],8,2)); 193 $mask[] = hexdec(substr($msg[1],10,2)); 194 $s = 12; 195 $n=0; 196 }else if($this->slen[$key] > 0){ 197 $len=$this->slen[$key]; 198 $mask=$this->ar[$key]; 199 $n=$this->n[$key]; 200 $s = 0; 201 } 202 203 $e = strlen($msg[1])-2; 204 for ($i=$s; $i<= $e; $i+= 2) { 205 $data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2))); 206 $n++; 207 } 208 $dlen=strlen($data); 209 210 if($len > 255 && $len > $dlen+intval($this->sjen[$key])){ 211 $this->ar[$key]=$mask; 212 $this->slen[$key]=$len; 213 $this->sjen[$key]=$dlen+intval($this->sjen[$key]); 214 $this->sda[$key]=$this->sda[$key].$data; 215 $this->n[$key]=$n; 216 return false; 217 }else{ 218 unset($this->ar[$key],$this->slen[$key],$this->sjen[$key],$this->n[$key]); 219 $data=$this->sda[$key].$data; 220 unset($this->sda[$key]); 221 return $data; 222 } 223 224 } 225 226 //与uncode相对 227 function code($msg){ 228 $frame = array(); 229 $frame[0] = '81'; 230 $len = strlen($msg); 231 if($len < 126){ 232 $frame[1] = $len<16?'0'.dechex($len):dechex($len); 233 }else if($len < 65025){ 234 $s=dechex($len); 235 $frame[1]='7e'.str_repeat('0',4-strlen($s)).$s; 236 }else{ 237 $s=dechex($len); 238 $frame[1]='7f'.str_repeat('0',16-strlen($s)).$s; 239 } 240 $frame[2] = $this->ord_hex($msg); 241 $data = implode('',$frame); 242 return pack("H*", $data); 243 } 244 245 function ord_hex($data) { 246 $msg = ''; 247 $l = strlen($data); 248 for ($i= 0; $i<$l; $i++) { 249 $msg .= dechex(ord($data{$i})); 250 } 251 return $msg; 252 } 253 254 //用户加入或client发送信息 255 function send($k,$msg){ 256 //将查询字符串解析到第二个参数变量中，以数组的形式保存如：parse_str("name=Bill&age=60",$arr) 257 parse_str($msg,$g); 258 $ar=array(); 259 260 if($g['type']=='add'){ 261 //第一次进入添加聊天名字，把姓名保存在相应的users里面 262 $this->users[$k]['name']=$g['ming']; 263 $ar['type']='add'; 264 $ar['name']=$g['ming']; 265 $key='all'; 266 }else{ 267 //发送信息行为，其中$g['key']表示面对大家还是个人，是前段传过来的信息 268 $ar['nrong']=$g['nr']; 269 $key=$g['key']; 270 } 271 //推送信息 272 $this->send1($k,$ar,$key); 273 } 274 275 //对新加入的client推送已经在线的client 276 function getusers(){ 277 $ar=array(); 278 foreach($this->users as $k=>$v){ 279 $ar[]=array('code'=>$k,'name'=>$v['name']); 280 } 281 return $ar; 282 } 283 284 //$k 发信息人的socketID $key接受人的 socketID ，根据这个socketID可以查找相应的client进行消息推送，即指定client进行发送 285 function send1($k,$ar,$key='all'){ 286 $ar['code1']=$key; 287 $ar['code']=$k; 288 $ar['time']=date('m-d H:i:s'); 289 //对发送信息进行编码处理 290 $str = $this->code(json_encode($ar)); 291 //面对大家即所有在线者发送信息 292 if($key=='all'){ 293 $users=$this->users; 294 //如果是add表示新加的client 295 if($ar['type']=='add'){ 296 $ar['type']='madd'; 297 $ar['users']=$this->getusers(); //取出所有在线者，用于显示在在线用户列表中 298 $str1 = $this->code(json_encode($ar)); //单独对新client进行编码处理，数据不一样 299 //对新client自己单独发送，因为有些数据是不一样的 300 socket_write($users[$k]['socket'],$str1,strlen($str1)); 301 //上面已经对client自己单独发送的，后面就无需再次发送，故unset 302 unset($users[$k]); 303 } 304 //除了新client外，对其他client进行发送信息。数据量大时，就要考虑延时等问题了 305 foreach($users as $v){ 306 socket_write($v['socket'],$str,strlen($str)); 307 } 308 }else{ 309 //单独对个人发送信息，即双方聊天 310 socket_write($this->users[$k]['socket'],$str,strlen($str)); 311 socket_write($this->users[$key]['socket'],$str,strlen($str)); 312 } 313 } 314 315 //用户退出向所用client推送信息 316 function send2($k){ 317 $this->close($k); 318 $ar['type']='rmove'; 319 $ar['nrong']=$k; 320 $this->send1(false,$ar,'all'); 321 } 322 323 //记录日志 324 function e($str){ 325 //$path=dirname(__FILE__).'/log.txt'; 326 $str=$str." "; 327 //error_log($str,3,$path); 328 //编码处理 329 echo iconv('utf-8','gbk//IGNORE',$str); 330 } 331 } 332 ?>