日本語

Concept of messaging system

SINETStream is a messaging system that adopts a topic-based publish/subscribe model. It provides an abstraction layer of Broker, which in turn employs Kafka or MQTT as its backend.

In SINETStream, the publisher is called Writer, and the subscriber is called Reader.

Conceptual diagram of the messaging system

Broker’s configuration and communication parameters are abstracted as “service” in SINETStream. Writers and Readers can communicate with any Broker just by specifying a “service”.

A logical channel in Broker is called a topic. Writers and Readers send/receive a message specifying a topic, allowing different types of messages to be transferred through a Broker.

Directory structure

Operating environment

The SINETStream API supports the following languages.

The SINETStream API supports the following messaging systems.

The operating environment of SINETStream is as follows:

Preparation

SINETStream uses Kafka or MQTT as a backend messaging system of Broker. Therefore, you need to install one of these messaging systems along with SINETStream. The tutorial package utilizes a Docker container to install the required software components, i.e., SINETStream, Kafka, and MQTT.

  1. Kafka broker settings
  2. MQTT broker settings
  3. Installing SINETStream
    • Python: pip3 install --user sinetstream-kafka sinetstream-mqtt
    • Java: Please refer to the Java version of README.

Please Refer to the tutorial using docker container.

License

Apache License, Version 2.0.