MQTT是一種專(zhuān)門(mén)用于物聯(lián)網(wǎng)連接設(shè)備通信的消息傳遞協(xié)議。整個(gè)MQTT系統(tǒng)由許多客戶機(jī)和一個(gè)代理組成。我們的設(shè)備就像客戶一樣。大多數(shù)微控制器和系統(tǒng)都支持MQTT。在這個(gè)項(xiàng)目中，我們將把樹(shù)莓派與MQTT連接起來(lái)。有幾個(gè)應(yīng)用程序可用于通過(guò)MQTT發(fā)送和接收，但在本項(xiàng)目中，使用mosquito來(lái)建立兩個(gè)樹(shù)莓派之間的通信平臺(tái)。前面我們已經(jīng)將MQTT代理與ESP8266連接起來(lái)。

組件的要求

這個(gè)項(xiàng)目不需要太多額外的硬件就可以工作。你只需要一個(gè)樹(shù)莓派。

?覆盆子π

什么是MQTT?

MQTT表示消息隊(duì)列遙測(cè)傳輸。MQTT是一種機(jī)器對(duì)機(jī)器的連接協(xié)議。當(dāng)我們想要發(fā)送幾個(gè)字節(jié)的數(shù)據(jù)或傳感器值時(shí)，它對(duì)于與遠(yuǎn)程位置的連接很有用。在這個(gè)系統(tǒng)中，您可以作為客戶機(jī)發(fā)布和接收消息。

通過(guò)使用MQTT，您可以發(fā)送命令來(lái)控制輸出、讀取和發(fā)布來(lái)自傳感器的數(shù)據(jù)等等。因此，通過(guò)使用MQTT，可以在多個(gè)設(shè)備之間建立通信。使用MQTT，您可以向客戶機(jī)發(fā)送命令來(lái)控制輸出，也可以從傳感器讀取數(shù)據(jù)并將其發(fā)布到客戶機(jī)。MQTT中有兩個(gè)主要術(shù)語(yǔ)，即客戶端和代理。讓我們討論一下什么是客戶和經(jīng)紀(jì)人。

MQTT客戶機(jī)：MQTT客戶機(jī)是運(yùn)行MQTT庫(kù)并通過(guò)網(wǎng)絡(luò)連接到MQTT代理的任何設(shè)備。發(fā)布者和訂閱者都是MQTT客戶機(jī)。發(fā)布者和訂閱者指的是客戶端是發(fā)布消息還是訂閱消息。

MQTT Broker：代理接收所有消息，過(guò)濾消息，確定誰(shuí)訂閱了每條消息，并將消息發(fā)送給這些訂閱的客戶機(jī)。

樹(shù)莓派MQTT服務(wù)器安裝

要在Pi上安裝mosquito服務(wù)器和客戶端，打開(kāi)Pi終端并運(yùn)行以下命令：

運(yùn)行此命令后，將自動(dòng)啟動(dòng)一個(gè)mosquito服務(wù)器。

現(xiàn)在我們將使用“ test_channel ”在通道中打開(kāi)一個(gè)訂閱者，它將接收來(lái)自發(fā)布者的消息：

在訂閱者之后，我們將在同一通道中打開(kāi)一個(gè)發(fā)布者，并向訂閱者發(fā)送消息：

注意：我們只是將數(shù)據(jù)傳輸?shù)较嗤臉?shù)莓派。為此，只需打開(kāi)兩個(gè)putty終端，一個(gè)用于訂閱者，另一個(gè)用于發(fā)布者。如果您使用的是兩個(gè)不同的樹(shù)莓派，那么請(qǐng)輸入第二個(gè)樹(shù)莓派的IP地址，而不是localhost。例如:

樹(shù)莓派- MQTT數(shù)據(jù)交換使用Python

第二種使用MQTT在兩個(gè)樹(shù)莓派之間建立連接的方法是使用Python代碼。

在這種方法中，我們將在兩個(gè)不同的窗口或兩個(gè)不同的Pi中為訂閱者和發(fā)布者使用兩個(gè)不同的python代碼。

首先使用以下命令安裝Paho MQTT庫(kù)：

現(xiàn)在，在第一個(gè)終端窗口中，創(chuàng)建訂閱者文件

復(fù)制此代碼并將其粘貼到訂閱者文件。

現(xiàn)在運(yùn)行這段代碼：

現(xiàn)在我們的訂閱者設(shè)置完成了。要設(shè)置publisher，打開(kāi)一個(gè)新的putty窗口，使用下面的命令創(chuàng)建一個(gè)publisher文件：

將以下代碼復(fù)制到發(fā)行者文件。

注意：如果您使用兩個(gè)不同的Pi，那么在MQTT_ SERVER中輸入第二個(gè)Pi的IP地址，而不是“l(fā)ocalhost”。

然后運(yùn)行它：

因此，我們已經(jīng)使用MQTT Server成功地從Pi發(fā)送了數(shù)據(jù)。我們還使用ESP8266使用MQTT服務(wù)器發(fā)送數(shù)據(jù)。

本文編譯自iotdesignpro