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

MQTT協(xié)議

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

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

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

適用范圍：在低帶寬、不可靠的網(wǎng)絡(luò)下提供基于云平臺的遠(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

啟動rabbitmq

#配置開機(jī)啟動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_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)限配置請參考access-control

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

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

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

為了安全和能遠(yuǎn)程登錄管理頁面，需要刪除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

安裝驗證

登錄管理頁面

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

測試MQTT

安裝mqttx

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

配置exchanges

新增加一個exchange，類型是: topic

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

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