Kann Redis als Nachrichtenwarteschlange verwendet werden?

Redis kann nicht nur als Cache-Server, sondern auch als Nachrichtenwarteschlange verwendet werden. Sein Listentyp unterstützt grundsätzlich die Verwendung als Nachrichtenwarteschlange.

Da die Redis-Liste mithilfe einer doppelt verknüpften Liste implementiert wird und die Kopf- und Endknoten gespeichert werden, ist es sehr schwierig, Elemente auf beiden Seiten einzufügen der Liste. (Empfohlenes Lernen: Redis-Video-Tutorial)

So können Sie die Redis-Liste direkt verwenden, um die Nachrichtenwarteschlange zu implementieren, mit nur zwei einfachen Anweisungen: lpush und rpop oder rpush und lpop.

Es gibt jedoch ein Problem mit Nachrichtenkonsumenten, das heißt, sie müssen ständig die rpop-Methode aufrufen, um zu überprüfen, ob ausstehende Nachrichten in der Liste vorhanden sind. Bei jedem Anruf wird eine Verbindung aufgebaut, was unnötige Verschwendung verursacht. Vielleicht werden Sie Thread.sleep() und andere Methoden verwenden, um den Consumer-Thread nach einer gewissen Zeit wieder konsumieren zu lassen, aber dabei gibt es zwei Probleme:

1) Wenn die Geschwindigkeit des Produzenten größer ist als die des Konsumenten Verbrauchsgeschwindigkeit, die Länge der Nachrichtenwarteschlange nimmt weiter zu und belegt mit der Zeit viel Speicherplatz.

2) Wenn die Ruhezeit zu lang ist, können einige zeitkritische Nachrichten nicht verarbeitet werden. Wenn die Ruhezeit zu kurz ist, verursacht dies auch einen relativ großen Overhead auf der Verbindung.

Sie können den Befehl brpop nur verwenden, wenn kein Element vorhanden ist. Anschließend können Sie Customer ausführen und die Konsole löschen Ich kann sehen, dass das Programm keine Ausgabe hat und blockiert ist. Öffnen Sie dann den Redis-Client und geben Sie den Befehl client list ein, um festzustellen, dass derzeit zwei Verbindungen vorhanden sind.

Neben der Unterstützung für Nachrichtenwarteschlangen bietet Redis auch eine Reihe von Befehlen zur Unterstützung des Publish/Subscribe-Modus.

1) Veröffentlichen

Die PUBLISH-Anweisung kann zum Veröffentlichen einer Nachricht verwendet werden, das Format ist PUBLISH-Kanalnachricht

Der Rückgabewert gibt die Nummer an der Abonnenten der Nachricht.

2) Abonnement

Die SUBSCRIBE-Anweisung wird verwendet, um eine Nachricht im Format SUBSCRIBE-Kanal zu empfangen

Sie können sehen, dass der Abonnementmodus nach Verwendung der SUBSCRIBE-Anweisung aufgerufen wurde. Die Veröffentlichungsnachricht wurde jedoch nicht empfangen. Dies liegt daran, dass das Abonnement sie erst erhält, wenn die Nachricht gesendet wird. Für andere Befehle in diesem Modus können nur Antworten angezeigt werden.

Antworten werden in drei Typen unterteilt:

1. Wenn es sich um ein Abonnement handelt, gibt der zweite Wert den abonnierten Kanal an und der dritte Wert gibt an, um welches Abonnement es sich handelt. Kanal? (als Seriennummer verstanden?)

2 Wenn es sich um eine Nachricht handelt, ist der zweite Wert der Kanal, der die Nachricht generiert hat, und der dritte Wert ist die Nachricht

3 Beim Abbestellen stellt der zweite Wert den abgemeldeten Kanal dar und der dritte Wert stellt die aktuelle Anzahl der Client-Abonnements dar.

Mit dem Befehl UNSUBSCRIBE können Sie sich abmelden. Wenn keine Parameter hinzugefügt werden, werden alle Kanäle, die mit dem Befehl SUBSCRIBE abonniert wurden, abgemeldet.

Redis unterstützt auch das Platzhalter-basierte Nachrichtenabonnement mithilfe des Befehls PSUBSCRIBE (Muster-Abonnement).

Sie können sehen, dass der Veröffentlichungsbefehl 2 zurückgibt und der Abonnent die Nachricht zweimal erhalten hat. Dies liegt daran, dass der Befehl PSUBSCRIBE den Kanal wiederholt abonnieren kann. Kanäle, die mit dem Befehl PSUBSCRIBE abonniert wurden, müssen auch mit dem Befehl PUNSUBSCRIBE abgemeldet werden. Mit diesem Befehl können Kanäle, die mit dem Befehl PSUBSCRIBE abonniert wurden, nicht abgemeldet werden. Gleichzeitig werden die Platzhalterzeichen der PUNSUBSCRIBE-Anweisung nicht erweitert.

Zusammenfassung:

Mit der Listendatenstruktur von Redis können Sie einfach und schnell eine Nachrichtenwarteschlange erstellen. Gleichzeitig werden die von Redis bereitgestellten BRPOP- und BLPOP-Anweisungen gelöst das Problem häufiger Aufrufe an Jedis. Ressourcenverschwendung durch Rpop- und Lpop-Methoden. Darüber hinaus stellt Redis Anweisungen für den Publish/Subscribe-Modus bereit, mit denen die Nachrichtenübermittlung und die Kommunikation zwischen Prozessen realisiert werden können.

Weitere technische Artikel zum Thema Redis finden Sie in der Spalte Einführung in das Redis-Datenbanknutzungs-Tutorial, um mehr zu erfahren!

Das obige ist der detaillierte Inhalt vonKann Redis als Nachrichtenwarteschlange verwendet werden?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!