简介
MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,它比较适合于在低带宽、不可靠的网络的进行远程传感器和控制设备通讯等,正在日益成为物联网通信协议的重要组成部分。MQTT现在主要用于即时通讯,物联网M2M,物联网采集等。本文就社区上常见的开源MQTT服务器在常见操作系统上的搭建做详细介绍。目前一些开源MQTT服务中间件有:
1)EMQX:github 4882 stars
2)Mosquitto:github 1645 stars
3)Apollo:ActiveMQ的升级版,github 109 stars,但是该项目已经有3~4年没有更新。而其号称的老版本ActiveMQ反而更新更加频繁。
EMQ君建议读者在阅读此篇文章之前,最好对MQTT协议有一些基本的了解,比如消息主题,消息发布,消息订阅和QoS等。
EMQ服务器在Windows搭建
EMQ (Erlang/Enterprise/Elastic MQTT Broker) 是基于 Erlang/OTP 平台开发的开源物联网 MQTT 消息服务器。Erlang/OTP 是出色的软实时(Soft-Realtime)、低延时(Low-Latency)、分布式(Distributed) 的语言平台。一般来说,生产环境的MQTT服务建议搭建在Linux操作系统上,但是作为在给你验证和使用阶段,可以在常见的Windows平台上搭建、运行和测试。
安装步骤
1)点击这里,下载EMQ windows版
2)解压emqttd-windows7-v2.3.9.zip(这里是解压到D盘)
3)打开 Windows 命令行窗口,进入emqtt解压目录
4)在Windows命令行中启动EMQ,执行下列命令
bin\emqttd.cmd start
5)EMQ提供了一个后端Web控制台,用户可通过 Web 控制台,查看服务器运行状态、统计数据、客户端(Client)、会话(Session)、主题(Topic)、订阅(Subscription)、插件(Plugin)。如果EMQ安装在本机,则在
浏览器打开http://127.0.0.1:18083
输入默认用户名“admin”和默认密码“public”,
进入EMQ管理控制台。如下图所示,“Stats(1)”表格中,显示的是客户端和Topic的一些基本信息,比如“Clients/Count”的数目为0,表示目前连接的客户端数目为0;“Client/Max”表示的是连接曾经达到的最大值等。这里不对每项做一一介绍,读者对MQTT协议比较熟悉之后,就能理解监控仪表盘上的内容。
EMQ X 程序包下载
EMQ X 消息服务器每个版本会发布 CentOS、Ubuntu、Debian、FreeBSD、macOS、Windows 、openSUSE 平台程序包与 Docker 镜像。
下载地址: https://www.emqx.io/downloads
CentOS
使用储存库安装 EMQ X
安装所需要的依赖包
$ sudo yum install -y yum-utils device-mapper-persistent-data lvm2
使用以下命令设置稳定存储库,以 CentOS7 为例
$ sudo yum-config-manager --add-repo https://repos.emqx.io/emqx-ce/redhat/centos/7/emqx-ce.repo
安装最新版本的 EMQ X
$ sudo yum install emqx
查询可用版本
$ yum list emqx --showduplicates | sort -r
启动 EMQ X
直接启动
$ emqx start
emqx 3.1.0 is started successfully!
$ emqx_ctl status
Node 'emqx@127.0.0.1' is started
emqx v3.1.0 is running
systemctl 启动
$ sudo systemctl start emqx
service 启动
$ sudo service emqx start
访问 EMX
在浏览器打开http://127.0.0.1:18083, 输入默认用户名“admin”和默认密码“public”
配置文件路径
配置文件路径:/etc/emqx
日志文件路径:/var/log/emqx
数据文件路径:/var/lib/emqx
参考资料:
https://docs.emqx.io/broker/v3/cn/install.html#centos
客户端测试 - MQTTBox
在安装好服务器端之后,我们使用MQTT的客户端对MQTT服务器的基本功能进行相关的测试。MQTT客户端有不少,比如mosquito提供了命令行,通过命令行工具可以方便地进行测试;最简单的方式可能还是通过可视化的界面对其进行测试,EMQ君建议用MQTTBox。MQTTBox有两种使用的方式:一种为Chrome插件;另外一种为Windows程序安装。两种方式下使用的方法差不多,本文以Windows程序安装版来介绍其功能。
安装步骤
1)下载安装软件:读者可以根据自己的喜好,下载不同的版本:此处为Chrome版本的下载地址(需翻墙);此处为Windows安装程序。
2)根据安装向导的提示,完成MQTTBox的安装
3)打开安装好的应用图标,如下图所示
测试消息发布/订阅(Pub/Sub)功能
MQTT协议中通过主题(Topic)在消息发布者和
1)建立MQTT连接,如下图所示,点击“Create MQTT Client”
2)指定连接相关信息,包括连接名称(可以随意输入)、协议(选择mqtt/tcp)和主机地址(安装在本地,MQTT缺省端口为1883,所以输入127.0.0.1:1883),然后单击“Save”保存。连接中一些别的选项先保持缺省值,读者对MQTT协议比较熟悉之后,就可以了解这些选项的意义。
保存成功后进入如下的界面,接下来可以开始测试消息发布和订阅。如下图所示,绿色“Connected”按钮表明当前MQTT连接已经成功
3)首先我们开启一个订阅,如下图所示。“Topic to subscribe”里填入要订阅的主题“windows”;“QoS”字段选择“0 - Almost Once”;然后点击“Subscribe”按钮
4)设置好订阅的主题后,在发布这边输入如下的信息。“Topic to publish”中输入“windows”,这里输入的主题的名字必须和订阅那里的输入相同;“QoS”中选择“0 - Almost Once”;“Payload”中输入任何内容都可以,如下图所示输入了一组JSON字符串;所有内容输入完毕之后,点击“Publish”按钮
5)在订阅端就会收到由服务器端转发的消息内容,如下图所示。
6)打开EMQ的管理员控制台,可以看到一些相关的统计数据已经发生了变化。比如在“The messages data”表格中,“qos0/received”的值为1,说明EMQ收到了1条QoS0的消息;“qos0/sent”的值为1,表示EMQ转发了一条QoS0的消息。
关于作者
王硕,网名信平,十多年软件开发经验,业余架构师,精通Java/Python/Go等,喜欢研究技术,著有《PyQt 5 快速开发与实战》《Python 3.* 全栈开发》,多个业余开源项目托管在GitHub上,欢迎微博交流。