[JAVA] Essayez d'utiliser le système de messagerie Pulsar

Aperçu

J'étais en train de faire des recherches et j'ai trouvé un système de messagerie, alors je vais essayer.

Yahoo! Système de messagerie OSS fourni par inc. https://github.com/yahoo/pulsar Il semble que la messagerie haute vitesse puisse être échangée à l'aide d'un processus résident.

Qu'est-ce que Pulsar

Il est organisé d'une manière facile à comprendre ci-dessous. https://techblog.yahoo.co.jp/infrastructure/pulsar_introduction/

Pour plus de détails, veuillez consulter l'article ci-dessus.

Avec un sentiment rugueux

• Système de messagerie
• Une communication asynchrone est possible
• Le message est
• producteur => expéditeur du message
• consumer => Destinataire du message
• topic => Groupe qui gère les messages

Lorsque le producteur envoie le message «yen faible» sur l'actualité du sujet, le consommateur qui s'apprête à recevoir les actualités du sujet reçoit le message «yen faible».

Je vais essayer de l'utiliser pour le moment

Supprime le fichier tar.gz (la 1.15.2 semble être la dernière en ce moment)

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

Veuillez vérifier la dernière version de ce qui suit. https://github.com/yahoo/pulsar/releases

Dégivrer

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

Lancez pulsar en mode autonome.

Pulsar fournit le mode autonome (Broker, BookKeeper, Zookeeper fonctionnent tous sur un serveur).

$ cd pulsar-1.15.2
$ bin/pulsar standalone

Ensuite, lancez le processus consommateur.

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

Ensuite, envoyons un message dans le processus producteur.

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

Ensuite, le message bonjour envoyé par le producteur est arrivé du côté du consommateur.

Dans le gif ci-dessous, l'écran de gauche est le consommateur et l'écran de droite est le producteur.

Résumé

• J'ai pu facilement découvrir le système de messagerie.
• Seul Java est encore pris en charge.
• Plus tard, j'essaierai Java au lieu de CLI.
• La construction d'un système asynchrone étant une partie réactive, le système de mise en file d'attente peut-il être utilement utilisé pour des informations importantes (informations de paiement, etc.) qui ne peuvent pas être supprimées?
• Je souhaite approfondir ma compréhension des différences avec les autres systèmes de messagerie.