So implementieren Sie eine lange Verbindung im PHP-Socket

Was ist eine lange Verbindung?

Freunde sollten viele Online-Chat-Tools und Web-Online-Chat-Tools gesehen haben. Es gibt eine bekannte Funktion in der Schule, wenn Ihnen jemand antwortet. Sie haben die Seite zu diesem Zeitpunkt auch nicht aktualisiert. Die Website wird Sie sofort daran erinnern, auch wenn die Webseite noch nie aktualisiert wurde. Apropos, jeder muss damit vertraut sein, nämlich die Wiederverwendung eines Links, um kontinuierlich mit Daten zu interagieren. Heutzutage erfordern viele Internet-Geschäftsszenarien die Unterstützung langer Verbindungen, wie z. B. Spiele, Chats, Informations-Push usw. Viele ähnliche Funktionen sind untrennbar mit langen Verbindungen verbunden. Im vorherigen Kapitel wurde die PHP-Socket-Kommunikation vorgestellt. In diesem Kapitel wird die PHP-Socket-Long-Verbindung vorgestellt.

Lange Verbindungen und kurze Links

Kurze Verbindungen fordern im Allgemeinen Daten von einem einzelnen Element an. Der Server kann die Daten nicht aktiv an den Client „pushen“, sondern mit einer langen Verbindung Verbindung Durch die Kombination von Back-End- und Front-End-Technologien kann die „Push-Information“-Funktion des Servers realisiert werden. Wenn in der Datenbank ein Update vorliegt, kann das Back-End-Programm die Daten sofort „herausschieben“. , anstatt es mehrmals anzufordern. Die Verbindung wird mehrmals hergestellt und getrennt.

Es gibt wahrscheinlich die folgenden Erklärungen:

1. Die sogenannte lange Verbindung bezieht sich auf die Aufrechterhaltung der Verbindung, unabhängig davon, ob sie nach dem Herstellen einer SOCKET-Verbindung verwendet wird oder nicht. aber die Sicherheit ist schlecht; die sogenannte kurze Verbindung bezieht sich auf den Aufbau einer SOCKET-Verbindung und deren Trennung unmittelbar nach dem Senden und Empfangen von Daten. Im Allgemeinen verwenden Banken kurze Verbindungen Aufrechterhaltung der Verbindung bei TCP-basierter Kommunikation, unabhängig davon, ob gerade Daten gesendet oder empfangen werden. Die kurze Verbindung bedeutet, dass die Verbindung nur dann hergestellt wird, wenn eine Datenübertragung stattfindet, und die Verbindung geschlossen wird, nachdem die Client-Server-Kommunikation/Datenübertragung abgeschlossen ist.

2. Kommunikationsmethoden

   Es gibt zwei Verbindungsmethoden zwischen jedem Netzwerkelement: lange Verbindung und kurze Verbindung. Die sogenannte lange Verbindung bedeutet, dass mehrere Datenpakete kontinuierlich über eine TCP-Verbindung gesendet werden können. Wenn während der Aufrechterhaltung der TCP-Verbindung keine Datenpakete gesendet werden, müssen beide Parteien Erkennungspakete senden, um die Verbindung aufrechtzuerhalten. Eine kurze Verbindung bedeutet, dass beim Datenaustausch zwischen den kommunizierenden Parteien eine TCP-Verbindung hergestellt wird. Nach dem Senden der Daten wird die TCP-Verbindung getrennt. Das heißt, jede TCP-Verbindung schließt nur das Senden eines CMPP-Nachrichtenpaars ab.
Zu diesem Zeitpunkt müssen ISMGs langfristige Kommunikationsmethoden verwenden. Es wird empfohlen, langfristige Kommunikationsmethoden zwischen SPs und ISMGs zu verwenden.

3. 
   
   Kurze Verbindung: HTTP stellt beispielsweise nur eine Verbindung her, fordert an und schließt. Die Prozesszeit ist kurz. Wenn der Server die Anfrage nicht innerhalb eines bestimmten Zeitraums erhält, kann er geschlossen werden die Verbindung. Lange Verbindung: Einige Dienste erfordern eine langfristige Verbindung zum Server, wie z. B. CMPP, und erfordern im Allgemeinen eine Online-Wartung durch Sie selbst.

4. Socket-Long-Verbindung implementieren

Jedes Mal, wenn wir auf ein PHP-Skript zugreifen, warten wir, bis alle PHP-Skripte ausgeführt wurden. Holen Sie sich das Rückgabeergebnis. Wenn wir ein Skript zur kontinuierlichen Ausführung benötigen, müssen wir eine lange PHP-Verbindung verwenden, um den Zweck des Betriebs zu erreichen.

Der Beispielcode lautet wie folgt:

Folgendes verbessert die Effizienz:

