2009-06-24 21 views
1

我用PHP_NORMAL_READ模式創建了一個PHP Socket服務器。因此,當以\ n或\ r結尾時,會向服務器發送一條消息。我試圖通過連接到具有多個telnet實例的服務器,它工作得很好。但是,當我通過1個閃存應用程序和1個telnet應用程序(我首先啓動閃存應用程序)連接到服務器時,閃存似乎會使服務器掛起 - 服務器卡住某處,不再接收數據從例如。 telnet客戶端。爲什麼我的PHP Socket服務器掛起?

因爲任何人都可以對Flash客戶端進行編碼,所以這必須是固定的服務器端。服務器的代碼:

<?php 
// config 
$timelimit = 60; // amount of seconds the server should run for, 0 = run indefintely 
$port = 9000; // the port to listen on 
$address = $_SERVER['SERVER_ADDR']; // the server's external IP 
$backlog = SOMAXCONN; // the maximum of backlog incoming connections that will be queued for processing 

// configure custom PHP settings 
error_reporting(1); // report all errors 
ini_set('display_errors', 1); // display all errors 
set_time_limit($timelimit); // timeout after x seconds 
ob_implicit_flush(); // results in a flush operation after every output call 

//create master IPv4 based TCP socket 
if (!($master = socket_create(AF_INET, SOCK_STREAM, SOL_TCP))) die("Could not create master socket, error: ".socket_strerror(socket_last_error())); 

// set socket options (local addresses can be reused) 
if (!socket_set_option($master, SOL_SOCKET, SO_REUSEADDR, 1)) die("Could not set socket options, error: ".socket_strerror(socket_last_error())); 

// bind to socket server 
if (!socket_bind($master, $address, $port)) die("Could not bind to socket server, error: ".socket_strerror(socket_last_error())); 

// start listening 
if (!socket_listen($master, $backlog)) die("Could not start listening to socket, error: ".socket_strerror(socket_last_error())); 

//display startup information 
echo "[".date('Y-m-d H:i:s')."] SERVER CREATED (MAXCONN: ".SOMAXCONN.").\n"; //max connections is a kernel variable and can be adjusted with sysctl 
echo "[".date('Y-m-d H:i:s')."] Listening on ".$address.":".$port.".\n"; 
$time = time(); //set startup timestamp 

// init read sockets array 
$read_sockets = array($master); 

// continuously handle incoming socket messages, or close if time limit has been reached 
while ((!$timelimit) or (time() - $time < $timelimit)) { 
    $changed_sockets = $read_sockets; 
    socket_select($changed_sockets, $write = null, $except = null, null); 
    foreach($changed_sockets as $socket) { 
     if ($socket == $master) { 
      if (($client = socket_accept($master)) < 0) { 
       continue; 
      } else { 
       array_push($read_sockets, $client); 
      } 
     } else { 
      $data = @socket_read($socket, 1024, PHP_NORMAL_READ); //read a maximum of 1024 bytes until a new line has been sent 
      if ($data === false) { //the client disconnected 
       $index = array_search($socket, $read_sockets); 
       unset($read_sockets[$index]); 
       socket_close($socket); 
      } elseif ($data = trim($data)) { //remove whitespace and continue only if the message is not empty 
       echo "we received: ".$data."\n\n"; 
       //handleData($data, $socket); 
      } 
     } 
    } 
} 
socket_close($master); //close the socket 
echo "[".date('Y-m-d H:i:s')."] SERVER CLOSED.\n"; 

//function to write to the flash client 
function flash_write($socket, $msg) { 
    socket_write($socket, $msg.chr(0x0)); 
} 
?> 

有沒有人知道可能會導致這種情況?我試着將socket_select的超時時間從none更改爲0(即時返回),但這似乎沒有改變任何東西。

回答

2

你可以發佈Flash客戶端的來源嗎?這將顯示問題是什麼?

你確定你從Flash客戶端發送的最後一件事是\ n嗎?

否則,服務器會阻塞socket_read()作爲Flash客戶端插座可以不受阻塞(觸發socket_select()),但不發送結束\ n讀取。

+1

@bucabay擁有正確的答案。 socket_select()將在套接字上的數據就緒時觸發,但不能保證數據包含socket_read($ socket,1024,PHP_NORMAL_READ)正在等待的終端換行符。如果您想通過惡意(或者僅僅是疏忽)的客戶端防禦DoS,您需要以二進制模式閱讀並自己查找換行符。 – bd808 2009-06-25 05:51:02