想用php来做socket服务,因为http协议效率实在太低了网上找来代码,调试好之后,发现即使能两个客户端同时连接上,服务端在处理一个客户端请求时
另外一个客户端的请求被阻塞了,只有等到前一个客户端的事情处理完了,后一个客户端的请求才会被响应!
server.php
<?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
// 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,两个客户端看起来都能和服务器端正常通讯,不知道谁有办法解决这个问题没有.
另外一个客户端的请求被阻塞了,只有等到前一个客户端的事情处理完了,后一个客户端的请求才会被响应!
server.php
<?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
// 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,两个客户端看起来都能和服务器端正常通讯,不知道谁有办法解决这个问题没有.
你要自己在记忆体或档案进行信息及缓存管理另外...你用sleep...什么开发语言都会没回应
代码并不长,都是调试通过的,帖上来的目的,是给以后有类似需求的朋友一个参考, 同事有抱有突然来个高手,把我问题解决的希望!
建议用 Python
这个认识是错误的啊,服务器一般都只开一个端口哈,跟堵没有关系...
WEB服务器开tcp 80,smtp开tcp 25 pop3 开110
当然实验性的应用也是可以的最好用多线程扩展 pcntl_fork
用 socket 的话,需要编写调度程序,楼主的代码仅供测试socket之用调度过程大致如下
当服务响应用户发起的连接时发送一个空闲的端口给用户,启动新进程监听该端口
用户收到端口号后,用新端口号重新发起连接
http://bbs3.chinaunix.net/thread-1529585-1-1.html
$:cd /php-5.2.10/ext/pcntl
$:/usr/local/php/bin/phpize
$:./configure --with-php-config=/usr/local/php/bin/php-config
$:sudo make
$:sudo make install
然后把生成的SO文件插到PHP护展目录下:
cp /usr/local/php/lib/php/extensions/no-debug-non-zts-20060613/pcntl.so /usr/local/php/ext/在php.ini里面加入
extension=pcntl.so重启即可,