Ein Nachrichtenwarteschlangenmodell in Erlang (Comet Chat)?

Question

Ich mache Comet Chat mit Erlang. Ich verwende nur eine Verbindung (Long-Polling) für den Nachrichtentransport. Aber wie Sie wissen, kann die Verbindung für lange Abfragen nicht ständig verbunden bleiben. Jedes Mal, wenn eine neue Nachricht ankommt oder das Zeitlimit erreicht, wird sie unterbrochen und dann erneut mit dem Server verbunden. Wenn eine Nachricht gesendet wird, bevor die Verbindung wieder hergestellt wird, ist es ein Problem, die Integrität des Chats beizubehalten.

Und auch, wenn ein Benutzer mehr als ein Fenster mit Comet-Chat öffnet, müssen alle Chat-Nachrichten synchronisiert werden, was bedeutet, dass ein Benutzer viele Long-Polling-Verbindungen haben kann. Daher ist es schwierig, jede Nachricht pünktlich zu erhalten.

Sollte ich eine Nachrichtenwarteschlange für jede Verbindung erstellen? Oder was könnte man sonst noch besser lösen?

Answer 1

Für mich scheint der einfachste Weg, eine Prozess/Nachrichtenwarteschlange pro Benutzer mit dem Chat verbunden zu haben (sogar mehr als ein Chat-Fenster haben). Dann verfolgen Sie den Zeitstempel der letzten Nachricht in der Chatfenster-Anwendung und fragen Sie nach dem Zeitstempel nach Nachrichten. Message Queue Prozess sollte Nachrichten nur für eine angemessene Zeitspanne halten. In diesem Szenario ist die Verbindung zum Client vollständig. In einem anderen Szenario können Sie einige harte Beats vom Server senden, aber es scheint weniger zuverlässig für mich. Es löst das Problem nicht aus anderen Grund der Trennung als Timeout. Es gibt viele Varianten serverseitiger Warteschlangen als eine Warteschlange pro Client, pro Benutzer, pro Chatroom, pro ...