Overview

I've been researching and finding a messaging system, so I'll give it a try.

Yahoo! OSS messaging system provided by inc. https://github.com/yahoo/pulsar It seems that high-speed messaging can be exchanged using a resident process.

What is Pulsar

It is organized in an easy-to-understand manner below. https://techblog.yahoo.co.jp/infrastructure/pulsar_introduction/

For details, please see the above article.

With a rough feeling

Messaging system
Asynchronous communication is possible
The message is
producer => Message sender
consumer => Message recipient
topic => Group that manages messages

When the producer sends the message "weak yen" on the topic news, the consumer who is preparing to receive the topic news receives the "weak yen" message.

I will try using it for the time being

Drops the tar.gz file (1.15.2 seems to be the latest at the moment)

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

Please check the latest version from the following. https://github.com/yahoo/pulsar/releases

Defrost

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

Launch pulsar in standalone mode.

Pulsar provides Standalone (Broker, BookKeeper, Zookeeper all run on one server) mode.

$ cd pulsar-1.15.2
$ bin/pulsar standalone

Next, launch the consumer process.

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

Next, let's send a message in the producer process.

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

Then, the message hello sent from the producer arrived at the consumer side.

In the gif below, the screen on the left is the consumer and the screen on the right is the producer.

Summary

I was able to easily experience the messaging system.
Only Java is supported yet.
Later I will try Java instead of CLI.
Asynchronous system construction is a responsive part, and the queuing system can be usefully used for important information (payment information, etc.) that cannot be dropped?
I want to deepen my understanding of the differences with other messaging systems.

Recommended Posts

Try using the messaging system Pulsar

Try using || instead of the ternary operator

Try using the service on Android Oreo

Try using the Rails API (zip code)

Try using the Emotion API from Android

Try using the Wii remote with Java

Try using the messaging system Pulsar

Implement the box ball system with Processing

Try using Maven

Try using powermock-mockito2-2.0.2

Try using GraalVM