基于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的安装
基于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进行收发测试的主要内容,如果未能解决你的问题,请参考以下文章
基于node.js搭建简单的MQTT服务器,手机通过热点连接电脑实现MQTT服务器测试
通过集群的方式解决基于MQTT协议的RabbitMQ消息收发