想用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,两个客户端看起来都能和服务器端正常通讯,不知道谁有办法解决这个问题没有.

解决方案 »

  1.   

    靠,PHP写socket,看着都觉得累
      

  2.   

    可以自行实现多线程,只是缺少了系统消息所以实时性低一点
    你要自己在记忆体或档案进行信息及缓存管理另外...你用sleep...什么开发语言都会没回应
      

  3.   

    可能所有WEB的socket都一样的,socket服务器应该只负责监听,且一个端口,他不象游戏服务器样,可以自动开多个端口,一个端口监听一个IP的相关端口!所以,因为都走一个端口,所以,堵是正常的!但服务接收后可以开多进程进行处理,返回响应内容!一般只在web服务用!
      

  4.   

    因为我们这里程序员都是做php的, 开发经验也是php的, 我们比较关注开发速度, 所以要拿php来做socket服务,如果php本身没有提供多线程或者异步的东西, 我就在考虑用c写个扩展来实现异步或者说是多线程!
    代码并不长,都是调试通过的,帖上来的目的,是给以后有类似需求的朋友一个参考, 同事有抱有突然来个高手,把我问题解决的希望!
      

  5.   

    pcntl_fork正在尝试, 看起来应该可以解决问题!
      

  6.   

    PHP 不适合写  socket Server .
    建议用 Python
      

  7.   

    pcntl_fork 可以解决问题,请教个问题,我最初编译时没有 --enable-pcntl,最简单加入pcntl的方法是什么?
      

  8.   


    这个认识是错误的啊,服务器一般都只开一个端口哈,跟堵没有关系...
    WEB服务器开tcp 80,smtp开tcp 25 pop3 开110
      

  9.   

    鉴于php是解释执行的,所以并不适合做服务。
    当然实验性的应用也是可以的最好用多线程扩展 pcntl_fork 
    用 socket 的话,需要编写调度程序,楼主的代码仅供测试socket之用调度过程大致如下
    当服务响应用户发起的连接时发送一个空闲的端口给用户,启动新进程监听该端口
    用户收到端口号后,用新端口号重新发起连接
      

  10.   

    LS说的不错,看看一个PHP真正的多进程实例,支持多核处理器
    http://bbs3.chinaunix.net/thread-1529585-1-1.html
      

  11.   

    我,已经写出来用php做socket服务器+flash的简单聊天程序;
      

  12.   


    $: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重启即可,