如何用PHP实现Socket服务器
socket服务器的工作方式是这样的,不间断地运行以等待客户端的连接。一旦客户端连接上了,服务器就会将它添加到客户名单中,然后开始等待来自客户端的消息。
PHP实现Socket服务器完整的源代码有哪些内容
//Settimelimittoindefiniteexecution
set_time_limit(0);
//Settheipandportwewilllistenon
$address='localhost';
$port=10000;
$max_clients=10;
//Arraythatwillholdclientinformation
$client=Array();
//CreateaTCPStreamsocket
$sock=socket_create(AF_INET,SOCK_STREAM,0);
//Bindthesockettoanaddress/port
socket_bind($sock,$address,$port)ordie('Couldnotbindtoaddress');
//Startlisteningforconnections
socket_listen($sock);
echo"Waitingforconnections...\r\n";
//Loopcontinuously
while(true){
//Setupclientslistensocketforreading
$read[0]=$sock;
for($i=0;$i<$max_clients;$i++){
if(isset($client[$i]['sock']))
$read[$i+1]=$client[$i]['sock'];
}
//Setupablockingcalltosocket_select()
if(socket_select($read,$write=NULL,$except=NULL,$tv_sec=5)<1)
continue;
/*ifanewconnectionisbeingmadeaddittotheclientarray*/
if(in_array($sock,$read)){
for($i=0;$i<$max_clients;$i++){
if(empty($client[$i]['sock'])){
$client[$i]['sock']=socket_accept($sock);
echo"Newclientconnected$i\r\n";
break;
}
elseif($i==$max_clients-1)
echo"Toomanyclients...\r\n";
}
}//endifin_array
//Ifaclientistryingtowrite-handleitnow
for($i=0;$i<$max_clients;$i++){//foreachclient
if(isset($client[$i]['sock'])){
if(in_array($client[$i]['sock'],$read)){
$input=socket_read($client[$i]['sock'],1024);
if($input==null){
echo"Clientdisconnecting$i\r\n";
//Zerolengthstringmeaningdisconnected
unset($client[$i]);
}else{
echo"Newinputreceived$i\r\n";
//sendittotheotherclients
for($j=0;$j<$max_clients;$j++){
if(isset($client[$j]['sock'])&&$j!=$i){
echo"Writing'$input'toclient$j\r\n";
socket_write($client[$j]['sock'],$input,strlen($input));
}
}
if($input=='exit'){
//requesteddisconnect
socket_close($client[$i]['sock']);
}
}
}else{
echo"Clientdisconnected$i\r\n";
//Closethesocket
socket_close($client[$i]['sock']);
unset($client[$i]);
}
}
}
}//endwhile
//Closethemastersockets
socket_close($sock);