#apache apollo

ひょんなことから Apache Apollo と Node.js で MQTT 経由で pub/sub するかもしれなくなったので、その検証のメモ。

まず、Apache Apollo をインストールする。Homebrew から一発で。

$ brew install apollo

インストールが終わったら Broker というものを作る。

$ `brew --prefix`/Cellar/apollo/1.6/bin/apollo create `brew --prefix`/var/apollo

Broker を作ったら Apollo を起動する。

$ `brew --prefix`/var/apollo/bin/apollo-broker

apollo のコンソールが起動するので run と入力して broker を起動する。

http://localhost:61680/broker から Web のインタフェースが表示できるか確認する。デフォルトの ID は admin, Password は password でログイン出来る。

ここからは Node.js 側の準備。よくメンテナンスされていてドキュメントも豊富なので MQTT.js というライブラリを選択。npm からインストール。

$ npm install mqtt

Subscribe する側のコード。

var mqtt = require('mqtt'); var client = mqtt.createClient(61613, { username: 'admin', password: 'password' }); client.subscribe('message'); client.on('message', function() { console.log(arguments); });

Publish する側のコード。一秒置きに適当なメッセージを送ってみる。

var mqtt = require('mqtt'); var client = mqtt.createClient(61613, { username: 'admin', password: 'password' }); setInterval(function() { client.publish('message'); client.publish('message', 'foo'); client.publish('message', Date.now().toString()); }, 1000);

publish すると subscribe している側でこんなログが出るはず。

{ '0': 'message', '1': '', '2': { cmd: 'publish', retain: false, qos: 0, dup: false, length: 9, topic: 'message', payload: '' } } { '0': 'message', '1': 'foo', '2': { cmd: 'publish', retain: false, qos: 0, dup: false, length: 12, topic: 'message', payload: 'foo' } } { '0': 'message', '1': '1374848125563', '2': { cmd: 'publish', retain: false, qos: 0, dup: false, length: 22, topic: 'message', payload: '1374848125563' } }