socket_read() im blocking modus

Remon · 01.04.2011, 13:22

Guten Tag liebe PHPler,

ich habe eine kleine MVC Implementation mit integriertem HTTP Server geschrieben. Diese funktioniert soweit. Das Problem besteht darin den Status des Sockets abzufragen. In POST Requests die nicht mit einem identifizierbarem Ende aufhören kann ich so nicht auslesen ohne vorher ihre Bytelänge zu kennen.

Das Script wartet solange bis Daten nach gesendet werden, dies wird aber nicht geschehen.

PHP-Code:

  <?php

 
class Server_Socket {

    private $socket;

    private $response;

    private $request;

    private $disp;

    public $dbs;

    

    public function __construct() {

        $this->socket = socket_create_listen( Server_Config::PORT );

        socket_set_nonblock( $this->socket );

        $this->dbs = new Server_Pool_Database;

        

        Server_Cron::init();

        

        //Alle Crons einrichten

        Server_Cron::add( array( $this->dbs, "check" ), ( 5 * 60 ) );

        Server_Cron::add( "Server_Statistic::createShot", ( 15 * 60 ) );

        Server_Cron::add( "Server_Session::checkSessions", 60 );

        

        if( PHP_OS != 'WINNT' ) {

            

            $fork = new Server_Fork( Server_Config::CHILDS, $this );    

        }

        

        else {

            $this->listen();    

        }

    }

    

    public function listen() {

        $this->response = new Server_Http_Response;

        $this->request = new Server_Http_Request;

        $this->disp = new MVC_Dispatcher;

        

        if( PHP_OS == 'WINNT' ) {

            while( 1 ) {

                Server_Cron::handle( );

 
                while( $conn = @socket_accept( $this->socket ) ) {

                    socket_set_block( $conn );

                    $this->handleRequest( $conn );    

                }

            }

        }

        

        else {

            while( 1 ) {

                while( $conn = @socket_accept( $this->socket ) ) {

                    socket_set_block( $conn );

                    $this->handleRequest( $conn );    

                }

            }

        }

    }

    

    public static function readFromSocket( $conn, $end = array( "\n" => "" ) ) {

        $ret = "";

        

        do {

            $read = socket_read( $conn, 1 );

            $ret .= $read;

        } while( !isset( $end[$read] ) );

        

        return $ret;

    }

    

    private function handleRequest( $conn ) {

        try {

            $start = microtime( true );

            

            $this->request->reset();

            $this->request->newRequest( $conn );

        

            $this->response->reset();

            $this->response->httpCode( 200 );

            

            if( !isset( $this->request->path['extension'] ) || in_array( $this->request->path['extension'], $this->disp->supported() ) ) {

                $this->disp->root( $this->request, $this->response );    

                $this->response->send( $conn );

            }            

            

            elseif( isset( Server_Mime::$mime[$this->request->path['extension']] ) ) {

                $this->response->setHeader( "Content-Type", Server_Mime::$mime[$this->request->path['extension']] );

                $this->response->sendFile( "www/". $this->request->conf['main']['document-root'] ."/static/". $this->request->url['path'], $conn );    

            }

            

            else {

                $this->response->httpCode( 404 );

                $this->response->setContent( 'File not Found!' );

                $this->response->send( $conn );

              }

        }

        

        catch( Server_Http_Exception $e ) {

            $this->response->reset();

            $this->response->httpCode( $e->getCode() );

            $this->response->setContent( $e->getMessage() );    

            $this->response->send( $conn );

        }

    }

}

 
?>

Und zwar geht es hier um die statische funktion readFromSocket die bis zu einem \n ( Zeilenumbruch liest ) und dann aufhört und den gelesenden String zurück gibt. Das Problem ist wie gesagt das beim letzten lesen kein Zeilenumbruch ist und er unendlich ( bzw. timeout ) auf ein weiteres Byte wartet.

lstegelitz · 01.04.2011, 14:31

Du brauchst ein non-blocking socket...

edit: warum ist bei dir \n ein Zeichen dafür, das die Übertragung endet? Auf Stream-Ebene muss jedes Byte durchgehen können, die Contentlänge bestimmt, wieviele Daten gelesen werden müssen.

Remon · 01.04.2011, 20:57

