Skip to content

Instantly share code, notes, and snippets.

@voluntas

voluntas/mqtt.rst

Last active February 16, 2018 00:03
Show Gist options
  • Save voluntas/8238751 to your computer and use it in GitHub Desktop.
Save voluntas/8238751 to your computer and use it in GitHub Desktop.
Download ZIP

Revisions

  1. voluntas revised this gist May 14, 2014. No changes.
  2. voluntas revised this gist May 14, 2014. No changes.
  3. voluntas revised this gist May 14, 2014. 1 changed file with 2 additions and 2 deletions.
    4 changes: 2 additions & 2 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -2,8 +2,8 @@
    MQTT コトハジメ
    ###############

    :更新: 2014-02-01
    :バージョン: 0.0.11
    :更新: 2014-05-14
    :バージョン: 0.0.12
    :作者: @voluntas
    :URL: http://voluntas.github.io/

  4. voluntas revised this gist May 14, 2014. 1 changed file with 8 additions and 0 deletions.
    8 changes: 8 additions & 0 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -12,6 +12,14 @@ MQTT コトハジメ
    MQTTについてのまとめ
    http://tdoc.info/blog/2014/01/27/mqtt.html

    宣伝
    ====

    時雨堂 MQTT ブローカー開発ログ

    https://gist.github.com/voluntas/558fea1445253e6dc6c2

    **絶賛開発中です!!**

    概要
    ====
  5. voluntas revised this gist Feb 1, 2014. 1 changed file with 8 additions and 3 deletions.
    11 changes: 8 additions & 3 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -267,6 +267,12 @@ etc/rabbitmq_mqtt.config::

    これで RabbitMQ での MQTT の準備は整った。

    Mosquitto
    ---------

    Qiita に Mac OS X で Mosquitto をビルドするサンプルを上げた
    http://qiita.com/voluntas/items/0cb4b1e7b75b3a00cede


    Python
    ------
    @@ -289,9 +295,8 @@ lua
    js
    --

    Qiita に Paho の MQTT Javascript のサンプルを上げました

    http://qiita.com/voluntas/items/e8014a41cd052b3748bb
    Qiita に Paho の MQTT Javascript のサンプルを上げた
    http://qiita.com/voluntas/items/e8014a41cd052b3748bb

    Python
    ======
  6. voluntas revised this gist Feb 1, 2014. 1 changed file with 5 additions and 2 deletions.
    7 changes: 5 additions & 2 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -3,7 +3,7 @@ MQTT コトハジメ
    ###############

    :更新: 2014-02-01
    :バージョン: 0.0.10
    :バージョン: 0.0.11
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -289,8 +289,9 @@ lua
    js
    --

    **後で**
    Qiita に Paho の MQTT Javascript のサンプルを上げました

    http://qiita.com/voluntas/items/e8014a41cd052b3748bb

    Python
    ======
    @@ -324,6 +325,7 @@ pub.py
    mqttc.on_message = on_message
    mqttc.on_connect = on_connect
    mqttc.on_publish = on_publish
    mqttc.connect("192.0.2.100", 1883, 60)
    mqttc.publish("my/topic/string", "hello world", 1)
    @@ -359,6 +361,7 @@ sub.py
    mqttc.on_message = on_message
    mqttc.on_connect = on_connect
    mqttc.on_subscribe = on_subscribe
    mqttc.connect("192.0.2.100", 1883, 60)
    mqttc.subscribe("my/topic/string", 0)
  7. voluntas revised this gist Feb 1, 2014. 1 changed file with 13 additions and 4 deletions.
    17 changes: 13 additions & 4 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -3,7 +3,7 @@ MQTT コトハジメ
    ###############

    :更新: 2014-02-01
    :バージョン: 0.0.9
    :バージョン: 0.0.10
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -431,6 +431,9 @@ HTTPからMQTTへ - IBMが提唱するモノとモノがつながる時代に最
    HiveMQ
    ------

    HiveMQ | Enterprise MQTT Broker
    http://www.hivemq.com/

    MQTT over Websockets with HiveMQ
    http://www.hivemq.com/mqtt-over-websockets-with-hivemq/

    @@ -446,6 +449,9 @@ MQTT V3.1 Protocol Specification
    Python | Mosquitto
    http://mosquitto.org/documentation/python/

    Mosquitto | projects.eclipse.org
    http://projects.eclipse.org/projects/technology.mosquitto

    Building WSN with MQTT, RPi & Arduino
    https://www.erlang-factory.com/upload/presentations/807/ZviMQTTS_for_EUC2013.pdf

    @@ -455,9 +461,6 @@ RabbitMQ - RabbitMQ MQTT Adapter
    Paho - Open Source messaging for M2M
    http://www.eclipse.org/paho/

    HiveMQ | Enterprise MQTT Broker
    http://www.hivemq.com/

    m2m.eclipse.org — Protocols
    http://m2m.eclipse.org/protocols.html

    @@ -503,8 +506,14 @@ MQTT, Eclipse Paho and Java - Messaging for the Internet of Things
    MQTT - REST Bridge using the Smart Object API
    http://www.slideshare.net/michaeljohnkoster/mqtt-rest-bridge?from_search=21

    Embedded Java and MQTT
    http://www.slideshare.net/InfoQ/embedded-java-and-mqtt

    MQTT-SN
    -------

    MQTT For Sensor Networks (MQTT-SN) Protocol Specification
    http://mqtt.org/new/wp-content/uploads/2009/06/MQTT-SN_spec_v1.2.pdf

    Building Wireless Sensor Networks with MQTT-S, RaspberryPi and Erlang
    http://www.slideshare.net/nivertech/zvi-mqtts-foreuc2013
  8. voluntas revised this gist Feb 1, 2014. 1 changed file with 10 additions and 1 deletion.
    11 changes: 10 additions & 1 deletion mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -3,7 +3,7 @@ MQTT コトハジメ
    ###############

    :更新: 2014-02-01
    :バージョン: 0.0.8
    :バージョン: 0.0.9
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -428,6 +428,15 @@ HTTPからMQTTへ - IBMが提唱するモノとモノがつながる時代に最
    大量の情報を安全確実に送受信するアプライアンス製品も用意：日本IBM、モバイル端末向けアプリケーション開発・運用環境の機能向上 - ＠IT
    http://www.atmarkit.co.jp/ait/articles/1306/13/news121.html

    HiveMQ
    ------

    MQTT over Websockets with HiveMQ
    http://www.hivemq.com/mqtt-over-websockets-with-hivemq/

    MQTT Websocket Client
    http://www.hivemq.com/demos/websocket-client/

    MQTT
    ----

  9. voluntas revised this gist Feb 1, 2014. 1 changed file with 36 additions and 11 deletions.
    47 changes: 36 additions & 11 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -2,8 +2,8 @@
    MQTT コトハジメ
    ###############

    :更新: 2014-01-27
    :バージョン: 0.0.7
    :更新: 2014-02-01
    :バージョン: 0.0.8
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -12,6 +12,7 @@ MQTT コトハジメ
    MQTTについてのまとめ
    http://tdoc.info/blog/2014/01/27/mqtt.html


    概要
    ====

    @@ -406,12 +407,12 @@ RabbitMQ MQTT plugin
    参考
    ====

    日本語
    ------

    MQ Telemetry Transport (MQTT) V3.1 プロトコル仕様
    http://www.ibm.com/developerworks/jp/websphere/library/wmq/mqtt31_spec/

    MQTT V3.1 Protocol Specification
    http://public.dhe.ibm.com/software/dw/webservices/ws-mqtt/MQTT_V3.1_Protocol_Specific.pdf

    米IBMらがマシン間通信プロトコル「MQTT」を公開、Eclipseプロジェクト「Paho」を提案 | SourceForge.JP Magazine
    http://sourceforge.jp/magazine/11/11/08/054236

    @@ -421,15 +422,24 @@ MQTT、IBM MessageSightのご紹介 - IBM MessageSight for Developersを使っ
    HTTPからMQTTへ - IBMが提唱するモノとモノがつながる時代に最適化したプロトコル&アプライアンス | IT Leaders
    http://it.impressbm.co.jp/special/2013/12/09/5313

    ニュース - 日本IBM、大量の端末を業務につなぐM2M向けメッセージ中継ゲートウエイ装置を発表：ITpro
    http://itpro.nikkeibp.co.jp/article/NEWS/20130613/484847/

    大量の情報を安全確実に送受信するアプライアンス製品も用意：日本IBM、モバイル端末向けアプリケーション開発・運用環境の機能向上 - ＠IT
    http://www.atmarkit.co.jp/ait/articles/1306/13/news121.html

    MQTT
    ----

    MQTT V3.1 Protocol Specification
    http://public.dhe.ibm.com/software/dw/webservices/ws-mqtt/MQTT_V3.1_Protocol_Specific.pdf

    Python | Mosquitto
    http://mosquitto.org/documentation/python/

    Building WSN with MQTT, RPi & Arduino
    https://www.erlang-factory.com/upload/presentations/807/ZviMQTTS_for_EUC2013.pdf

    ニュース - 日本IBM、大量の端末を業務につなぐM2M向けメッセージ中継ゲートウエイ装置を発表：ITpro
    http://itpro.nikkeibp.co.jp/article/NEWS/20130613/484847/

    RabbitMQ - RabbitMQ MQTT Adapter
    https://www.rabbitmq.com/mqtt.html

    @@ -442,9 +452,6 @@ HiveMQ | Enterprise MQTT Broker
    m2m.eclipse.org — Protocols
    http://m2m.eclipse.org/protocols.html

    大量の情報を安全確実に送受信するアプライアンス製品も用意：日本IBM、モバイル端末向けアプリケーション開発・運用環境の機能向上 - ＠IT
    http://www.atmarkit.co.jp/ait/articles/1306/13/news121.html

    Go vs D vs Erlang vs C in real life: MQTT broker implementation shootout. | Átila on Code
    http://atilanevesoncode.wordpress.com/2013/12/05/go-vs-d-vs-erlang-vs-c-in-real-life-mqtt-broker-implementation-shootout/

    @@ -474,3 +481,21 @@ Messaging for the Internet of Awesome Things

    What a week for MQTT! | The lost outpost
    http://andypiper.co.uk/2011/08/15/what-a-week-for-mqtt/

    MQTT - MQ Telemetry Transport for Message Queueing
    http://www.slideshare.net/PeterREgli/mq-telemetry-transport

    M2M for Java Developers - MQTT with Eclipse Paho
    http://www.slideshare.net/dobermai/m2m-for-java-developers-mqtt-with-eclipse-paho

    MQTT, Eclipse Paho and Java - Messaging for the Internet of Things
    http://www.slideshare.net/andypiper/mqtt-27769811

    MQTT - REST Bridge using the Smart Object API
    http://www.slideshare.net/michaeljohnkoster/mqtt-rest-bridge?from_search=21

    MQTT-SN
    -------

    Building Wireless Sensor Networks with MQTT-S, RaspberryPi and Erlang
    http://www.slideshare.net/nivertech/zvi-mqtts-foreuc2013
  10. voluntas revised this gist Jan 27, 2014. 1 changed file with 7 additions and 2 deletions.
    9 changes: 7 additions & 2 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -2,11 +2,16 @@
    MQTT コトハジメ
    ###############

    :更新: 2014-01-04
    :バージョン: 0.0.6
    :更新: 2014-01-27
    :バージョン: 0.0.7
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    とても詳しいまとめがありますので、ますはそちらを見ることをオススメします。

    MQTTについてのまとめ
    http://tdoc.info/blog/2014/01/27/mqtt.html

    概要
    ====

  11. voluntas revised this gist Jan 4, 2014. 1 changed file with 7 additions and 4 deletions.
    11 changes: 7 additions & 4 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -3,7 +3,7 @@ MQTT コトハジメ
    ###############

    :更新: 2014-01-04
    :バージョン: 0.0.5
    :バージョン: 0.0.6
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -78,10 +78,10 @@ Re: Build up a MQTT server with about 20, 000+ subscribers

    永続化あり、 SSL ありが気になる。

    消費電力
    ========
    省電力
    ======

    MQTT はシンプルなプロトコルなため消費電力が少ないのも魅力だ。
    MQTT はシンプルなプロトコルなため省電力が少ないのも魅力だ。

    stephendnicholas.com » Power Profiling: HTTPS Long Polling vs. MQTT with SSL, on Android
    http://stephendnicholas.com/archives/1217
    @@ -404,6 +404,9 @@ RabbitMQ MQTT plugin
    MQ Telemetry Transport (MQTT) V3.1 プロトコル仕様
    http://www.ibm.com/developerworks/jp/websphere/library/wmq/mqtt31_spec/

    MQTT V3.1 Protocol Specification
    http://public.dhe.ibm.com/software/dw/webservices/ws-mqtt/MQTT_V3.1_Protocol_Specific.pdf

    米IBMらがマシン間通信プロトコル「MQTT」を公開、Eclipseプロジェクト「Paho」を提案 | SourceForge.JP Magazine
    http://sourceforge.jp/magazine/11/11/08/054236

  12. voluntas revised this gist Jan 4, 2014. 1 changed file with 3 additions and 3 deletions.
    6 changes: 3 additions & 3 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -78,10 +78,10 @@ Re: Build up a MQTT server with about 20, 000+ subscribers

    永続化あり、 SSL ありが気になる。

    省電力
    ======
    消費電力
    ========

    MQTT はシンプルなプロトコルなため省電力が少ないのも魅力だ。
    MQTT はシンプルなプロトコルなため消費電力が少ないのも魅力だ。

    stephendnicholas.com » Power Profiling: HTTPS Long Polling vs. MQTT with SSL, on Android
    http://stephendnicholas.com/archives/1217
  13. voluntas revised this gist Jan 4, 2014. 1 changed file with 10 additions and 1 deletion.
    11 changes: 10 additions & 1 deletion mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -3,7 +3,7 @@ MQTT コトハジメ
    ###############

    :更新: 2014-01-04
    :バージョン: 0.0.3
    :バージョン: 0.0.5
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -457,3 +457,12 @@ IBM Redbooks | Building Smarter Planet Solutions with MQTT and IBM WebSphere MQ

    Building Smarter Planet Solutions with MQTT and IBM WebSphere MQ Telemetry
    http://www.redbooks.ibm.com/redbooks/pdfs/sg248054.pdf

    Getting Started with MQTT
    http://wiki.eclipse.org/images/7/7c/MQTTIntroEclipseWebinarv1.pdf

    Messaging for the Internet of Awesome Things
    http://www.slideshare.net/andypiper/lightweightmessaging-oc2011

    What a week for MQTT! | The lost outpost
    http://andypiper.co.uk/2011/08/15/what-a-week-for-mqtt/
  14. voluntas revised this gist Jan 4, 2014. 1 changed file with 13 additions and 2 deletions.
    15 changes: 13 additions & 2 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -3,7 +3,7 @@ MQTT コトハジメ
    ###############

    :更新: 2014-01-04
    :バージョン: 0.0.2
    :バージョン: 0.0.3
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -59,7 +59,12 @@ Facebook Messenger が MQTT を使用している。
    Building Facebook Messenger
    https://www.facebook.com/notes/facebook-engineering/building-facebook-messenger/10150259350998920

    クレジット読んでいたら Message-Pack のライセンスがあったので、もしかすると色々やってるのかもしれない。
    2011 年の時点で 3 億 5000 万の モバイルユーザが MQTT を使っていると Facebook のエンジニアが言っているようだ (以下のスライドの 7 ページ目)

    Low Latency Mobile Messaging using MQTT
    http://www.slideshare.net/henriksjostrand/devmobile-2013-low-latencymessagingusingmqtt

    iOS 版 Facebook Messenger のクレジット読んでいたら Message-Pack のライセンスがあったので、もしかすると色々やってるのかもしれない。

    その他
    ------
    @@ -387,6 +392,12 @@ pub.py::
    my/topic/string 0 hello world


    RabbitMQ MQTT plugin
    ====================

    ソースコードを少し眺めたところ基本的には MQTT to AMQP をしているだけ。


    参考
    ====

  15. voluntas revised this gist Jan 4, 2014. 1 changed file with 66 additions and 3 deletions.
    69 changes: 66 additions & 3 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -2,8 +2,8 @@
    MQTT コトハジメ
    ###############

    :更新: 2014-01-03
    :バージョン: 0.0.1
    :更新: 2014-01-04
    :バージョン: 0.0.2
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -30,10 +30,18 @@ MQTT の導入自体はかなり気軽に出来るような仕組みが作られ

    今回は RabbitMQ を使う事にする、理由はインストール方法をまとめておきたかったから。

    プロトコル
    ==========

    **後で**

    用途
    ====

    主に IBM の MessageSight の導入事例となるが ...
    IBM
    ---

    主に MessageSight の導入事例となるが ...

    - 自動車の座席位置や、ラジオ、カーナビなどをリモート設定するサービス
    - 石油パイプラインのリアルタイム制御
    @@ -43,6 +51,43 @@ MQTT の導入自体はかなり気軽に出来るような仕組みが作られ

    http://it.impressbm.co.jp/special/2013/12/09/5313

    Facebook
    --------

    Facebook Messenger が MQTT を使用している。

    Building Facebook Messenger
    https://www.facebook.com/notes/facebook-engineering/building-facebook-messenger/10150259350998920

    クレジット読んでいたら Message-Pack のライセンスがあったので、もしかすると色々やってるのかもしれない。

    その他
    ------

    mosquitto の ML に 100K コネクションを達成した話が書いてあった。AWS の medium サイズらしい。

    ただ QoS 0 only, no persistence, no SSL/encryption なのでちょっと微妙。

    Re: Build up a MQTT server with about 20, 000+ subscribers
    https://lists.launchpad.net/mosquitto-users/msg00106.html

    永続化あり、 SSL ありが気になる。

    省電力
    ======

    MQTT はシンプルなプロトコルなため省電力が少ないのも魅力だ。

    stephendnicholas.com » Power Profiling: HTTPS Long Polling vs. MQTT with SSL, on Android
    http://stephendnicholas.com/archives/1217

    stephendnicholas.com » Power Profiling: MQTT on Android
    http://stephendnicholas.com/archives/219

    HTTPS vs MQTT with SSL での話がまとめられている。

    HTTPS に比べてかなりバッテリーの消費が抑えられるようだ。

    ゴール
    ======

    @@ -383,3 +428,21 @@ m2m.eclipse.org — Protocols

    Go vs D vs Erlang vs C in real life: MQTT broker implementation shootout. | Átila on Code
    http://atilanevesoncode.wordpress.com/2013/12/05/go-vs-d-vs-erlang-vs-c-in-real-life-mqtt-broker-implementation-shootout/

    Re: Build up a MQTT server with about 20, 000+ subscribers
    https://lists.launchpad.net/mosquitto-users/msg00106.html

    stephendnicholas.com » Power Profiling: HTTPS Long Polling vs. MQTT with SSL, on Android
    http://stephendnicholas.com/archives/1217

    stephendnicholas.com » Power Profiling: MQTT on Android
    http://stephendnicholas.com/archives/219

    Low Latency Mobile Messaging using MQTT
    http://www.slideshare.net/henriksjostrand/devmobile-2013-low-latencymessagingusingmqtt

    IBM Redbooks | Building Smarter Planet Solutions with MQTT and IBM WebSphere MQ Telemetry
    http://www.redbooks.ibm.com/abstracts/sg248054.html

    Building Smarter Planet Solutions with MQTT and IBM WebSphere MQ Telemetry
    http://www.redbooks.ibm.com/redbooks/pdfs/sg248054.pdf
  16. voluntas revised this gist Jan 3, 2014. 1 changed file with 4 additions and 1 deletion.
    5 changes: 4 additions & 1 deletion mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -3,7 +3,7 @@ MQTT コトハジメ
    ###############

    :更新: 2014-01-03
    :バージョン: 0.0.0
    :バージョン: 0.0.1
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    @@ -380,3 +380,6 @@ m2m.eclipse.org — Protocols

    大量の情報を安全確実に送受信するアプライアンス製品も用意：日本IBM、モバイル端末向けアプリケーション開発・運用環境の機能向上 - ＠IT
    http://www.atmarkit.co.jp/ait/articles/1306/13/news121.html

    Go vs D vs Erlang vs C in real life: MQTT broker implementation shootout. | Átila on Code
    http://atilanevesoncode.wordpress.com/2013/12/05/go-vs-d-vs-erlang-vs-c-in-real-life-mqtt-broker-implementation-shootout/
  17. voluntas revised this gist Jan 3, 2014. 1 changed file with 228 additions and 9 deletions.
    237 changes: 228 additions & 9 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -59,6 +59,7 @@ http://it.impressbm.co.jp/special/2013/12/09/5313
    ============

    :ローカル: Mac OS X 10.8.5
    :リモート: Ubuntu 13.10 64bit Server

    - RabbitMQ は Vagrant を使ってとりあえずシングルノードで立てた
    - MQTT クライアントは Python でローカルから触っている
    @@ -75,27 +76,140 @@ aptitude::

    Erlang/OTP R16B03::

    $ curl -O http://download.basho.co.jp.cs-ap-e1.ycloud.jp/otp/download/otp_src_R16B03.tar.gz
    $ wget http://download.basho.co.jp.cs-ap-e1.ycloud.jp/otp/download/otp_src_R16B03.tar.gz
    $ tar xvfz otp_src_R16B03.tar.gz
    $ cd otp_src_R16B03
    $ ./configure --prefix=/opt/erlang/R16B03 --enable-m64-build --enable-smp-support --enable-kernel-poll --disable-sctp --enable-hipe --enable-native-libs --without-javac
    $ make -j4
    $ sudo make install
    $ export PATH=/opt/erlang/R16B03/bin:$PATH

    RabbitMQ
    --------

    起動方法は
    起動確認::

    $ wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.2.2/rabbitmq-server-generic-unix-3.2.2.tar.gz
    $ tar xvfz rabbitmq-server-generic-unix-3.2.2.tar.gz
    $ cd rabbitmq_server-3.2.2/
    $ ./sbin/rabbitmq-server

    RabbitMQ 3.2.2. Copyright (C) 2007-2013 GoPivotal, Inc.
    ## ## Licensed under the MPL. See http://www.rabbitmq.com/
    ## ##
    ########## Logs: ./sbin/../var/log/rabbitmq/[email protected]
    ###### ## ./sbin/../var/log/rabbitmq/[email protected]
    ##########
    Starting broker... completed with 0 plugins.

    一度落として、MQTT plugin を突っ込む

    ::

    $ curl -O http://www.rabbitmq.com/releases/rabbitmq-server/v3.2.2/rabbitmq-server-generic-unix-3.2.2.tar.gz
    $ tar xvfz rabbitmq-server-generic-unix-3.2.2.tar.gz
    $
    $ ./sbin/rabbitmq-plugins enable rabbitmq_mqtt
    The following plugins have been enabled:
    amqp_client
    rabbitmq_mqtt
    Plugin configuration has changed. Restart RabbitMQ for changes to take effect.

    Web UI ベースの管理画面もとりあえず入れておく

    ::

    $ rabbitmq-plugin
    $ ./sbin/rabbitmq-plugins enable rabbitmq_management
    The following plugins have been enabled:
    mochiweb
    webmachine
    rabbitmq_web_dispatch
    rabbitmq_management_agent
    rabbitmq_management
    Plugin configuration has changed. Restart RabbitMQ for changes to take effect.

    再度起動::

    $ ./sbin/rabbitmq-server

    RabbitMQ 3.2.2. Copyright (C) 2007-2013 GoPivotal, Inc.
    ## ## Licensed under the MPL. See http://www.rabbitmq.com/
    ## ##
    ########## Logs: ./sbin/../var/log/rabbitmq/[email protected]
    ###### ## ./sbin/../var/log/rabbitmq/[email protected]
    ##########
    Starting broker... completed with 7 plugins.

    plugin が読み込まれていることを確認する。

    MQTT 用のコンフィグを用意する::

    $ cp etc/rabbitmq.config.example etc/rabbitmq_mqtt.config

    こんな感じでコメントアウトを外して有効にする。backlog だけ 512 にしておいた。

    etc/rabbitmq_mqtt.config::

    {rabbitmq_mqtt,
    [%% Set the default user name and password. Will be used as the default login
    %% if a connecting client provides no other login details.
    %%
    %% Please note that setting this will allow clients to connect without
    %% authenticating!
    %%
    {default_user, <<"guest">>},
    {default_pass, <<"guest">>},

    %% Enable anonymous access. If this is set to false, clients MUST provide
    %% login information in order to connect. See the default_user/default_pass
    %% configuration elements for managing logins without authentication.
    %%
    {allow_anonymous, true},

    %% If you have multiple chosts, specify the one to which the
    %% adapter connects.
    %%
    {vhost, <<"/">>},

    %% Specify the exchange to which messages from MQTT clients are published.
    %%
    {exchange, <<"amq.topic">>},

    %% Specify TTL (time to live) to control the lifetime of non-clean sessions.
    %%
    {subscription_ttl, 1800000},

    %% Set the prefetch count (governing the maximum number of unacknowledged
    %% messages that will be delivered).
    %%
    {prefetch, 10},

    %% TCP/SSL Configuration (as per the broker configuration).
    %%
    {tcp_listeners, [1883]},
    {ssl_listeners, []},

    %% TCP/Socket options (as per the broker configuration).
    %%
    {tcp_listen_options, [binary,
    {packet, raw},
    {reuseaddr, true},
    %% {backlog, 128},
    {backlog, 512},
    {nodelay, true}]}
    ]},


    設定ファイルを有効にして起動する::

    $ ./sbin/rabbitmq-server --config etc/rabbitmq_mqtt.config

    RabbitMQ 3.2.2. Copyright (C) 2007-2013 GoPivotal, Inc.
    ## ## Licensed under the MPL. See http://www.rabbitmq.com/
    ## ##
    ########## Logs: ./sbin/../var/log/rabbitmq/[email protected]
    ###### ## ./sbin/../var/log/rabbitmq/[email protected]
    ##########
    Starting broker... completed with 7 plugins.

    これで RabbitMQ での MQTT の準備は整った。


    Python
    @@ -105,7 +219,7 @@ Python

    - paho-mqtt

    今回は mosquitto ではなく paho を使う事にする。理由としては lua も同じ paho が提供しているからだ。
    今回は mosquitto ではなく paho を使う事にする。理由としては lua も js 同じ paho が提供しているから、単に統一感で。

    ::

    @@ -114,13 +228,118 @@ Python
    lua
    ---

    **ローカル**
    **後で**

    js
    --

    **ローカル**
    **後で**


    Python
    ======

    - IP アドレスは書き換えること。

    pub.py
    ------

    .. code-block:: python
    # coding=utf8
    import paho.mqtt.client as paho
    def on_connect(mqttc, obj, rc):
    mqttc.subscribe("$SYS/#", 0)
    print("rc: "+str(rc))
    def on_message(mqttc, obj, msg):
    print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))
    def on_publish(mqttc, obj, mid):
    print("mid: "+str(mid))
    def on_log(mqttc, obj, level, string):
    print(string)
    if __name__ == '__main__':
    mqttc = paho.Client()
    mqttc.on_message = on_message
    mqttc.on_connect = on_connect
    mqttc.on_publish = on_publish
    mqttc.connect("192.0.2.100", 1883, 60)
    mqttc.publish("my/topic/string", "hello world", 1)
    sub.py
    ------

    .. code-block:: python
    # coding=utf8
    import paho.mqtt.client as paho
    def on_connect(mqttc, obj, rc):
    mqttc.subscribe("$SYS/#", 0)
    print("rc: "+str(rc))
    def on_message(mqttc, obj, msg):
    print(msg.topic+" "+str(msg.qos)+" "+str(msg.payload))
    def on_publish(mqttc, obj, mid):
    print("mid: "+str(mid))
    def on_subscribe(mqttc, obj, mid, granted_qos):
    print("Subscribed: "+str(mid)+" "+str(granted_qos))
    def on_log(mqttc, obj, level, string):
    print(string)
    if __name__ == '__main__':
    mqttc = paho.Client()
    mqttc.on_message = on_message
    mqttc.on_connect = on_connect
    mqttc.on_subscribe = on_subscribe
    mqttc.connect("192.0.2.100", 1883, 60)
    mqttc.subscribe("my/topic/string", 0)
    mqttc.loop_forever()
    実行
    ----

    sub.py を複数実行して見る。

    sub.py (1)::

    $ python sub.py
    rc: 0
    Subscribed: 1 (0,)
    Subscribed: 2 (0,)


    sub.py (2)::

    $ python sub.py
    rc: 0
    Subscribed: 1 (0,)
    Subscribed: 2 (0,)

    pub.py::

    $ python pub.py

    実行した結果 ... 両方の sub.py に以下のメッセージが出力されれば成功です。


    ::

    my/topic/string 0 hello world


    参考
  18. voluntas revised this gist Jan 3, 2014. 1 changed file with 1 addition and 1 deletion.
    2 changes: 1 addition & 1 deletion mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -39,7 +39,7 @@ MQTT の導入自体はかなり気軽に出来るような仕組みが作られ
    - 石油パイプラインのリアルタイム制御
    - 病院におけるペースメーカー管理

    出典は以下の URL から引っ張り出した
    以下の URL から引っ張り出してみた

    http://it.impressbm.co.jp/special/2013/12/09/5313

  19. voluntas revised this gist Jan 3, 2014. 1 changed file with 18 additions and 4 deletions.
    22 changes: 18 additions & 4 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -22,15 +22,26 @@ MQTT はざっくり言うと以下のようなプロトコルである。
    - 機器にメッセージを配信する
    - 機器がメッセージを配信する

    ブローカーサーバは商用がほとんどなので、OSS なものを使うとなると Mosquitto か RabbitMQ を使う事になる。
    ブローカーサーバは商用がほとんどのため、OSS なものを使うとなると Mosquitto か RabbitMQ を使う事になる。

    クライアントは Paho が C / C++ / Java / JavaScript / Lua / Python と様々な言語のクライアントを用意してくれている。

    また Mosquitto もコマンドから使える mosquitto_sub と mosquitto_pub を用意してくれているため、気軽に MQTT を試すことが可能となる。
    MQTT の導入自体はかなり気軽に出来るような仕組みが作られていると感じた。

    導入自体はかなり気軽に出来るような仕組みが作られていると感じた。
    今回は RabbitMQ を使う事にする、理由はインストール方法をまとめておきたかったから。

    今回は RabbitMQ を使う事にする。よく使われる MQ であるため、導入障壁も低いためだ。
    用途
    ====

    主に IBM の MessageSight の導入事例となるが ...

    - 自動車の座席位置や、ラジオ、カーナビなどをリモート設定するサービス
    - 石油パイプラインのリアルタイム制御
    - 病院におけるペースメーカー管理

    出典は以下の URL から引っ張り出した

    http://it.impressbm.co.jp/special/2013/12/09/5313

    ゴール
    ======
    @@ -147,3 +158,6 @@ HiveMQ | Enterprise MQTT Broker

    m2m.eclipse.org — Protocols
    http://m2m.eclipse.org/protocols.html

    大量の情報を安全確実に送受信するアプライアンス製品も用意：日本IBM、モバイル端末向けアプリケーション開発・運用環境の機能向上 - ＠IT
    http://www.atmarkit.co.jp/ait/articles/1306/13/news121.html
  20. voluntas revised this gist Jan 3, 2014. 1 changed file with 2 additions and 3 deletions.
    5 changes: 2 additions & 3 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -10,10 +10,10 @@ MQTT コトハジメ
    概要
    ====

    MQTT という M2M 向けの軽量な MQ プロトコルがあるらしいので、とりあえず触ってみる。
    MQTT はざっくり言うと以下のようなプロトコルである。

    - TCP/IP ベースの軽量な PUB/SUB 型 MQ
    - M2M 向けのプロトコル
    - IBM が主導
    - プロトコルはロイヤリティー・フリー

    @@ -22,7 +22,7 @@ MQTT はざっくり言うと以下のようなプロトコルである。
    - 機器にメッセージを配信する
    - 機器がメッセージを配信する

    サーバ自体は商用がほとんどなので、OSS なものを使うとなると Mosquitto か RabbitMQ を使う事になる。
    ブローカーサーバは商用がほとんどなので、OSS なものを使うとなると Mosquitto か RabbitMQ を使う事になる。

    クライアントは Paho が C / C++ / Java / JavaScript / Lua / Python と様々な言語のクライアントを用意してくれている。

    @@ -71,7 +71,6 @@ Erlang/OTP R16B03::
    $ make -j4
    $ sudo make install


    RabbitMQ
    --------

  21. voluntas revised this gist Jan 3, 2014. 1 changed file with 48 additions and 35 deletions.
    83 changes: 48 additions & 35 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -11,16 +11,36 @@ MQTT コトハジメ
    ====

    MQTT という M2M 向けの軽量な MQ プロトコルがあるらしいので、とりあえず触ってみる。
    MQTT はざっくり言うと以下のようなプロトコルである。

    MQTT
    ====
    - TCP/IP ベースの軽量な PUB/SUB 型 MQ
    - IBM が主導
    - プロトコルはロイヤリティー・フリー

    主に以下の二つの用意とで使う事になる

    - 機器にメッセージを配信する
    - 機器がメッセージを配信する

    サーバ自体は商用がほとんどなので、OSS なものを使うとなると Mosquitto か RabbitMQ を使う事になる。

    クライアントは Paho が C / C++ / Java / JavaScript / Lua / Python と様々な言語のクライアントを用意してくれている。

    また Mosquitto もコマンドから使える mosquitto_sub と mosquitto_pub を用意してくれているため、気軽に MQTT を試すことが可能となる。

    導入自体はかなり気軽に出来るような仕組みが作られていると感じた。

    今回は RabbitMQ を使う事にする。よく使われる MQ であるため、導入障壁も低いためだ。

    ゴール
    ======

    **今回は Mosquitto はクライアントとしてしか使わない**

    - RabbitMQ で MQTT を使って見る
    - Python で MQTT を使って見る
    - Lua で MQTT を使って見る
    - Mosquitto で MQTT を使って見る
    - CentOS と Ubuntu の RabbitMQ のインストール方法を残す
    - MQTT 関連記事のリンクを残す

    @@ -29,43 +49,13 @@ MQTT

    :ローカル: Mac OS X 10.8.5

    - RabbitMQ は Vagrant を使ってとりあえずシングルノードで立てました
    - MQTT クライアントは Python でローカルから触っています
    - RabbitMQ は Vagrant を使ってとりあえずシングルノードで立てた
    - MQTT クライアントは Python でローカルから触っている

    Erlang/OTP
    ----------

    Erlang/OTP 関連のアプリを扱う場合は Ubuntu がオススメなので Ubuntu を使うようにしましょう。

    CentOS 6.5 64 bit
    ^^^^^^^^^^^^^^^^^

    CentOS 6.5 に最初から入っている OpenSSL だと色々問題があって crypto モジュールが使えないため OpenSSL を独自で入れる。

    yum::

    $ sudo yum install gcc make ncurses-devel

    OpenSSL 1.0.1e::

    $ curl -O http://www.openssl.org/source/openssl-1.0.1e.tar.gz
    $ tar xvfz openssl-1.0.1e.tar.gz
    $ cd openssl-1.0.1e
    $ ./config --prefix=/opt/openssl/1.0.1e shared
    $ make
    $ sudo make install

    Erlang/OTP R16B03::

    $ curl -O http://download.basho.co.jp.cs-ap-e1.ycloud.jp/otp/download/otp_src_R16B03.tar.gz
    $ tar xvfz otp_src_R16B03.tar.gz
    $ cd otp_src_R16B03
    $ ./configure --prefix=/opt/erlang/R16B03 --enable-m64-build --enable-smp-support --enable-kernel-poll --disable-sctp --enable-hipe --enable-native-libs --without-javac --with-ssl=/opt/openssl/1.0.1e
    $ make -j4
    $ sudo make install

    Ubuntu 13.04 64 bit
    ^^^^^^^^^^^^^^^^^^^
    Erlang/OTP 関連のアプリを扱う場合は Ubuntu がオススメなので Ubuntu を使うようにする

    aptitude::

    @@ -103,11 +93,25 @@ Python

    **ローカル**

    - paho-mqtt

    今回は mosquitto ではなく paho を使う事にする。理由としては lua も同じ paho が提供しているからだ。

    ::

    $ pip install paho-mqtt

    lua
    ---

    **ローカル**

    js
    --

    **ローカル**



    参考
    ====
    @@ -135,3 +139,12 @@ Building WSN with MQTT, RPi & Arduino

    RabbitMQ - RabbitMQ MQTT Adapter
    https://www.rabbitmq.com/mqtt.html

    Paho - Open Source messaging for M2M
    http://www.eclipse.org/paho/

    HiveMQ | Enterprise MQTT Broker
    http://www.hivemq.com/

    m2m.eclipse.org — Protocols
    http://m2m.eclipse.org/protocols.html
  22. voluntas created this gist Jan 3, 2014.
    137 changes: 137 additions & 0 deletions mqtt.rst
    View file
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,137 @@
    ###############
    MQTT コトハジメ
    ###############

    :更新: 2014-01-03
    :バージョン: 0.0.0
    :作者: @voluntas
    :URL: http://voluntas.github.io/

    概要
    ====

    MQTT という M2M 向けの軽量な MQ プロトコルがあるらしいので、とりあえず触ってみる。

    MQTT
    ====

    ゴール
    ======

    - RabbitMQ で MQTT を使って見る
    - Python で MQTT を使って見る
    - Lua で MQTT を使って見る
    - CentOS と Ubuntu の RabbitMQ のインストール方法を残す
    - MQTT 関連記事のリンクを残す

    セットアップ
    ============

    :ローカル: Mac OS X 10.8.5

    - RabbitMQ は Vagrant を使ってとりあえずシングルノードで立てました
    - MQTT クライアントは Python でローカルから触っています

    Erlang/OTP
    ----------

    Erlang/OTP 関連のアプリを扱う場合は Ubuntu がオススメなので Ubuntu を使うようにしましょう。

    CentOS 6.5 64 bit
    ^^^^^^^^^^^^^^^^^

    CentOS 6.5 に最初から入っている OpenSSL だと色々問題があって crypto モジュールが使えないため OpenSSL を独自で入れる。

    yum::

    $ sudo yum install gcc make ncurses-devel

    OpenSSL 1.0.1e::

    $ curl -O http://www.openssl.org/source/openssl-1.0.1e.tar.gz
    $ tar xvfz openssl-1.0.1e.tar.gz
    $ cd openssl-1.0.1e
    $ ./config --prefix=/opt/openssl/1.0.1e shared
    $ make
    $ sudo make install

    Erlang/OTP R16B03::

    $ curl -O http://download.basho.co.jp.cs-ap-e1.ycloud.jp/otp/download/otp_src_R16B03.tar.gz
    $ tar xvfz otp_src_R16B03.tar.gz
    $ cd otp_src_R16B03
    $ ./configure --prefix=/opt/erlang/R16B03 --enable-m64-build --enable-smp-support --enable-kernel-poll --disable-sctp --enable-hipe --enable-native-libs --without-javac --with-ssl=/opt/openssl/1.0.1e
    $ make -j4
    $ sudo make install

    Ubuntu 13.04 64 bit
    ^^^^^^^^^^^^^^^^^^^

    aptitude::

    $ sudo aptitude install gcc g++ make libssl-dev libncurses5-dev


    Erlang/OTP R16B03::

    $ curl -O http://download.basho.co.jp.cs-ap-e1.ycloud.jp/otp/download/otp_src_R16B03.tar.gz
    $ tar xvfz otp_src_R16B03.tar.gz
    $ cd otp_src_R16B03
    $ ./configure --prefix=/opt/erlang/R16B03 --enable-m64-build --enable-smp-support --enable-kernel-poll --disable-sctp --enable-hipe --enable-native-libs --without-javac
    $ make -j4
    $ sudo make install


    RabbitMQ
    --------

    起動方法は

    ::

    $ curl -O http://www.rabbitmq.com/releases/rabbitmq-server/v3.2.2/rabbitmq-server-generic-unix-3.2.2.tar.gz
    $ tar xvfz rabbitmq-server-generic-unix-3.2.2.tar.gz
    $

    ::

    $ rabbitmq-plugin


    Python
    ------

    **ローカル**

    lua
    ---

    **ローカル**


    参考
    ====

    MQ Telemetry Transport (MQTT) V3.1 プロトコル仕様
    http://www.ibm.com/developerworks/jp/websphere/library/wmq/mqtt31_spec/

    米IBMらがマシン間通信プロトコル「MQTT」を公開、Eclipseプロジェクト「Paho」を提案 | SourceForge.JP Magazine
    http://sourceforge.jp/magazine/11/11/08/054236

    MQTT、IBM MessageSightのご紹介 - IBM MessageSight for Developersを使ってMQTTを体験する
    http://www.ibm.com/developerworks/jp/websphere/library/connectivity/ms_mqttintro/

    HTTPからMQTTへ - IBMが提唱するモノとモノがつながる時代に最適化したプロトコル&アプライアンス | IT Leaders
    http://it.impressbm.co.jp/special/2013/12/09/5313

    Python | Mosquitto
    http://mosquitto.org/documentation/python/

    Building WSN with MQTT, RPi & Arduino
    https://www.erlang-factory.com/upload/presentations/807/ZviMQTTS_for_EUC2013.pdf

    ニュース - 日本IBM、大量の端末を業務につなぐM2M向けメッセージ中継ゲートウエイ装置を発表：ITpro
    http://itpro.nikkeibp.co.jp/article/NEWS/20130613/484847/

    RabbitMQ - RabbitMQ MQTT Adapter
    https://www.rabbitmq.com/mqtt.html