万恶的单线程!!怎样才能实现一个真正的多线程的php socket server啊!!!

wuaji

　　想用php来做socket服务,因为http协议效率实在太低了
网上找来代码,调试好之后,发现即使能两个客户端同时连接上,服务端在处理一个客户端请求时
另外一个客户端的请求被阻塞了,只有等到前一个客户端的事情处理完了,后一个客户端的请求才会被响应!

server.php


PHP code


<?php
$addr = "127.0.0.1";
$port = 1000;
$remoteIP = "";
$remotePort = "";
$socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
if($socket < 0) {
echo "Socket create:".$socket_strerror($socket)."/n";
exit;
}
if ( ($ret = socket_bind($socket, $addr, $port)) < 0 ) {
echo "socket bind:".socket_strerror()."/n";
exit;
}
if ( ($ret = socket_listen($socket, 5)) < 0 ) {
echo "socket listen:".socket_strerror()."/n";
exit;
}
socket_set_nonblock($socket);
echo "Wainting fro a connection:/n";
$clients = array($socket);
while(true) {
$read = $clients;
if(socket_select($read, $writes=NULL, $execs=NULL, 3) < 1){
//echo ".";
        continue;
}
if(in_array($socket,$read)) {
$clients[] = $newsock = socket_accept($socket);
socket_set_nonblock($newsock);
socket_getpeername($newsock,&$remoteIP,&$remotePort);        
$key = array_search($socket,$read);
unset($read[$key]);
$msg = "Server: $addr/r/n".
"Notice:Welcome the user from ".$remoteIP.":".$remotePort."./r/n";
echo $remoteIP.":".$remotePort." conected in./r/n";
socket_write($newsock,$msg);
}
foreach($read as $read_sock) {
$data = @socket_read($read_sock,1024,PHP_BINARY_READ);
if($data == false) {
$key = array_search($read_sock,$clients);
print_r($clients[$key]);
unset($clients[$key]);
socket_close($read_sock);
echo "Client disconnected./n";
continue;
}
$command = strtoupper ($data);
switch ($command)
{
case "LIST":
$writer = print_r($clients,1);
break;
case "HELLO":
$writer = "Hello Everybody!";
break;
case "QUIT":
$writer = "Bye-Bye";
break;
case "SLEEP":
sleep(30);
$writer = "sleeped 10 seconds!";
break;
case "HELP":
$writer = "HELLO/tQUIT/tHELP";
break;
default:
$writer = "Error Command!/r/nType help for help message!";
}
socket_write($read_sock, $writer);
//exit;
    }
}
socket_close($socket);
?>


　　
client.php


PHP code


<?php
// Client
// 设置错误处理
error_reporting (E_ALL);
// 设置处理时间
set_time_limit (0);
$ip = "127.0.0.1";       // IP 地址
$port = 1000;            // 端口号

$socket = socket_create (AF_INET, SOCK_STREAM, SOL_TCP);   // 创建一个SOCKET
if ($socket)
echo "socket_create() successed!/n";
else
echo "socket_create() failed:".socket_strerror ($socket)."/n";
$conn = socket_connect ($socket, $ip, $port);       // 建立SOCKET的连接
if ($conn)
echo "Success to connection![".$ip.":".$port."]/n";
else
echo "socket_connect() failed:".socket_strerror ($conn)."/n";
echo socket_read ($socket, 1024);   
$stdin = fopen ('php://stdin', 'r');
while (true)
{
$command = trim (fgets ($stdin, 1024));
socket_write ($socket, $command, strlen ($command));
$msg = trim (socket_read ($socket, 1024));
echo $msg."/n";
if ($msg == "Bye-Bye")
break;
}
fclose ($stdin);
socket_close ($socket);
?>


　　
第一个客户端连接上后输入命令sleep,迫使服务器端持续处理第一个客户端的请求,第二个客户端连接能成功连接,但是得不到响应,如果不使用sleep,两个客户端看起来都能和服务器端正常通讯,不知道谁有办法解决这个问题没有.