本文 基于Rabbit MQ的mqtt插件，針對(duì)MQTT進(jìn)行簡(jiǎn)單的測(cè)試。 包括MQTT協(xié)議的介紹，rabbitmq的安裝、配置、開啟mqtt插件及基于MQTTX進(jìn)行的測(cè)試。

MQTT協(xié)議

隨著5G時(shí)代的到來(lái)，連接一切正在成為現(xiàn)實(shí)。大量設(shè)備的接入和設(shè)備管理給網(wǎng)絡(luò)寬帶、通信協(xié)議和平臺(tái)服務(wù)體系結(jié)構(gòu)帶來(lái)了巨大的挑戰(zhàn)。

MQTT協(xié)議是基于發(fā)布-訂閱模型的物聯(lián)網(wǎng)消息傳遞協(xié)議。由于其實(shí)現(xiàn)簡(jiǎn)單、易于實(shí)現(xiàn)、支持QoS和小分組，已占據(jù)物聯(lián)網(wǎng)協(xié)議的一半
特點(diǎn)如下：

• 輕量級(jí)的和可靠的：緊湊的MQTT包，能夠在嚴(yán)格受限的設(shè)備硬件和高延遲/低帶寬網(wǎng)絡(luò)上穩(wěn)定傳輸
• 更好的生態(tài)：其客戶端和SDK覆蓋所有語(yǔ)言平臺(tái)，是AWS IoT Core Azure IoT Hub等頂級(jí)云廠商的物聯(lián)網(wǎng)平臺(tái)標(biāo)準(zhǔn)通信協(xié)議，是物聯(lián)網(wǎng)的實(shí)際標(biāo)準(zhǔn)
• 發(fā)布-訂閱模型：基于發(fā)布-訂閱模型。發(fā)布-訂閱模型的優(yōu)點(diǎn)是發(fā)布者和訂閱者之間的解耦:不需要在訂閱者和訂閱者之間建立直接連接，也不需要同時(shí)在線
• 為物聯(lián)網(wǎng)而生：提供全面的物聯(lián)網(wǎng)應(yīng)用功能，如心跳機(jī)制、Will消息、QoS質(zhì)量級(jí)別+離線消息、異步機(jī)制、主題和安全管理
• 對(duì)負(fù)載內(nèi)容屏蔽的消息傳輸機(jī)制。
• QoS: 對(duì)傳輸消息有三種服務(wù)質(zhì)量 (QoS)：
  • 最多一次，這一級(jí)別會(huì)發(fā)生消息丟失或重復(fù)，消息發(fā)布依賴于底層 TCP/IP 網(wǎng)絡(luò)。即：<=1
  • 至多一次，這一級(jí)別會(huì)確保消息到達(dá)，但消息可能會(huì)重復(fù)。即：>=1
  • 只有一次，確保消息只有一次到達(dá)。即：=1。在一些要求比較嚴(yán)格的計(jì)費(fèi)系統(tǒng)中，可以使用此級(jí)別
• 數(shù)據(jù)傳輸和協(xié)議交換的最小化 (協(xié)議頭部只有 2 字節(jié))，以減少網(wǎng)絡(luò)流量
• 通知機(jī)制: 異常中斷時(shí)通知傳輸雙方

適用范圍：在低帶寬、不可靠的網(wǎng)絡(luò)下提供基于云平臺(tái)的遠(yuǎn)程設(shè)備的數(shù)據(jù)傳輸和監(jiān)控。

rabbitmq的安裝

rabbitmq的安裝

基于PackageCloud yum源安裝

以在centos 7.2中安裝為例

配置rabbitmq yum源

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

創(chuàng)建rabbitmq.repo 文件
vi /etc/yum.repos.d/rabbitmq.repo

