建站
咨詢
售后
建站咨詢
新聞中心
隨著物聯(lián)網(wǎng)技術(shù)的不斷發(fā)展，越來越多的設(shè)備需要進行消息通信，而MQTT協(xié)議便是其中一種廣泛應(yīng)用的通信協(xié)議。在Linux平臺上搭建MQTT消息推送系統(tǒng)，可以實現(xiàn)高效穩(wěn)定的設(shè)備消息傳遞，本篇文章將為大家提供一份完整的MQTT消息推送指南。
為新化等地區(qū)用戶提供了全套網(wǎng)頁設(shè)計制作服務(wù)，及新化網(wǎng)站建設(shè)行業(yè)解決方案。主營業(yè)務(wù)為成都做網(wǎng)站、成都網(wǎng)站設(shè)計、新化網(wǎng)站設(shè)計，以傳統(tǒng)方式定制建設(shè)網(wǎng)站，并提供域名空間備案等一條龍服務(wù)，秉承以專業(yè)、用心的態(tài)度為用戶提供真誠的服務(wù)。我們深信只要達到每一位用戶的要求，就會得到認可，從而選擇與我們長期合作。這樣，我們也可以走得更遠！
一、MQTT簡介
MQTT協(xié)議（Message Queue Telemetry Transport）是一種輕量級的消息傳輸協(xié)議，基于發(fā)布/訂閱模式實現(xiàn)消息的傳遞。它可以使得多個客戶端向多個服務(wù)器發(fā)送和接受消息，適用于被網(wǎng)絡(luò)帶寬或通信線路質(zhì)量限制的場景。MQTT顧名思義，是一種消息隊列協(xié)議，它可以實現(xiàn)消息的排隊和分發(fā)，保證消息的可靠性和實時性。
二、安裝MQTT Broker
在Linux平臺上搭建MQTT消息系統(tǒng)，首先要安裝MQTT Broker，也就是消息服務(wù)端。這里我們將使用開源的EMQ X作為MQTT Broker，EMQ X提供了完整的MQTT Broker實現(xiàn)，并具備高性能、高可用、高并發(fā)等優(yōu)勢。
1.安裝依賴庫
EMQ X依賴于一些庫，需要先進行安裝：
– Erlang/OTP（>= 21.0）
– OpenSSL（>= 1.0.2）
– wxWidgets（>= 2.8）
在Ubuntu系統(tǒng)中，可通過以下命令安裝：
“`
sudo apt-get install build-essential git
sudo apt-get install erlang erlang-dev
sudo apt-get install openssl libssl-dev
sudo apt-get install wx-common wx2.8-headers libwxgtk2.8-dev libgl1-mesa-dev libglu1-mesa-dev libpng3
“`
2.下載EMQ X
通過 Git 命令從 EMQ X Github 倉庫中克隆最新版本的項目：
“`
git clone https://github.com/emqx/emqx-rel.git
cd emqx-rel && make
“`
3.啟動EMQ X
在終端中運行以下命令啟動 EMQ X 服務(wù)：
“`
./bin/emqx start
“`
啟動成功后，EMQ X 默認綁定1883端口，可使用以下命令進行檢查：
“`
telnet localhost 1883
“`
三、編寫消息發(fā)送程序
接下來我們將編寫Python程序類來實現(xiàn)MQTT消息的發(fā)送功能。這里我們將使用paho-mqtt庫，它是一種MQTT協(xié)議的Python實現(xiàn)。paho-mqtt庫提供了MQTT客戶端和消息發(fā)布/訂閱API，在Python腳本中方便地實現(xiàn)MQTT通信功能。
以下是Python程序的實現(xiàn)步驟：
1.安裝paho-mqtt庫
可以使用以下命令安裝：
“`
pip install paho-mqtt
“`
2.導(dǎo)入paho-mqtt庫
在Python程序中，先導(dǎo)入paho-mqtt庫：
“`
import paho.mqtt.client as mqtt
“`
3.連接MQTT Broker
在MQTT Broker上需要先創(chuàng)建一個客戶端，初始化客戶端參數(shù)并連接MQTT Broker。在EMQ X上默認情況不需要連接密碼，所以這里我們直接傳入連接地址即可。
“`
def __init__(self, broker_address, port):
super().__init__()
self.broker_address = broker_address
self.port = port
self.client = mqtt.Client()
self.client.on_connect = self.on_connect
self.client.connect(self.broker_address, self.port)
“`
4.發(fā)送消息
調(diào)用publish()函數(shù)來實現(xiàn)消息的發(fā)送，需要指定消息的主題、消息內(nèi)容和QoS級別。QoS級別分為0、1、2三個級別，分別代表最多一次、最少一次、恰好一次的消息傳輸保證。
“`
def send_message(self, topic, payload, qos=0):
self.client.publish(topic, payload, qos)
“`
其中，主題(topic)是字符串類型，用于定義消息的語義類別，是消息訂閱與處理的關(guān)鍵；payload是消息的內(nèi)容，并且只支持bytes類型。消息客戶端發(fā)送需要選擇合適的 QoS，根據(jù)實際情況來選擇保證消息傳輸可靠。
五、調(diào)用Python程序?qū)崿F(xiàn)MQTT消息推送
實現(xiàn)Python程序后，我們可以通過終端調(diào)用該程序?qū)崿F(xiàn)消息推送。具體實現(xiàn)步驟如下：
1.安裝Python3
在Linux系統(tǒng)中，使用以下命令進行安裝：
“`
sudo apt-get install python3 python3-pip
“`
2.運行Python程序
調(diào)用實現(xiàn)的Python程序，以此實現(xiàn)MQTT消息的推送：
“`
python3 mqtt_push.py
“`
其中，mqtt_push.py是你的Python程序文件名。在已經(jīng)啟動MQTT Broker的情況下，運行后客戶端可以連接到 Broker，然后向指定的頻道發(fā)布消息。
六、
以上就是一份完整的Linux平臺下MQTT消息推送指南。通過EMQ X搭建MQTT Broker，使用paho-mqtt庫實現(xiàn)Python程序的編寫，并成功在終端中運行該程序?qū)崿F(xiàn)了MQTT消息的推送。小伙伴們可以根據(jù)實際需要，調(diào)整Python腳本以實現(xiàn)更復(fù)雜的MQTT功能，幫助設(shè)備之間更加高效的消息交互。
成都網(wǎng)站建設(shè)公司-創(chuàng)新互聯(lián),建站經(jīng)驗豐富以策略為先導(dǎo)10多年以來專注數(shù)字化網(wǎng)站建設(shè),提供企業(yè)網(wǎng)站建設(shè),高端網(wǎng)站設(shè)計,響應(yīng)式網(wǎng)站制作,設(shè)計師量身打造品牌風(fēng)格,熱線:028-86922220springboot整合RabbitMQ Mqtt
之一，pom配置，我們需要引入相關(guān)jar：
第二，配置MQTT服務(wù)器基本信息，在springBoot配置文件application.properties中配置，添加如下：
第三，配置MQTT消息推送配置類，
第四，配置MqttGateway消息推送接口類，在sendToMqtt(String data,@Header(MqttHeaders.TOPIC)String topic)接口中，data為發(fā)送的消息內(nèi)容，topic為主題。指定topic，則我們的接口可以根據(jù)需要，向不同的主題發(fā)送消息，方便靈活應(yīng)用。如果不指定，則使用默認配置的主題。
第五，接口類測試下功能，用Postman調(diào)用sendMqtt.do接口，往hello主題發(fā)送消息，用MQTTLens訂閱hello主題，從下面截圖，可以看出可以正常往MQTT服務(wù)發(fā)送消息了，而且可以訂閱到。
關(guān)于mqtt消息推送linux的介紹到此就結(jié)束了，不知道你從中找到你需要的信息了嗎 ？如果你還想了解更多這方面的信息，記得收藏關(guān)注本站。
成都創(chuàng)新互聯(lián)科技公司主營:網(wǎng)站設(shè)計、網(wǎng)站建設(shè)、小程序制作、成都軟件開發(fā)、網(wǎng)頁設(shè)計、微信開發(fā)、成都小程序開發(fā)、網(wǎng)站制作、網(wǎng)站開發(fā)等業(yè)務(wù)，是專業(yè)的成都做小程序公司、成都網(wǎng)站建設(shè)公司、成都做網(wǎng)站的公司。創(chuàng)新互聯(lián)公司集小程序制作創(chuàng)意，網(wǎng)站制作策劃，畫冊、網(wǎng)頁、VI設(shè)計，網(wǎng)站、軟件、微信、小程序開發(fā)于一體。
網(wǎng)頁名稱：Linux平臺下的MQTT消息推送完全指南(mqtt消息推送linux)
文章來源：http://www.dlmjj.cn/article/dpjoged.html
