はじめに
簡単に今回の経緯。
Go言語の楽しさに目覚めるもIoTへの憧れも捨てきれないので、とりあえずパッケージを探してみました。
好きです。Go言語。
MQTTとは
一部では割と有名なTCP/IPプロトコルの一種です。
よくZigbeeとかと一緒に使われることが多い印象。
軽量かつ省電力なのでIoTと一緒に取り上げられることが多いです。
セキュリティ的に問題が。。。とかまれに耳にしますが、自分はPICで室温とか酸素濃度とか明るさとかを何かしらしてコネコネしたいので、あんまり気にしないことにします。
使用したMQTTのパッケージ
いろいろ見た中で一番実装がシンプルでした。
簡単なSampleもわかりやすく配置してくれていたので、仕事終わりにサクッと試すにはぴったりだと感じました。
実演
サクッと試したかったのでターミナルを９窓立ち上げて使ってみました。
ちなみにサンプルコードはHOSTを指定することもできますが、何も指定しなければLocalhost接続になるのでこのまま進めます。
(スマホだと画像が見辛い！)
まず真ん中の窓でブローカーと呼ばれる中継サーバを立ち上げます。
$ go run ./mqttsrv/main.go
このブローカーに対しサブスクライバーが監視をし続け特定のトピックが更新されればそれを受信するような流れです。
次に、ブローカーを立ち上げている窓以外の下２列でサブスクライブします。
左真ん中から、反時計回りに以下のコマンドを打ちます。
$ go run ./sub/main.go "/house/room/+/brightness" <- + は部分一致（+はワイルドカード）
$ go run ./sub/main.go "/house/room/light1/brightness"
$ go run ./sub/main.go "/house/room/light2/brightness"
$ go run ./sub/main.go "/house/room/light3/brightness"
$ go run ./sub/main.go "/house/room/#" <- # は前方一致（#はワイルドカード）
次にパブリッシュして各センサーノード（のふりをさせたコンソール）からブローカーに向けて値を発行してみます。
go run ./pub/main.go "/house/room/light1/brightness" 555
go run ./pub/main.go "/house/room/light1/temp" 28
go run ./pub/main.go "/house/room/light2/brightness" 777
go run ./pub/main.go "/house/room/light3/brightness" 999
/house/room/の中にあるlight*から何かしらの値が飛んできているようなイメージです。
こうすることで受信側では
- フルパスを指定したサブスクライバーはそれぞれ指定した値のみを
- 部分一致で監視させたサブスクライバーは全てのbrightnessを
- 前方一致で監視させたサブスクライバーは全ての値を
それぞれ受信できているはずです。
では順番にみていきます。
↓部分一致:light1~3のbrightnessの値を正しく受信しています。
↓フルパス:指定したlight1の値を正しく受信しています。
↓フルパス:指定したlight2の値を正しく受信しています。
↓フルパス:指定したlight3の値を正しく受信しています。
↓前方一致:全ての値を取得しています。
思った通りになりました。
これで任意のセンサーノードの値を取ることができますね。
送信側が主導権を握っているので使うところは選びますが、定期的な値を必要とする定点観測などにはあっているんじゃないかなと思います。
結論
ここまで完了するのに
- 調査：１時間
- 実験：0.5時間
- Qiita執筆：1.5時間
くらいの時間配分でした。（筆が遅い）
導入のハードルが低いので「RaspberryPiZeroでお家IoT」とかにはいいんじゃないでしょうか？
自分は社内の酸素濃度と業務効率との相関図とか作りたいなと思っています。
とにかくいろんな人にGo言語を使ってもらいたい。
Goのインストールはここからできます。RaspberryPiにGoをインストールする場合は「ARMv6アーキテクチャ」を選択してください。
github.com/jeffallen/mqtt
上記のパッケージの中の動作には今回は触れませんでしたが、ソースも簡潔に書かれているので読んでみても理解が深まるかもしれません。
追記
動画でやるべきでした。