基于RabbitMQ的MQTT插件搭建MQTT服务,使用MQTTX进行收发测试

Posted 架构师忠哥

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了基于RabbitMQ的MQTT插件搭建MQTT服务,使用MQTTX进行收发测试相关的知识,希望对你有一定的参考价值。

本文 基于Rabbit MQ的mqtt插件,针对MQTT进行简单的测试。 包括MQTT协议的介绍,rabbitmq的安装、配置、开启mqtt插件及基于MQTTX进行的测试。

MQTT协议

随着5G时代的到来,连接一切正在成为现实。大量设备的接入和设备管理给网络宽带、通信协议和平台服务体系结构带来了巨大的挑战。

MQTT协议是基于发布-订阅模型的物联网消息传递协议。由于其实现简单、易于实现、支持QoS和小分组,已占据物联网协议的一半
特点如下:

  • 轻量级的和可靠的:紧凑的MQTT包,能够在严格受限的设备硬件和高延迟/低带宽网络上稳定传输
  • 更好的生态:其客户端和SDK覆盖所有语言平台,是AWS IoT Core Azure IoT Hub等顶级云厂商的物联网平台标准通信协议,是物联网的实际标准
  • 发布-订阅模型:基于发布-订阅模型。发布-订阅模型的优点是发布者和订阅者之间的解耦:不需要在订阅者和订阅者之间建立直接连接,也不需要同时在线
  • 为物联网而生:提供全面的物联网应用功能,如心跳机制、Will消息、QoS质量级别+离线消息、异步机制、主题和安全管理
  • 对负载内容屏蔽的消息传输机制。
  • QoS: 对传输消息有三种服务质量 (QoS):
    • 最多一次,这一级别会发生消息丢失或重复,消息发布依赖于底层 TCP/IP 网络。即:<=1
    • 至多一次,这一级别会确保消息到达,但消息可能会重复。即:>=1
    • 只有一次,确保消息只有一次到达。即:=1。在一些要求比较严格的计费系统中,可以使用此级别
  • 数据传输和协议交换的最小化 (协议头部只有 2 字节),以减少网络流量
  • 通知机制: 异常中断时通知传输双方

适用范围:在低带宽、不可靠的网络下提供基于云平台的远程设备的数据传输和监控。

rabbitmq的安装

rabbitmq的安装

基于PackageCloud yum源安装

以在centos 7.2中安装为例

配置rabbitmq yum源

在Red Hat 7 或 CentOS 7 上面 基于PackageCloud yum源安装rabbitmq

创建rabbitmq.repo 文件
vi /etc/yum.repos.d/rabbitmq.repo

##
## Zero dependency Erlang
##

[rabbitmq_erlang]
name=rabbitmq_erlang
baseurl=https://packagecloud.io/rabbitmq/erlang/el/7/$basearch
repo_gpgcheck=1
gpgcheck=1
enabled=1
# PackageCloud's repository key and RabbitMQ package signing key
gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey
       https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300

[rabbitmq_erlang-source]
name=rabbitmq_erlang-source
baseurl=https://packagecloud.io/rabbitmq/erlang/el/7/SRPMS
repo_gpgcheck=1
gpgcheck=0
enabled=1
gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300

##
## RabbitMQ server
##

[rabbitmq_server]
name=rabbitmq_server
baseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/7/$basearch
repo_gpgcheck=1
gpgcheck=1
enabled=1
# PackageCloud's repository key and RabbitMQ package signing key
gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey
       https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300

[rabbitmq_server-source]
name=rabbitmq_server-source
baseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/7/SRPMS
repo_gpgcheck=1
gpgcheck=0
enabled=1
gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey
sslverify=1
sslcacert=/etc/pki/tls/certs/ca-bundle.crt
metadata_expire=300

安装依赖

install these dependencies from standard OS repositories

yum install socat logrotate -y

yum install erlang  -y

安装rabbitmq

yum install  rabbitmq-server  -y

启动rabbitmq

#配置开机启动
chkconfig rabbitmq-server on

/sbin/service rabbitmq-server start
/sbin/service rabbitmq-server status
/sbin/service rabbitmq-server stop

开启必要的插件

# 开启管理插件
rabbitmq-plugins enable rabbitmq_management

#开启mqtt插件,也可同时开启 rabbitmq-plugins enable rabbitmq_web_mqtt
rabbitmq-plugins enable rabbitmq_mqtt

# 查看已经安装的插件,输出结果见下图
rabbitmq-plugins list

# 禁止xxx插件,如rabbitmq_mqtt
rabbitmq-plugins disable rabbitmq_mqtt

# 查看开启的插件,返回[rabbitmq_management,rabbitmq_mqtt].
more /etc/rabbitmq/enabled_plugins

配置用户

用户权限配置请参考access-control

当服务器第一次开始运行,并检测到它的数据库未初始化或已被删除,它将使用以下资源初始化一个新的数据库

默认的Virtual Host and User如下:

  • 一个名为/(斜杠)的虚拟主机,
  • 一个名为guest的用户,默认密码为guest,被授予对/虚拟主机的完全访问权。注意:"guest"用户只能从本地主机连接

为了安全和能远程登录管理页面,需要删除guest用户并创建新用户,用户的标签有5种:administrator ,monitoring,policymaker,management和none ,详见rabbitmq management

#查看用户列表:
rabbitmqctl list_users --formatter=json
# 删除guest用户
rabbitmqctl delete_user guest
#增加用户
rabbitmqctl add_user "admin"  根据提示输入密码,如输入20212021
#增加vhost, 根据需要执行,默认的vhost为/
rabbitmqctl add_vhost vnode22
# 给用户赋予权限
#https://www.rabbitmq.com/access-control.html
# First ".*" for configure permission on every entity
# Second ".*" for write permission on every entity
# Third ".*" for read permission on every entity
rabbitmqctl set_permissions -p "/" "admin" ".*" ".*" ".*"
# 给用户增加管理员标签
rabbitmqctl set_user_tags admin administrator

安装验证

登录管理页面

http://172.25.11.22:15672/#/
输入用户 admin / 20212021 进行登录,首页展示如下:

测试MQTT

安装mqttx

下载mqttx, 然后直接安装,安装后打开如下:
mqttx下载地址

配置exchanges

新增加一个exchange,类型是: topic

在mqttx中配置收发客户端

可以看到,发送到mq中的消息,订阅者可以立即收到

以上是关于基于RabbitMQ的MQTT插件搭建MQTT服务,使用MQTTX进行收发测试的主要内容,如果未能解决你的问题,请参考以下文章

RabbitMQ MQTT插件源码级性能优化

基于node.js搭建简单的MQTT服务器,手机通过热点连接电脑实现MQTT服务器测试

通过集群的方式解决基于MQTT协议的RabbitMQ消息收发

转 MQTT在Windows下搭建MQTT服务器

基于ESP32搭建物联网服务器十二(使用MQTT协议与ESP32互动)

Centos搭建mqtt