#### Zero dependency Erlang##[rabbitmq_erlang]name=rabbitmq_erlangbaseurl=https://packagecloud.io/rabbitmq/erlang/el/7/$basearchrepo_gpgcheck=1gpgcheck=1enabled=1# PackageCloud"s repository key and RabbitMQ package signing keygpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkey       https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.ascsslverify=1sslcacert=/etc/pki/tls/certs/ca-bundle.crtmetadata_expire=300[rabbitmq_erlang-source]name=rabbitmq_erlang-sourcebaseurl=https://packagecloud.io/rabbitmq/erlang/el/7/SRPMSrepo_gpgcheck=1gpgcheck=0enabled=1gpgkey=https://packagecloud.io/rabbitmq/erlang/gpgkeysslverify=1sslcacert=/etc/pki/tls/certs/ca-bundle.crtmetadata_expire=300#### RabbitMQ server##[rabbitmq_server]name=rabbitmq_serverbaseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/7/$basearchrepo_gpgcheck=1gpgcheck=1enabled=1# PackageCloud"s repository key and RabbitMQ package signing keygpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey       https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.ascsslverify=1sslcacert=/etc/pki/tls/certs/ca-bundle.crtmetadata_expire=300[rabbitmq_server-source]name=rabbitmq_server-sourcebaseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/7/SRPMSrepo_gpgcheck=1gpgcheck=0enabled=1gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkeysslverify=1sslcacert=/etc/pki/tls/certs/ca-bundle.crtmetadata_expire=300

安裝依賴

install these dependencies from standard OS repositories

yum install socat logrotate -yyum install erlang  -y

安裝rabbitmq

yum install  rabbitmq-server  -y

啟動(dòng)rabbitmq

#配置開機(jī)啟動(dòng)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插件,也可同時(shí)開啟 rabbitmq-plugins enable rabbitmq_web_mqttrabbitmq-plugins enable rabbitmq_mqtt# 查看已經(jīng)安裝的插件,輸出結(jié)果見下圖rabbitmq-plugins list# 禁止xxx插件,如rabbitmq_mqttrabbitmq-plugins disable rabbitmq_mqtt# 查看開啟的插件，返回[rabbitmq_management,rabbitmq_mqtt].more /etc/rabbitmq/enabled_plugins

配置用戶

用戶權(quán)限配置請(qǐng)參考access-control

當(dāng)服務(wù)器第一次開始運(yùn)行，并檢測(cè)到它的數(shù)據(jù)庫(kù)未初始化或已被刪除，它將使用以下資源初始化一個(gè)新的數(shù)據(jù)庫(kù)

默認(rèn)的Virtual Host and User如下：

• 一個(gè)名為/(斜杠)的虛擬主機(jī)，
• 一個(gè)名為guest的用戶，默認(rèn)密碼為guest，被授予對(duì)/虛擬主機(jī)的完全訪問(wèn)權(quán)。注意："guest"用戶只能從本地主機(jī)連接

為了安全和能遠(yuǎn)程登錄管理頁(yè)面，需要?jiǎng)h除guest用戶并創(chuàng)建新用戶，用戶的標(biāo)簽有5種:administrator ，monitoring，policymaker，management和none ，詳見rabbitmq management

#查看用戶列表:rabbitmqctl list_users --formatter=json# 刪除guest用戶rabbitmqctl delete_user guest#增加用戶rabbitmqctl add_user "admin"  根據(jù)提示輸入密碼,如輸入20212021#增加vhost, 根據(jù)需要執(zhí)行，默認(rèn)的vhost為/rabbitmqctl add_vhost vnode22# 給用戶賦予權(quán)限#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 entityrabbitmqctl set_permissions -p "/" "admin" ".*" ".*" ".*"# 給用戶增加管理員標(biāo)簽rabbitmqctl set_user_tags admin administrator

安裝驗(yàn)證

登錄管理頁(yè)面

http://172.25.11.22:15672/#/
輸入用戶 admin / 20212021 進(jìn)行登錄，首頁(yè)展示如下：

測(cè)試MQTT

安裝mqttx

下載mqttx, 然后直接安裝，安裝后打開如下：
mqttx下載地址

配置exchanges

新增加一個(gè)exchange，類型是: topic

在mqttx中配置收發(fā)客戶端

可以看到，發(fā)送到mq中的消息，訂閱者可以立即收到