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)

[adwol]

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.

Zainteresuj się funkcją socket_select. Nie daje to prawdziwej wielowątkowości (nie są tworzone osobne wątki ani procesy dla każdego requestu), ale pozwala na obsługę wielu połączeń w obrębie jednego procesu. Niestety php w wersji 4 na windows nie ma porządnego wsparcia do tworzenia wątków i procesów (o funkcjach exec i system nie mówimy). Rozszerzenie pctnl w którym jest funkcja pctnl_fork istnieje tylko w wersji uniksowej, więc z niej nie skorzystasz. Będziesz się musiał zadowolić praktyczne chyba tylko selectem.

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

Sockety pochodzą orygnialnie z uniksa (dokładniej z BSD) i uniksy są ich ojczyzną. Jeśli pracuje to prawidłowo na windowsie to na linuksie też nie będzie większych problemów. (IMG:http://forum.php.pl/style_emoticons/default/smile.gif)

Z ogólnych uwag:
:arrow: Masz troche bałaganu w kodzie. Napisałeś to bez użycia chociażby jednej funkcjii, że o klasach nawet nie wspomnę.
:arrow: Ustal sobie najpierw jakiś protokół komunikacji (możesz bazować na HTTP). Wymyśl jak będzie przebiegała transmisja i komunikacja, jakie będą wydawane komendy, itp. Np. niech będą na początek dwie istotne komendy: GET i PUT (znaczenie wiadome). Parametry do tych komend (np. nazwy plików) staraj się dawać w jednej linii z komendą, np.:

Kod

GET plik.txt

Niech serwer odpowiada coś po każdym wysłanym żądaniu od klienta. Linie z odpowiedzią niech będą poprzedzane jakimś kodem statusu operacji. Będzie im wtedy łatwiej się ,,dogadać'' przy bardziej rozbudowanym protokole, reagować na błędy, itp. Np.: (S -- server, K -- klient)

Kod

S: 00 Witamy na naszym serwerze

K: GET /katalog/plik.txt

S: 10 Błąd. Plik /katalog/plik.txt nie istnieje.

K: GET /katalog/plik2.txt

S: 20 572

S: Pierwsza linia pliku

S: Druga linia pliku

S: Trzecia linia pliku

K: PUT /katalog/plik3.txt 1092

K: Pierwsza linia pliku

K: Druga linia pliku

K: Trzecia linia pliku

S: 30 Dziekuje. Odebrano 1092 bajty danych.

K: QUIT

S: 00 Do widzenia

Generalnie przewiduj rozszerzenie protokołu w przyszłości (chyba, że napewno tego nie chcesz) o np. autoryzacje, listowanie zawartości katalogów, itp. Łatwiej jest później dodać jeden nagłówek w żądaniu, niż przerabiać pół protokołu.
:arrow: Po co kodujesz wysyłane pliki za pomocą base64? Niech klient i serwer wysyłają przed początkiem transmisji długość pliku. W przyszłości być może przyda Ci się to do optymalizacji.
:arrow: Zapisz sobie obsługę każdej komendy jako osobną funkcję ze jednym stałym interfejsem do wszystkich. Główna pętla programu niech tylko obsługuje połączenia i rozdziela zadania pomiędzy funkcje

Możesz mieć problemy z efektywnym wykorzystaniem socket_select(), ale na początek spróbuj chociaż uzyskać wiele połączeń naraz (bez jednoczesnego wysyłania danych).

Dobrze, że ktoś się zainteresował innym wykorzystaniem php niż tylko jako język dynamicznych stron WWW, bo dla większości jest on nieodłącznie związany z tym segementem internetu. Niestety nie był on projektowany do takich zastosowań, ale przy odrobinie chęci da się z tego coś sensownego wykrzesać. (IMG:http://forum.php.pl/style_emoticons/default/winksmiley.jpg)