[JAVA] Versuchen Sie es mit dem Nachrichtensystem Pulsar

Überblick

Ich habe recherchiert und ein Nachrichtensystem gefunden, also werde ich es versuchen.

Yahoo! OSS-Messagingsystem von inc. https://github.com/yahoo/pulsar Es scheint, dass Hochgeschwindigkeitsnachrichten mithilfe eines residenten Prozesses ausgetauscht werden können.

Was ist Pulsar?

Es ist im Folgenden leicht verständlich organisiert. https://techblog.yahoo.co.jp/infrastructure/pulsar_introduction/

Einzelheiten finden Sie im obigen Artikel.

Mit einem rauen Gefühl

• Nachrichtensystem
• Asynchrone Kommunikation ist möglich
• Die Nachricht ist
• Produzent => Absender der Nachricht
• consumer => Nachrichtenempfänger
• topic => Gruppe, die Nachrichten verwaltet

Wenn der Produzent die Nachricht "schwacher Yen" in den Themennachrichten sendet, erhält der Verbraucher, der sich auf den Empfang der Themennachrichten vorbereitet, die Nachricht "schwacher Yen".

Ich werde es vorerst versuchen

Drops tar.gz Datei (1.15.2 scheint im Moment die neueste zu sein)

$ wget https://github.com/yahoo/pulsar/releases/download/v1.15.2/pulsar-1.15.2-bin.tar.gz

Bitte überprüfen Sie die neueste Version aus dem Folgenden. https://github.com/yahoo/pulsar/releases

Auftauen

$ tar xvfz pulsar-1.15.2-bin.tar.gz

Starten Sie Pulsar im Standalone-Modus.

Pulsar bietet den Standalone-Modus (Broker, BookKeeper, Zookeeper, die alle auf einem Server ausgeführt werden).

$ cd pulsar-1.15.2
$ bin/pulsar standalone

Starten Sie als Nächstes den Consumer-Prozess.

$ bin/pulsar-client consume -s 'sub' 'persistent://sample/standalone/ns1/my-topic'

Als nächstes senden wir eine Nachricht im Produzentenprozess.

$ bin/pulsar-client produce -m 'hello' 'persistent://sample/standalone/ns1/my-topic'

Dann traf die vom Produzenten gesendete Hallo-Nachricht auf der Verbraucherseite ein.

Im GIF unten ist der Bildschirm links der Verbraucher und der Bildschirm rechts der Produzent.

Zusammenfassung

• Ich konnte das Messaging-System problemlos erleben.
• Bisher wird nur Java unterstützt.
• Später werde ich Java anstelle von CLI versuchen.
• Kann das Warteschlangensystem sinnvoll für wichtige Informationen (Zahlungsinformationen usw.) verwendet werden, die nicht gelöscht werden können, da der Aufbau eines asynchronen Systems ein reaktionsfähiger Teil ist?
• Ich möchte mein Verständnis der Unterschiede zu anderen Nachrichtensystemen vertiefen.