<?php
$sfd = socket_create(AF_INET, SOCK_STREAM, 0);  
socket_bind($sfd, "0.0.0.0", 1234);  
socket_listen($sfd, 511);  
socket_set_option($sfd, SOL_SOCKET, SO_REUSEADDR, 1);  
socket_set_nonblock($sfd);  
$rfds = array($sfd);  
$wfds = array(); 
 
do{  
    $rs = $rfds;  
    $ws = $wfds;  
    $es = array();  
    $ret = socket_select($rs, $ws, $es, 3);        
    //读取事件 
    foreach($rs as $fd){  
        if($fd == $sfd){ 
           $cfd = socket_accept($sfd);  
           socket_set_nonblock($cfd);  
            $rfds[] = $cfd;  
            echo "new client coming, fd=$cfd\n";  
        }else{  
            $msg = socket_read($fd, 1024); 
 
            if($msg <= 0){  
                //close  
            }else{                 
                echo "on message, fd=$fd data=$msg\n";  
            }  
        }  
    } 
  
    //写入事件 
    foreach($ws as $fd){  
        socket_write($fd, ........);  
    }       
}while(true);
?>

Wenn die Anzahl der Personen zunimmt und die Parallelität zunimmt, kann ein einzelner Prozess die Anforderungen nicht mehr erfüllen. Gibt es vorgefertigte Erweiterungen und Bibliotheken, um dieses Problem zu lösen, z. B. Swoole, Workerman usw.? Wenn wir jedoch PHP zum Entwickeln des Webs verwenden, verwenden wir für die Entwicklung keine Webserver-bezogenen Bibliotheken, oder? Wir sind nur ein einfaches Echo. Diese komplizierten Dinge werden alle an Nginx oder Apache übergeben, und sie übernehmen ohne zu zögern die Führung, sodass wir uns auf das Schreiben von Logik konzentrieren können. Das Schreiben von Socket-Diensten ist nicht weiter fortgeschritten als das Schreiben von Web-Diensten. Die Kommunikationsschicht ist festgelegt, aber eine wird von Nginx und die andere von Ihnen selbst vervollständigt. . Aber jetzt müssen Sie es nicht mehr selbst fertigstellen. Eine Lösung ähnlich wie nginx+fpm, fooking+fpm=php lange Verbindung, Gateway wird zum Übertragen der Verbindung verwendet und Router wird zum Weiterleiten von Nachrichten verwendet.

<?php
$sfd = stream_socket_server (&#39;tcp://0.0.0.0:1234&#39;, $errno, $errstr);  
stream_set_blocking($sfd, 0);  
$base = event_base_new();  
$event = event_new();  
event_set($event, $sfd, EV_READ | EV_PERSIST, &#39;ev_accept&#39;, $base);  
event_base_set($event, $base);  
event_add($event);  
event_base_loop($base); 
 
function ev_accept($socket, $flag, $base)  
{  
    $connection = stream_socket_accept($socket);  
    stream_set_blocking($connection, 0);  
    $buffer = event_buffer_new($connection, &#39;ev_read&#39;, NULL, &#39;ev_error&#39;,  $connection);      
    event_buffer_base_set($buffer, $base);  
    event_buffer_timeout_set($buffer, 30, 30);  
    event_buffer_watermark_set($buffer, EV_READ, 0, 0xffffff);  
    event_buffer_priority_set($buffer, 10);  
    event_buffer_enable($buffer, EV_READ | EV_PERSIST);  
} 
 
function ev_error($buffer, $error, $connection)  
{  
    event_buffer_disable($buffer, EV_READ | EV_WRITE);                  
    event_buffer_free($buffer);                  
    fclose($connection);                  
} 
 
function ev_read($buffer, $connection)  
{  
    $read = event_buffer_read($buffer, 256);  
    //do something....  
}
?>

[Verwandte Tutorials empfohlen]

<?php
$sid = $_SERVER[&#39;SESSIONID&#39;];//这是sessionid  
$data = file_get_contents("php://input");//这样就能拿到请求内容了  
//想要返回消息只需要两步  
header(&#39;Content-Length: 11&#39;);//返回给客户端字节数  
echo "hello world";  
//想要给别的用户发消息  
include &#39;api.php&#39;;  
$router = new RouterClient(&#39;router host&#39;, &#39;router port&#39;);  
$router->sendMsg(用户sessionid, "fuck you");  
//想要给所有人要消息  
$router->sendAllMsg("fuck all");  
//想给指定组发消息(类似redis的pub/sub)  
$router->publish("channel name", "fuck all");
?>

》

2. Eine vollständige Reihe von Tutorials zur PHP-Programmierung vom Einstieg bis zum Master

Das obige ist der detaillierte Inhalt vonSo implementieren Sie eine lange Verbindung im PHP-Socket. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!