基于RabbitMQ的MQTT插件搭建MQTT服务，使用MQTTX进行收发测试_rabbitmq 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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

安装依赖

install these dependencies from standard OS repositories

yum install socat logrotate -y

yum install erlang  -y
1
2
3

安装rabbitmq

yum install  rabbitmq-server  -y

1
2

启动rabbitmq

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

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

1
2
3
4
5
6
7

开启必要的插件

# 开启管理插件
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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

配置用户

用户权限配置请参考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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

安装验证

登录管理页面

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

测试MQTT

安装mqttx

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

配置exchanges

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

在mqttx中配置收发客户端

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