Es gibt zum Beispiel beim Header lesen nach jedem Header einen Zeilenumbruch. Damit ich jeden Header einzelnd lesen kann gibt mir die funktion nur bis zum nächsten Zeilenumbruch den String zurück.

Das mit non block hatte ich auch schon. Das Problem dabei ist das der schreibbuffer nicht schnell genug ist und geschriebende Bytes nicht sendet.

Renner · 04.04.2011, 11:55

RFC2616, 4.4 Message Length ?

lstegelitz · 05.04.2011, 10:49

Zitat:

Zitat von Remon

Das mit non block hatte ich auch schon. Das Problem dabei ist das der schreibbuffer nicht schnell genug ist und geschriebende Bytes nicht sendet.

Dann hast du es vlt. falsch implementiert. Hast du die Hinweise zu socket_write() beachtet?

Zitat:

socket_write() does not necessarily write all bytes from the given buffer. It's valid that, depending on the network buffers etc., only a certain amount of data, even one byte, is written though your buffer is greater. You have to watch out so you don't unintentionally forget to transmit the rest of your data.

Du kannst jedenfalls nicht den gleichen Code verwenden, wie bei sequentiellem Versenden. Non-Blocking heisst, alle Funktionen kehren *sofort* wieder zurück und geben Hinweise darauf, was passieren könnte, wenn die Voraussetzungen nicht erfüllt sind (accept() ohne Clientanfrage liefert z.B. WSAWOULDBLOCK, ein Hinweis darauf, das bei einem blocking-socket dieser blockieren würde um auf einen Client zu warten...)

Das heisst, man muss anders an die Sache rangehen und immer vorher prüfen (peek) was passieren würde. Beim Senden musst du immer noch abfragen, ob auch alle Daten gesendet wurden, die du bereitgestellt hast und eventuell "nachliefern"... asynchrone Operationen verlangen asynchrones Handeln, du musst dann selber machen, was dir im blocking modus der Netzwerktreiber abnimmt (Pufferung von Daten, Häppchenweises Senden o. Empfangen).

Themen-Optionen
Druckbare Version zeigen Jemanden per E-Mail auf dieses Thema hinweisen
Thema bewerten
Thema bewerten:

Ähnliche Themen
Thema	Autor	Forum	Antworten	Letzter Beitrag
[Erledigt] Verständnis non blocking stream	McSodbrenner	PHP-Fortgeschrittene	4	13.03.2011 13:49
[Erledigt] Standardkonformen Modus erzwingen	Dark Guardian	HTML, Usability und Barrierefreiheit	2	10.02.2011 16:48
[Erledigt] IE Quirks Modus und Menu	chunky	HTML, Usability und Barrierefreiheit	9	10.02.2010 16:27
Rausfinden ob Browser im inkognito modus	roest	PHP Tipps 2009	3	29.07.2009 03:14
fopen im Modus "a" und der Dateizeiger	Mati_	PHP-Fortgeschrittene	10	02.07.2009 22:48
[Erledigt] PHP - Modus Statistk	dsmcg	PHP Tipps 2009	11	16.06.2009 20:36
[Erledigt] Voting mit IP blocking		PHP Tipps 2006	8	20.02.2006 23:07
[Erledigt] PHP Safe Modus deaktivieren !		PHP-Fortgeschrittene	8	27.02.2005 14:21
socket / non blocking / socket_accept Problem		PHP Tipps 2004	0	08.06.2004 16:08

