Einführung in das Accept-Blockierungsmodell in der PHP-Netzwerkprogrammierung

Der Inhalt dieses Artikels soll Ihnen eine Einführung in das Accept-Blockierungsmodell in der PHP-Netzwerkprogrammierung geben. Der Inhalt ist sehr detailliert. Ich hoffe, er kann jedem helfen.

Accept-Blocking-Modell ist ein relativ altes Modell, aber es enthält viele interessante Kenntnisse, wie Blockieren/Nicht-Blockieren, Sperren, Timeout-Neuübertragung ...

Dienstende Programm „acceptSever.php“

<?php set_time_limit(0);  # 设置脚本执行时间无限制

class SocketServer 
{
    private static $socket;
    function SocketServer($port) 
    {
        global $errno, $errstr;
        if ($port < 1024) {
            die("Port must be a number which bigger than 1024/n");
        }
        
        $socket = stream_socket_server("tcp://0.0.0.0:{$port}", $errno, $errstr);
        if (!$socket) die("$errstr ($errno)");
        
        
        while ($conn = stream_socket_accept($socket, -1)) { // 这样设置不超时才有用
            static $id = 0; # 进程 id
            static $ct = 0; # 接收数据的长度  
            $ct_last = $ct; 
            $ct_data = &#39;&#39;; # 接受的数据
            $buffer = &#39;&#39;;  # 分段读取数据
        
            $id++; 
            echo "Client $id come" . PHP_EOL;
            
            # 持续监听
            while (!preg_match(&#39;{/r/n}&#39;, $buffer)) { // 没有读到结束符，继续读
//                if (feof($conn)) break; // 防止 popen 和 fread 的 bug 导致的死循环
                $buffer = fread($conn, 1024);
                echo &#39;R&#39; . PHP_EOL; #  打印读的次数
                $ct += strlen($buffer);
                $ct_data .= preg_replace(&#39;{/r/n}&#39;, &#39;&#39;, $buffer);
            }
            $ct_size = ($ct - $ct_last) * 8;
            echo "[$id] " . __METHOD__ . " > " . $ct_data . PHP_EOL;
            fwrite($conn, "Received $ct_size byte data./r/n");
            fclose($conn);
        }
        
        fclose($socket);
    }
}
new SocketServer(2000);

Client-Programm „acceptClient.php“

<?php # 日志记录
function debug ($msg)
{
    error_log($msg, 3, &#39;./socket.log&#39;);
}

if ($argv[1]) {
    
    $socket_client = stream_socket_client(&#39;tcp://0.0.0.0:2000&#39;, $errno, $errstr, 30);
    
    /*    设置脚本为非阻塞    */
#    stream_set_blocking($socket_client, 0);

    /*    设置脚本超时时间    */
#    stream_set_timeout($socket_client, 0, 100000);
    
    if (!$socket_client) {
        die("$errstr ($errno)");
    } else {
        # 填充容器
        $msg = trim($argv[1]);

        for ($i = 0; $i < 10; $i++) {
            $res = fwrite($socket_client, "$msg($i)");
            usleep(100000);
            echo &#39;W&#39;; // 打印写的次数
#            debug(fread($socket_client, 1024)); // 将产生死锁，因为 fread 在阻塞模式下未读到数据时将等待
        }
        fwrite($socket_client, "/r/n"); // 传输结束符
        # 记录日志
        debug(fread($socket_client, 1024));
        fclose($socket_client);
    }
}
else {
    
//    $phArr = array();
//    for ($i = 0; $i < 10; $i++) {
//        $phArr[$i] = popen("php ".__FILE__." &#39;{$i}:test&#39;", &#39;r&#39;);
//    }
//    foreach ($phArr as $ph) {
//        pclose($ph);
//    }
    
    for ($i = 0; $i < 10; $i++) {
        system("php ".__FILE__." &#39;{$i}:test&#39;");    # 这里等于 php "当前文件" "脚本参数"
    }
}

Code-Analyse

Erklären Sie zunächst die obige Codelogik: „Client AcceptClient.php“ sendet Daten in einer Schleife und Senden Sie schließlich den Terminator. Der Server akzeptiert die Blockierungsmethode, um die Socket-Verbindung zu empfangen, und empfängt dann Daten in einer Schleife, bis der Terminator empfangen wird, und gibt die Ergebnisdaten (die Anzahl der empfangenen Bytes) zurück empfängt die vom Server zurückgegebenen Daten und schreibt sie in das Protokoll. Obwohl die Logik sehr einfach ist, gibt es mehrere Situationen, die es wert sind, analysiert zu werden:

A> Für die empfangenen Daten zeichnet socket.log die vom Server zurückgegebenen Empfangsergebnisdaten auf. Der Effekt ist wie folgt:

Diese Situation ist leicht zu verstehen und wird nicht beschrieben wieder. Verwenden Sie dann den Telnet-Befehl, um mehrere Clients gleichzeitig zu öffnen. Sie werden feststellen, dass der Server jeweils nur einen Client verarbeitet, wie in der Abbildung gezeigt:

Andere müssen später in die Warteschlange gestellt werden. "; Dies ist das Merkmal des blockierenden E / A. Die Schwächen dieses Modus sind offensichtlich und die Effizienz ist äußerst gering.

B> Öffnen Sie nur den Kommentarcode in Zeile 29 von socket_client.php und führen Sie php socket_client.php test erneut aus. Der Client gibt ein W aus und der Server gibt auch ein R aus. Danach bleiben beide Programme hängen. Warum ist das so? Nach der Analyse der Logik werden Sie feststellen, dass der Client Daten an den Server zurücksenden möchte, bevor er den Terminator sendet, und weil der Server den Terminator nicht empfangen hat. Verursacht einen Deadlock. Der Grund, warum nur ein W und ein R eingegeben wird, liegt darin, dass fread standardmäßig blockiert. Um diesen Deadlock zu lösen, müssen Sie den Kommentarcode in Zeile 17 von socket_client.php öffnen und einen Timeout für den Socket festlegen. Wenn Sie ihn erneut ausführen, werden Sie feststellen, dass ein W und ein R angezeigt werden alle 0,1 Sekunden und endet dann normal. Die vom Server zurückgegebenen Empfangsergebnisdaten werden ebenfalls normal aufgezeichnet. Es ist ersichtlich, dass Fread standardmäßig blockiert. Wenn das Timeout nicht festgelegt ist, kann es leicht zu einem Deadlock kommen.

C> Öffnen Sie nur 14 Kommentarzeilen, stellen Sie das Skript auf „Nicht blockierend“ ein und führen Sie den php socket_client.php-Test aus. Das Ergebnis ist im Grunde das gleiche wie in Fall A. Der einzige Unterschied besteht darin, dass socket.log Dies liegt daran, dass der Client in unserem nicht blockierenden Modus nicht auf das Antwortergebnis vom Server warten muss, um die Ausführung fortzusetzen. Die gelesenen Daten sind also noch leer .log ist ebenfalls leer. Hier können Sie den Unterschied zwischen dem Client, der im blockierenden und nicht blockierenden Modus läuft, erkennen. Wenn dem Client die Annahme von Ergebnissen nicht wichtig ist, kann natürlich der nicht blockierende Modus verwendet werden, um maximale Effizienz zu erzielen.

D> Beim Ausführen von php socket_client.php wird die obige Logik zehnmal ausgeführt. Das ist jedoch sehr seltsam, wenn Sie 39–45 Zeilen Code verwenden Das gleichzeitige Öffnen von 10 Prozessen führt zu einer Endlosschleife auf der Serverseite, was sehr seltsam ist! Später wurde nach einer Untersuchung festgestellt, dass, solange die durch den mit popen geöffneten Prozess erstellte Verbindung dazu führt, dass fread oder socket_read einen Fehler verursacht und direkt eine leere Zeichenfolge zurückgibt, was zu einer Endlosschleife führt, nachdem der PHP-Quellcode überprüft wurde Ich habe festgestellt, dass die PHP-Funktionen „popen“ und „fread“ überhaupt nicht in C enthalten sind. Es wurde eine große Menge an php_stream_*-Implementierungslogik eingefügt. Es wird zunächst angenommen, dass dies auf die Unterbrechung der Socket-Verbindung zurückzuführen ist. Die Lösung besteht darin, die 33 Codezeilen in socket_server.php zu öffnen, wenn die Verbindung unterbrochen wird, aber auf diese Weise gehen viele Daten verloren, und dieses Problem erfordert besondere Aufmerksamkeit!

Verwandte Empfehlungen:

Grundlegende Anwendungen von PHP und Apache

Was sind reguläre PHP-Ausdrücke? So verwenden Sie reguläre PHP-Ausdrücke (mit Code)

Das obige ist der detaillierte Inhalt vonEinführung in das Accept-Blockierungsmodell in der PHP-Netzwerkprogrammierung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!