permalink
README.html

English

メッセージングシステムの概念

SINETStreamは トピックベースのPublish/Subscribeモデル のメッセージングシステムである。 Brokerを実現するバックエンドのメッセージングシステムとしてKafkaまたはMQTTを利用している。

SINETStreamではPublisherをWriterと呼び、SubscriberをReaderと呼ぶ。

Brokerの構成情報やBrokerとの通信パラメータをまとめたものをSINETStreamではサービスと呼ぶ。 WriterやReaderはサービスを指定するだけでブローカーに接続してメッセージの送受信ができる。

トピックとはブローカーにおける論理的なチャンネルであり、 Writer/Readerはトピックを指定してメッセージの送受信を行うことで 異なる種類のメッセージ配信を1つのブローカー上で行える。

ファイル構成

• README.md
  • このファイル
• python/
  • README.md
    • Python版SINETStreamのビルド手順
  • src/
    • Python版SINETStreamの共通部分
  • plugins/
    • broker/
      • kafka/
        • Python版SINETStreamのKafka固有部分
      • mqtt/
        • Python版SINETStreamのMQTT固有部分
    • value_type/
      • image/
        • 画像メッセージのサポート
  • sample/
    • サンプルプログラム
• java/
  • README.md
    • Java版SINETStreamのビルド手順
  • api/
    • Java版SINETStreamの共通部分
  • plugin-kafka/
    • Java版SINETStreamのKafka固有部分
  • plugin-mqtt/
    • Java版SINETStreamのMQTT固有部分
  • plugin-type-image/
    • 画像メッセージのサポート
  • sample/
    • サンプルプログラム
• docs/
  • userguide/
    • ユーザガイド
  • tutorial/
    • チュートリアル
  • developer_guide/
    • 開発者ガイド

動作環境

SINETStream API では以下の言語をサポートする。

• Python 3.6
• Java 8

SINETStream では以下のメッセージングシステムをサポートする。

• Apache Kafka 2.2.1
• MQTT v3.1, v3.1.1
  • Eclipse Mosquitto v1.6.2

SINETStreamの動作環境は以下の通り。

• CentOS 7.6
• Windows 10

準備

SINETStreamでは、Brokerを実現するバックエンドのメッセージングシステムとしてKafkaまたはMQTTを利用している。 そのため、SINETStreamとともに、これらのメッセージングシステムのどちらかをインストールする必要がある。 チュートリアルパッケージでは、dockerコンテナを利用して必要なソフトウェア一式（SINETStream, Kafka, MQTT）をインストールする方法を用意している。

1. Kafkaブローカーの設定
   • Kafka Quickstart
2. MQTTブローカーの設定
   • Eclipse Mosquitto: Installing
   • Eclipse Mosquitto: Quick start
3. SINETStreamのインストール
   • Python: pip3 install --user sinetstream-kafka sinetstream-mqtt
   • Java: Java版READMEを参照

dockerコンテナをつかったチュートリアルも参考のこと。

リンク

• チュートリアル
• ユーザガイド
• SINETStream性能測定結果
• プラグイン開発ガイド
• 更新履歴

ライセンス

Apache License, Version 2.0.