Message Pipe verteilte Nachrichten-Sequential-Consuming-Pipeline v1.0.6

Message Pipe ist eine auf Redis implementierte sequentielle Nachrichtenpipeline. Da die verteilte Redisson-Sperre intern eingeführt wird, ist sie threadsicher. In Multithread-Situationen erfolgt der Verbrauch auch in der in die Pipeline geschriebenen Reihenfolge.

Message Pipe basiert auf den Konzepten von Client und Server. Intern wird grpc-netty verwendet, um lange Verbindungen für die Kommunikation zwischen Nachrichtenkanälen herzustellen. Der Server ist für die Verteilung von Nachrichten verantwortlich, und die Nachrichten werden in jeder Pipeline verteilt über LoadBalance (Lastausgleich) Methode zum Abrufen von Online-Client-Informationen und zum sequentiellen Senden von Nachrichten an den Client.

Merkmal

Automatische Registrierung

Herzschlagprüfung

Nachrichtenverteilung

Sequentielle Konsum

Lese- und Schreibtrennung

Thread-Sicherheit

Lastausgleich

Automatisches Aussortieren