socket文件傳輸，客戶(hù)端寫(xiě)文件速度特別慢

elegant

注：雖然用php寫(xiě)的，但是原理應(yīng)該是一樣的，因?yàn)檫@個(gè)板塊高手比較多，所以發(fā)到這個(gè)上面了，比較著急用，請(qǐng)各位幫幫忙

我用php寫(xiě)了server和client程序，我要從server接收文件handle，然后再client寫(xiě)文件，但是在client寫(xiě)文件的時(shí)候，一個(gè)1k不到的文件要寫(xiě)2分鐘左右，高手幫我看看，是什么原因
付程序[第一次，羅嗦的地方請(qǐng)幫忙告訴一下，如果有類(lèi)似的例子也可以，我去自己看，謝謝各位了]
<?php
// Set time limit to indefinite execution
set_time_limit (0);

// Set the ip and port we will listen on
#$address = '172.30.6.110';
$address = '192.168.11.4';
$port = 9200;


// Create a TCP Stream socket
$sock = socket_create(AF_INET, SOCK_STREAM, 0);
// Bind the socket to an address/port
socket_bind($sock, $address, $port) or die('Could not bind to address');
// Start listening for connections
socket_listen($sock);



$val_source_dir = "D:/php4/webapp/file";
$val_input_file_pattern = "/sample*/";

//得到要傳輸?shù)奈募�列�?
$has_file_list = r25_get_file_list($val_source_dir,$val_input_file_pattern);

foreach($has_file_list as $val_file){
   $clientHandle = socket_accept($sock);
   echo "file name:".$val_file."\n";
   $output = getFileContent($val_file);
   socket_write($clientHandle,$output);

   do {
       if (false === ($buf = socket_read($clientHandle, )) {
           echo "socket_read() failed: reason: " . socket_strerror($clientHandle) . "\n";
           break;
       }
       if ($buf == 'ok') {
           break;
       }
   } while (true);
       //
        

       printf ("<<<<<<<<<<<<< %s >;>;>;>;>;>;>;>;>;>;>;>;>;\n",$val_file);
            
            
socket_close($clientHandle);
}


// Close the master sockets
socket_close($sock);


function getFileContent($val_file) {
$file_content = file_get_contents ($val_file);
echo ">;>;>;>;>;>;>;>;>;>;>;>;>;".filesize ($val_file)."<<<<<<<<<<<<<<\n";
return $file_content;
}

?>;

客戶(hù)端：
<?
define("INPUT_PATH","D:\php4\webapp\clientIn";

$i = 0;
while (true) {

   $address = '192.168.11.4';
   $port = 9200;

   $i ++;
   $read_handle = fsockopen($address, $port, $errno, $errstr,2);
   if (!$read_handle) {
       echo "$errstr ($errno)<br />;\n";
   } else {
        if (writeFile($read_handle, $i ) == true) {
           $out = "ok";
           fputs($read_handle, $out,strlen($out));
        } else {
           echo "faile restart send\n";
           $out = "ng";
           fputs($read_handle, $out,strlen($out));
        }
         fclose($read_handle);
   }


}



function writeFile($read_handle, $index) {

$filename = "\sample_".$index;

$filewrite = fopen(INPUT_PATH."$filename","wb";

while (!feof ($read_handle)) {
    $buffer = fgets($read_handle, 4096);
if (fwrite($filewrite, $buffer) == false) {
print "not write $filename\n";
return false;
}
}


fclose($filewrite);
return true;
}

?>;

elegant

我找到辦法了，我重新設(shè)定了客戶(hù)端的緩沖區(qū)的大小
速度就變快了，但是不知道算不算正確地解決辦法

elegant

我弄錯(cuò)了，加上那個(gè)緩沖沒(méi)有作用，是因?yàn)槲以赾lient write從server的數(shù)據(jù)之前，我先發(fā)給server端一個(gè)"ok"的字符，這個(gè)字符導(dǎo)致了server繼續(xù)讀取下一個(gè)文件，如果我的原意是等客戶(hù)端寫(xiě)完了這個(gè)數(shù)據(jù)以后，才希望服務(wù)器發(fā)下一筆數(shù)據(jù)過(guò)來(lái)，最先發(fā)的就是這個(gè)意思，但是卻需要等很長(zhǎng)的時(shí)間
不知道為什么

elegant

up