物联网核心协议MQTT快速入门2 安装Mosquitto服务和MQTT.fx订阅

准备

下载地址：http://mosquitto.org/download/

ubuntu 20.04安装Mosquitto服务

$ sudo apt-add-repository ppa:mosquitto-dev/mosquitto-ppa
$ sudo apt-get update
$ sudo apt-get install mosquitto
$ sudo apt-get install mosquitto-clients
● mosquitto.service - Mosquitto MQTT Broker
     Loaded: loaded (/lib/systemd/system/mosquitto.service; enabled; vendor preset: enabled)
     Active: active (running) since Tue 2021-02-02 17:44:19 CST; 14min ago
       Docs: man:mosquitto.conf(5)
             man:mosquitto(8)
    Process: 794 ExecStartPre=/bin/mkdir -m 740 -p /var/log/mosquitto (code=exited, status=0/SUCCESS)
    Process: 800 ExecStartPre=/bin/chown mosquitto: /var/log/mosquitto (code=exited, status=0/SUCCESS)
    Process: 807 ExecStartPre=/bin/mkdir -m 740 -p /var/run/mosquitto (code=exited, status=0/SUCCESS)
    Process: 818 ExecStartPre=/bin/chown mosquitto: /var/run/mosquitto (code=exited, status=0/SUCCESS)
   Main PID: 821 (mosquitto)
      Tasks: 1 (limit: 38201)
     Memory: 2.8M
     CGroup: /system.slice/mosquitto.service
             └─821 /usr/sbin/mosquitto -c /etc/mosquitto/mosquitto.conf

2月 02 17:44:19 andrew-HP-EliteDesk-880-G5-TWR systemd[1]: Starting Mosquitto MQTT Broker...
2月 02 17:44:19 andrew-HP-EliteDesk-880-G5-TWR systemd[1]: Started Mosquitto MQTT Broker.

$ netstat -an | grep 1883
tcp        0      0 127.0.0.1:1883          0.0.0.0:*               LISTEN     
tcp6       0      0 ::1:1883                :::*                    LISTEN

Windows安装Mosquitto服务

下载exe文件，启动服务即可。

安装MQTT.fx

MQTT.fx是一个用JavaFX实现的GUI工具，适用于Windows、Linux和macOS。这个工具可以让我们连接到MQTT服务器，订阅主题过滤器，查看收到的消息和发布消息到主题。你可以从这个工具的主网页的下载部分下载适合你的操作系统的版本：http://www.mqttfx.org 。

• ubuntu 20.04

    sudo apt-add-repository ppa:mosquitto-dev/mosquitto-ppa
    sudo apt-get update

• Windows

安装exe文件即可。

无人机控制实例

无人机(drone)是一种与许多传感器和执行器交互的物联网设备，包括与发动机、螺旋桨和伺服电机相连的数字电子速度控制器。无人机也被称为无名飞行器( UAV Unnamed Aerial Vehicle)。让我们想象一下，我们必须监控许多无人机。具体来说，我们必须显示它们的高度和每个伺服电机的速度。并非所有的无人机都有相同数量的发动机、螺旋桨和伺服电机。

每架无人机将每两秒钟发布一次高度到以下主题：sensor/dronename/altitude ，其中dronename必须用分配给每架无人机的名字来代替。例如，名为drone01的无人机将把它的高度值发布到sensor/drone01/altitude主题，而名为drone20的无人机将使用sensor/drone20/altitude主题。

此外，每架无人机每两秒发布其每个转速到以下主题：sensor/dronename/speed/rotor/rotornumber。

我们将使用 Mosquitto 中包含的 mosquitto_sub 命令行工具来生成一个简单的 MQTT 客户端，该客户端可以订阅主题并显示它收到的所有消息。

$ mosquitto_sub -V mqttv311 -t sensors/drone01/altitude -d
Client (null) sending CONNECT
Client (null) received CONNACK (0)
Client (null) sending SUBSCRIBE (Mid: 1, Topic: sensors/drone01/altitude, QoS: 0, Options: 0x00)
Client (null) received SUBACK
Subscribed (mid: 1): 0

上面创建MQTT客户端，它将与本地MQTT服务器建立连接，订阅主题：sensor/drone01/altitude 。我们用-V mqttv311指定要使用MQTT服务器的MQTT版本3.1.1。-d选项来启用调试消息。

下面使用 MQTT.fx GUI 实用程序生成另一个 MQTT 客户端，该客户端订阅相同的主题，sensor/drone01/altitude ，并显示它收到的所有消息。

MQTT服务器将处理有效的SUBSCRIBE包，它将用一个SUBACK包来响应，表示订阅确认，并确认SUBSCRIBE包的接收和处理。SUBACK包将在包头中包含与SUBSCRIBE包中收到的相同的包标识符(PacketId)。SUBACK包将为SUBSCRIBE包中接收到的主题过滤器和所需的QoS级别的返回码。

返回代码值

0 以最大的QoS为0的方式成功订购。
1 成功申请最大QoS为1的服务。
2 成功申请最大QoS为2的服务。
128 未能订阅