MQTT 使用與連結

今天介紹 MQTT 使用與連結實際操作部分，前一篇有介紹了 MQTT 各種特性與特點。

MQTT Broker

MQTT Borker 先介紹一下因為沒有他我們也沒得用。

MQTT 軟體比對表

下表提到的軟體都是市面上較常見的軟體，大家可以挑一些開源的來使用。
我個人偏好 找使用Ｃ或者 Erlang 開發的軟體，一方面因為Ｃ的較輕量化而 Erlang 也是很輕量並且可以做到 Cluster 集群的功能。

MQTT Broker 安裝使用

這邊我們將使用Raspberry Pi 3 Model B作為使用的硬體，當然你也可以用很好的 PC 或者伺服器來使用。
不過會挑選這個作為硬體裝置是有原因因為該裝置已內建無線網路與 Bluetooth 且價格低好入手。

Raspberry Pi 3 Model B

規格

• SoC： Broadcom BCM2837
• CPU： 1.2 GHz 64-bit quad-core ARM Cortex-A53
• GPU： Dual Core VideoCore IV® Multimedia Co-Processor; Open GL ES 2.0; hardware-accelerated OpenVG; 1080p60 H.264 high-profie decode
• 記憶體： 1GB LPDDR2（和 GPU 共享）
• 視訊輸出： Composite RCA; HDMI
• 音訊輸出： 3.5 mm jack; HDMI(1.3 & 1.4)
• 儲存： microSD
• USB： USB 2.0 x 4
• Ethernet： 10/100 RJ45
• Wireless： 802.11n
• Bluetooth： Bluetooth 4.1; Bluetooth Low Energy(BLE)
• GPIO： 40-pin 2.54 mm (100 mil) expansion header: 2×20 strip
• 工作電流： 800 mA
• 尺寸： 85mm x 56mm x 17mm
• 重量： 42g

Broker 軟體準備

一般來說因為硬體關係勢必不能挑選太吃重的軟體，大部分會推薦Mosquitto使用。那我這邊介紹另一套軟體EMQ X來作為今天使用的 Broker。

Docker

這邊請先幫你硬體裝好 Docker。

a. 更新安裝軟體需求套件庫。

sudo apt-get install apt-transport-https ca-certificates software-properties-common -y

b. 下載安裝 Docker.

curl -fsSL get.docker.com -o get-docker.sh && sh get-docker.sh

c. 設定使用者 ‘pi’ 執行 Docker 命令.

sudo usermod -aG docker pi

d. 匯入 Docker CPG key.

sudo curl https://download.docker.com/linux/raspbian/gpg

e. 增加 Docker Repo.

vim /etc/apt/sources.list

加入下面內容

deb https://download.docker.com/linux/raspbian/ stretch stable

f. 更新你的 Pi 系統.

sudo apt-get update
sudo apt-get upgrade

g. 重新登入系統 檢查資訊

pi@ras2:~ $ docker info
Client:
 Debug Mode: false

Server:
 Containers: 0
  Running: 0
  Paused: 0
  Stopped: 0
 Images: 0
 Server Version: 19.03.2
 Storage Driver: overlay2
  Backing Filesystem: extfs
  Supports d_type: true
  Native Overlay Diff: true
 Logging Driver: json-file
 Cgroup Driver: cgroupfs
 Plugins:
  Volume: local
  Network: bridge host ipvlan macvlan null overlay
  Log: awslogs fluentd gcplogs gelf journald json-file local logentries splunk syslog
 Swarm: inactive
 Runtimes: runc
 Default Runtime: runc
 Init Binary: docker-init
 containerd version: 894b81a4b802e4eb2a91d1ce216b8817763c29fb
 runc version: 425e105d5a03fabd737a126ad93d62a9eeede87f
 init version: fec3683
 Security Options:
  seccomp
   Profile: default
 Kernel Version: 4.9.59-v7+
 Operating System: Raspbian GNU/Linux 9 (stretch)
 OSType: linux
 Architecture: armv7l
 CPUs: 4
 Total Memory: 875.8MiB
 Name: ras2
 ID: ZEA6:XS2N:GZZG:W2QU:3CSC:T2CN:YKMC:SDGA:FL6H:YMFG:5YYM:N4TR
 Docker Root Dir: /var/lib/docker
 Debug Mode: false
 Registry: https://index.docker.io/v1/
 Labels:
 Experimental: false
 Insecure Registries:
  127.0.0.0/8
 Live Restore Enabled: false

WARNING: No memory limit support
WARNING: No swap limit support
WARNING: No kernel memory limit support
WARNING: No kernel memory TCP limit support
WARNING: No oom kill disable support
WARNING: No cpu cfs quota support
WARNING: No cpu cfs period support

EMQ X 安裝使用

這邊將以 docker 來直接使用 EMQ X。
EMQ X 官方很貼心的有特別提供 arm32v7 版本正是我們要的。

pi@ras2:~ $ docker run -d --name emqx -p 18083:18083 -p 1883:1883 emqx/emqx:v3.2.3-alpine3.9-arm32v7
Unable to find image 'emqx/emqx:v3.2.3-alpine3.9-arm32v7' locally
v3.2.3-alpine3.9-arm32v7: Pulling from emqx/emqx
856f4240f8db: Pull complete
fb2a25685f00: Pull complete
e740ed46f780: Pull complete
88ea9aa400a1: Pull complete
d4bd4e91ba24: Pull complete
e3f75bba18eb: Pull complete
26b711eb4d74: Pull complete
Digest: sha256:4db689fa5b821625274adbda3b51e66808a01993a3640561c1b3538fc884f420
Status: Downloaded newer image for emqx/emqx:v3.2.3-alpine3.9-arm32v7
479698322a6d71133e2fd3235aa710bae83df8d4726f4f68d85a245516980e0d
pi@ras2:~ $ docker ps
CONTAINER ID        IMAGE                                COMMAND                  CREATED             STATUS              PORTS                                                                                                                          NAMES
479698322a6d        emqx/emqx:v3.2.3-alpine3.9-arm32v7   "/usr/bin/docker-ent…"   58 seconds ago      Up 18 seconds       4369/tcp, 5369/tcp, 6369/tcp, 8080/tcp, 8083-8084/tcp, 8883/tcp, 0.0.0.0:1883->1883/tcp, 0.0.0.0:18083->18083/tcp, 11883/tcp   emqx
pi@ras2:~ $

如果見到上面資訊表示已經在執行了。

EMQX 特點還有提供管理介面可以使用那我們現在就登入系統。

http://你的pi IP:18083/

輸入預設帳密 admin / public

EMQ X 控制面板 看到這個是不是覺得很厲害應有盡有資訊。

MQTT Client 連線

這邊我們用MQTT.fx來做為測試用的 MQTT Client 連線軟體。
MQTT.fx 1.7.1

設定連線 IP 請改成你的 Pi IP。

連線成功

結語

今天介紹MQTT 相關軟體實際使用與介紹，相信很快的大家都可以成為大師。

參考

wikipedia Comparison of MQTT implementations

Blog 同步刊登