socket_write i sockety, sprawdzenie czy wysłany ciąg dotarł do klienta Opcje

[DzikiLis]

Cześć,

Piszę w PHP prosty serwer działający po socketach. Schemat działania jest prosty:
1) klient wysyła ciąg znaków z komendą,
2) serwer odbiera ciąg,
3) serwer "myśli" przez kilkanaście-kilkadziesiąt sekund,
4) serwer wysyła odpowiedź,
5) klient odbiera odpowiedź i zamyka połączenie.

Sęk w tym, że mielenie w punkcie trzecim może trwać dowolnie długo i klient może w międzyczasie zamknąć połączenie, a odpowiedź zostanie wysłana na zamknięty port. Zgodnie z manualem funkcja socket_write() powinna zwrócić false w przypadku, gdy nie doszło do zapisania. Niestety, nigdy nie zwraca false, nawet jeśli klient w międzyczasie przerwie połączenie.

Wymyśliłem obejście z funkcją socket_shutdown, ale to wymusza schemat: jedno połączenie, jedno zapytanie, jedna odpowiedź. Może ktoś ma pomysł co z tym fantem zrobić?

[PHP] pobierz, plaintext 
#!/usr/bin/php -q
<?php
$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($sock, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($sock, '12.34.56.789', 10000);
socket_listen($sock);
$clients = array($sock);
while (true) {
	$read = $clients;
	if (socket_select($read, $write = null, $except = null, 0) < 1) continue;
	if (in_array($sock, $read))
	{
		$clients[] = $newsock = socket_accept($sock);
		socket_getpeername($newsock, $ip);
		echo "New client connected: {$ip}r\n";
		$key = array_search($sock, $read);
		unset($read[$key]);
	}
	foreach ($read as $j => $read_sock)
	{
		$data = @socket_read($read_sock, 1024, PHP_NORMAL_READ);
		if ($data === false) {
			$key = array_search($read_sock, $clients);
			unset($clients[$key]);
			echo "Client disconnected.r\n";
			continue;
		}
		$data = trim($data);
		if (!empty($data))
		{
			if ($data == 'mielenie') sleep(30);
			// i tutaj pojawia się problem, bo socket_write nie zwraca błędu nawet jeśli połączenie zostanie przerwane
			if (@socket_write($read_sock, $data."\n") !== false)
			{
				echo "Sent {$data}r\n";
				// działa natomiast ręczne zamknięcie socketa, ale też nie zawsze (NAT).
				if (@socket_shutdown($read_sock) !== false)
				{
					echo "Shutdown ok {$data}r\n";
				}
				else 
				{
					echo "Shutdown error {$data}r\n";
				}
			}
			else 
			{
				echo "Error {$data}r\n";
			}
		}
	}
}
socket_close($sock);
?>
[PHP] pobierz, plaintext 

Ten post edytował DzikiLis 4.11.2007, 13:22:21