01.04.2011, 13:22
Remon Neuer Benutzer Registriert seit: 17.07.2009 Beiträge: 18 PHP-Kenntnisse: Fortgeschritten	socket_read() im blocking modus Guten Tag liebe PHPler, ich habe eine kleine MVC Implementation mit integriertem HTTP Server geschrieben. Diese funktioniert soweit. Das Problem besteht darin den Status des Sockets abzufragen. In POST Requests die nicht mit einem identifizierbarem Ende aufhören kann ich so nicht auslesen ohne vorher ihre Bytelänge zu kennen. Das Script wartet solange bis Daten nach gesendet werden, dies wird aber nicht geschehen. PHP-Code: <?php class Server_Socket { private $socket; private $response; private $request; private $disp; public $dbs; public function __construct() { $this->socket = socket_create_listen( Server_Config::PORT ); socket_set_nonblock( $this->socket ); $this->dbs = new Server_Pool_Database; Server_Cron::init(); //Alle Crons einrichten Server_Cron::add( array( $this->dbs, "check" ), ( 5 * 60 ) ); Server_Cron::add( "Server_Statistic::createShot", ( 15 * 60 ) ); Server_Cron::add( "Server_Session::checkSessions", 60 ); if( PHP_OS != 'WINNT' ) { $fork = new Server_Fork( Server_Config::CHILDS, $this ); } else { $this->listen(); } } public function listen() { $this->response = new Server_Http_Response; $this->request = new Server_Http_Request; $this->disp = new MVC_Dispatcher; if( PHP_OS == 'WINNT' ) { while( 1 ) { Server_Cron::handle( ); while( $conn = @socket_accept( $this->socket ) ) { socket_set_block( $conn ); $this->handleRequest( $conn ); } } } else { while( 1 ) { while( $conn = @socket_accept( $this->socket ) ) { socket_set_block( $conn ); $this->handleRequest( $conn ); } } } } public static function readFromSocket( $conn, $end = array( "\n" => "" ) ) { $ret = ""; do { $read = socket_read( $conn, 1 ); $ret .= $read; } while( !isset( $end[$read] ) ); return $ret; } private function handleRequest( $conn ) { try { $start = microtime( true ); $this->request->reset(); $this->request->newRequest( $conn ); $this->response->reset(); $this->response->httpCode( 200 ); if( !isset( $this->request->path['extension'] ) \|\| in_array( $this->request->path['extension'], $this->disp->supported() ) ) { $this->disp->root( $this->request, $this->response ); $this->response->send( $conn ); } elseif( isset( Server_Mime::$mime[$this->request->path['extension']] ) ) { $this->response->setHeader( "Content-Type", Server_Mime::$mime[$this->request->path['extension']] ); $this->response->sendFile( "www/". $this->request->conf['main']['document-root'] ."/static/". $this->request->url['path'], $conn ); } else { $this->response->httpCode( 404 ); $this->response->setContent( 'File not Found!' ); $this->response->send( $conn ); } } catch( Server_Http_Exception $e ) { $this->response->reset(); $this->response->httpCode( $e->getCode() ); $this->response->setContent( $e->getMessage() ); $this->response->send( $conn ); } } } ?> Und zwar geht es hier um die statische funktion readFromSocket die bis zu einem \n ( Zeilenumbruch liest ) und dann aufhört und den gelesenden String zurück gibt. Das Problem ist wie gesagt das beim letzten lesen kein Zeilenumbruch ist und er unendlich ( bzw. timeout ) auf ein weiteres Byte wartet.


Mister Ad PHP Code Flüsterer Registriert seit: 21.08.2005 Beiträge: 4682 PHP-Kenntnisse: Fortgeschritten

01.04.2011, 14:31
lstegelitz Erfahrener Benutzer Registriert seit: 07.09.2009 Beiträge: 4.005 PHP-Kenntnisse: Fortgeschritten	Du brauchst ein non-blocking socket... edit: warum ist bei dir \n ein Zeichen dafür, das die Übertragung endet? Auf Stream-Ebene muss jedes Byte durchgehen können, die Contentlänge bestimmt, wieviele Daten gelesen werden müssen. __________________ Über 90% aller Gewaltverbrechen passieren innerhalb von 24 Stunden nach dem Konsum von Brot.

01.04.2011, 20:57
Remon Neuer Benutzer Registriert seit: 17.07.2009 Beiträge: 18 PHP-Kenntnisse: Fortgeschritten	Es gibt zum Beispiel beim Header lesen nach jedem Header einen Zeilenumbruch. Damit ich jeden Header einzelnd lesen kann gibt mir die funktion nur bis zum nächsten Zeilenumbruch den String zurück. Das mit non block hatte ich auch schon. Das Problem dabei ist das der schreibbuffer nicht schnell genug ist und geschriebende Bytes nicht sendet.

04.04.2011, 11:55
Renner Benutzer Registriert seit: 25.01.2011 Beiträge: 59 PHP-Kenntnisse: Fortgeschritten	RFC2616, 4.4 Message Length ?