Mój pierwszy serwer w PHP... Opcje

[Bakus]

Serwer (Wywoływany jako "php -q serwer.php"):

[PHP] pobierz, plaintext 
<?php
if(!extension_loaded('sockets'))
	dl(&#092;"php_sockets.dll\");
 
error_reporting (E_ALL);
set_time_limit (0);
ob_implicit_flush ();
 
$address = '192.168.0.1';
$port = 522;
 
print 'Uruchamianie serwera';
 
if (($sock = socket_create(AF_INET, SOCK_STREAM, 0)) < 0)
	echo &#092;"nnsocket_create() failed: reason: \" . socket_strerror ($sock) . \"n\"; else print '.';
 
if (($ret = socket_bind($sock, $address, $port)) < 0)
	echo &#092;"nnsocket_bind() failed: reason: \" . socket_strerror($ret) . \"n\"; else print '.';
 
if (($ret = socket_listen($sock, 5)) < 0)
	echo &#092;"nnsocket_listen() failed: reason: \" . socket_strerror($ret) . \"n\"; else print '.';
 
do{
	if (($msgsock = socket_accept($sock)) < 0)
	{
		echo &#092;"nnsocket_accept() failed: reason: \" . socket_strerror($msgsock) . \"n\";
		break;
	}
 
	$msg = &#092;"nWelcome to the KAB php Test Server. n\";
	socket_write($msgsock, $msg, strlen($msg));
	print &#092;"tUser connected\";
 
	do{
		if (FALSE === ($buf = socket_read ($msgsock, 4096, PHP_NORMAL_READ)))
		{
			echo &#092;"socket_read() failed: reason: \" . socket_strerror($ret) . \"n\";
			break 2;
		}
		if (!$buf = trim($buf))
		{
			continue;
		}
		if ($buf == 'quit')
		{
			break;
		}
		if ($buf == 'get')
		{
			print &#092;"nttWysylanie 'file'...n\";
			$message = 'file';
			socket_write($msgsock, $message, strlen($message));
			print &#092;"ttreadyn\";
			if(!(FALSE === ($b = socket_read ($msgsock, 4096, PHP_NORMAL_READ))))
			{
				$message = 'ok';
				socket_write($msgsock, $message, strlen($message));
				$f = fopen(&#092;"./\" . $b, \"wb\");
				print &#092;"ttTransfering data\";
				while(!(FALSE === ($b = socket_read ($msgsock, 10240, PHP_NORMAL_READ))))
				{
					if($b != &#092;"end\")
					{
						print '.';
						fwrite($f, base64_decode($B));
					}else{
						print &#092;"nttOtrzymano 'end'...n\";
						fclose($f);
						break 2;
					}
				}
				print &#092;"tendn\";
			}else{
				print &#092;"terrorn\";
			}
		}
		if ($buf == 'shutdown')
		{
			$quit_message = 'Dziękujemy za skorzystanie z naszych usług';
			socket_write($msgsock, $quit_message, strlen($quit_message));
			socket_close($msgsock);
			print 'Zatrzymywanie serwera';
			break 2;
		}
		$talkback = &#092;"> '$buf'.n\";
		socket_write($msgsock, $talkback, strlen($talkback));
		echo &#092;"$bufn\";
	}while(true);
	print &#092;"tUzytkownik rozlaczonynn\";
	print &#092;"Oczekiwanie na nastepne polaczenien\";
	socket_close ($msgsock);
}while(true);
socket_close ($sock);
 
print &#092;"...EOSnn\";
?>
[PHP] pobierz, plaintext 

Klient (przez www):

[PHP] pobierz, plaintext 
<PRE><?php
$plik = &#092;"do_przeslania.zip\";
$sciezka = &#092;"./\";
 
$s = fsockopen('192.168.0.1', 522, $error, $errno, 10);
print fread($s, 2048);
fputs($s, 'get');
if(fread($s, 2048) == &#092;"file\")
{
	fputs($s, $plik);
	if(fread($s, 2048) == &#092;"ok\")
	{
			$fp = fopen($sciezka . $plik, &#092;"rb\");
			while (!feof($fp))
			{
				fputs($s, base64_encode(fgets($fp, 8196)));
			}
			fclose($fp);
		fputs($s, 'end');
		fputs($s, 'quit');
		fclose($s);
	}else{
		fputs($s, 'quit');
		fclose($s);
	}
}else{
	fputs($s, 'quit');
	fclose($s);
}
?></PRE>
[PHP] pobierz, plaintext 

Klient wysyła zawartość pliku odczytanego z dysku na serwer.
Serwer jest jednowątkowy piki co, ale jak na pierwsze moje dzieło z użyciem socket_* to chyba nieźle...

Byłbym wdzięczny za poprawki do tego wspaniałego (moim skromym zdaniem) serwera...
Klient będzie docelowo napisany w php-GTK, tak by odczytywać pliki z dysków użytkowników...

Celem jest stworzenie uploadera w php-GTK (klient) i php (serwer).

Klient tutaj zamieszczony jest (jak już wspomniałem) dla potrzeb testów...

Najbardziej liczę na waszą pomoc jeżeli chodzi o dodanie wielowątkowości do serwera - tak by naraz z niego mogło korzystać wiele osób.
Jeżeli okaże się to niemożliwe, to proszę o podpowiedź w jaki sposób można "zablokować" serwer przed kolejnymi uploadami (tak, by klient wiedziałm że serwer jest wykorzystywany przez kogoś innego i musi poczkać)

<b>Właśnie - najważniejsza sprawa - serwer jest pod windowsa!</b>
Nie mam zielonego pojęcia, czy i w jaki sposób będzie działał pod linuxem...

UpDated: malutki bug w kliencie - nazwy zmiennych
UpDated: dodanie "if mod loaded = false"...
Uaktualniłem BBCode do wersji z IPB...
(IMG:http://forum.php.pl/style_emoticons/default/winksmiley.jpg)

[Bakus]

Komentarz na stronie manuala:

Please note that the timeout parameter has important side-effects on the CPU usage of your script.

Setting the timeout to 0 will make your CPU looping without any time to have some rest and handle other running processes on your system, causing the system load to increase heavily while your script is running.

To chyba dyskwalifikuje funkcje dla zadania jakie mam jej powierzyć...