So implementieren Sie ein Publish-Subscribe-Muster für lange Abfragen mit PHP

In der modernen Webentwicklung ist Echtzeitkommunikation zu einer sehr wichtigen Anforderung geworden, und die Nachrichtenwarteschlange und das Publish-Subscribe-Modell sind zu Standardlösungen für die Realisierung von Echtzeitkommunikation in Webanwendungen geworden. In diesem Artikel stellen wir vor, wie Sie mit PHP den Publish-Subscribe-Modus für lange Abfragen implementieren.

Was ist eine lange Umfrage?

Bei herkömmlichen Webanwendungen sendet der Client eine Anfrage an den Server und der Server gibt unmittelbar nach Erhalt der Anfrage eine Antwort zurück. Long Polling ist eine fortschrittlichere Webanwendungsarchitektur, die es dem Server ermöglicht, nach dem Empfang einer Client-Anfrage eine Zeit lang zu warten, um festzustellen, ob eine neue Nachricht vorliegt. Wenn keine neue Nachricht vorliegt, wird die Verbindung aufrechterhalten, bis eine neue Nachricht vorliegt Neue Nachricht Wenn neue Nachrichten eintreffen, wird eine Antwort an den Client zurückgegeben.

Daher ist die Implementierung langer Abfragen effizienter als der herkömmliche Anforderungsantwortmodus, spart Serverressourcen und entspricht besser den Anforderungen der Echtzeitkommunikation.

Wie implementiert man lange Abfragen mit PHP?

Im Folgenden stellen wir vor, wie Sie PHP und die Nachrichtenwarteschlange verwenden, um lange Abfragen zu implementieren.

1. Message Queue installieren

Bevor wir PHP zur Implementierung langer Abfragen verwenden, müssen wir Message Queue installieren. Zu den derzeit beliebten Nachrichtenwarteschlangen gehören RabbitMQ, ZeroMQ und Beanstalkd. In diesem Artikel verwenden wir Beanstalkd, um Nachrichtenwarteschlangen zu implementieren.

Zuerst müssen wir Beanstalkd herunterladen und installieren. Im Ubuntu-System können Sie zur Installation den folgenden Befehl verwenden:

sudo apt-get install Beanstalkd

Wenn Sie andere Betriebssysteme verwenden, können Sie die entsprechende Version von der offiziellen Beanstalkd-Website herunterladen und installieren.

Nachdem die Installation abgeschlossen ist, können wir den folgenden Befehl verwenden, um Beanstalkd zu starten:

sudo service beanstalkd start

2. PHP-Code schreiben

Im Folgenden zeigen wir anhand eines Beispiels, wie man mit Beanstalkd lange Abfragen implementiert in PHP.

Verbinden Sie zunächst Beanstalkd in der PHP-Datei:

$beanstalk = new Pheanstalk('127.0.0.1');

Dann müssen wir eine Funktion zum Veröffentlichen von Nachrichten definieren:

functionPublish($channel, $message ){

global $beanstalk;
$data = json_encode(array('channel' => $channel, 'message' => $message));
$beanstalk->useTube("pubsub")
          ->put($data, Pheanstalk::DEFAULT_PRIORITY, 0, 10);

}

Die Funktion dieser Funktion besteht darin, die Nachricht an die Pipe mit dem Namen „pubsub“ zu senden. Wir können bei Bedarf Nachrichten an verschiedene Pipes senden.

Dann müssen wir eine Funktion zum Abonnieren von Nachrichten definieren:

function subscribe($channel, $callback){

global $beanstalk;
$beanstalk->watch($channel);
while (true) {
    $job = $beanstalk->reserve();
    if ($job) {
        $data = json_decode($job->getData(), true);
        if ($data['channel'] == $channel) {
            call_user_func($callback, $data['message']);
            $beanstalk->delete($job);
            break;
        } else {
            $beanstalk->bury($job);
        }
    }
}

}

Die Funktion dieser Funktion besteht darin, die angegebene Pipe abzuhören, wenn eine Nachricht eintrifft , führen Sie die Callback-Funktion $ aus und löschen Sie die Nachricht aus der Warteschlange.

Als nächstes müssen wir JavaScript-Code auf der Clientseite verwenden, um lange Abfragen zu implementieren.

3. Client-JavaScript-Code

Im Client müssen wir zwei Funktionen definieren. Eine davon ist eine Funktion zum Senden von Nachrichten und die andere ist eine Funktion zum Empfangen von Nachrichten. Das Folgende ist der Beispielcode:

function Publish(channel, message){

// 发送消息
$.ajax({
    type: 'POST',
    url: 'publish.php',
    data: {channel: channel, message: message},
    success: function(data){}
});

}

function subscribe(channel, callback){

// 接收消息
function poll(){
    $.ajax({
        type: 'GET',
        url: 'subscribe.php',
        data: 'channel=' + channel,
        dataType: 'json',
        success: function(data){
            if (data && data.message){
                callback(data.message);
            }
            poll();
        },
        error: function(){
            setTimeout(poll, 5000);
        }
    });
}
poll();

}

In diesem Beispiel verwenden wir jQuery, um eine POST-Anfrage an zu senden Senden Sie die Nachricht. Verwenden Sie GET-Anfragen, um Nachrichten zu empfangen.

Es ist zu beachten, dass der Client bei langen Abfragen verbunden bleibt, bis eine Antwort eingeht. Damit der Server die Verbindung nicht schließt, wenn er inaktiv ist, müssen wir der Seite den folgenden Code hinzufügen, um Zeitüberschreitungen zu verhindern:

In diesem Beispiel wird die Seite alle 600 Sekunden aktualisiert.

Fazit

Mit PHP und der Nachrichtenwarteschlange können wir das Publish-Subscribe-Modell mit langer Abfrage problemlos implementieren, um Echtzeit-Kommunikationsanforderungen zu erfüllen. Diese Methode wird sehr häufig beim Echtzeit-Datenaustausch und bei der Kommunikation in Webanwendungen verwendet. Sie kann den Einsatz von Abfragen und anderen Methoden zur Beanspruchung der Serverleistung in Anwendungen erheblich reduzieren und die Skalierbarkeit von Webanwendungen verbessern.

Das obige ist der detaillierte Inhalt vonSo implementieren Sie ein Publish-Subscribe-Muster für lange Abfragen mit PHP. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!