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)

[spenalzo]

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ć)

Utwórz sobie pusty plik "busy" i jeżeli jest to znaczy, że serwer jest zajęty.

Hmmm... nie rozumiem po co pisać serwer w php... szczególnie jeżeli jest do przesyłu plików protokół php - ale nie żebym był przeciwny (IMG:http://forum.php.pl/style_emoticons/default/smile.gif)