MQTT（MQ遙測傳輸）是一種輕量級的發布/訂閱消息傳遞協議。 MQTT在物聯網應用程序中得到了廣泛使用，因為它被設計為在占用空間小的系統上運行在遠程位置。

MQTT 3.1是OASIS標準，您可以在http://mqtt.org/上找到所有信息。

本文將指導您完成運行第一個MQTT應用程序的各個步驟：

安裝并啟動MQTT代理

編寫一個發布消息的應用程序

編寫使用消息的應用程序

GitHub上提供了示例應用程序的源代碼。

先決條件

• Apache Maven 3.x
• 吉特

安裝并啟動MQTT代理

您可以找到許多MQTT經紀人，在這個示例中，我將使用最常見的經紀人之一Mosquitto 。

您可以從二進制軟件包下載并安裝。 我已經使用Homebrew在Mac上安裝了它：

$ brew install mosquitto

使用默認配置啟動MQTT Broker

$ /usr/local/sbin/mosquitto

發布和使用消息

打開兩個終端窗口，然后運行以下命令：

消耗

$ mosquitto_sub -h 127.0.0.1 -t iot_data

發布

$ mosquitto_pub -h 127.0.0.1 -t iot_data -m "Hello world"

您應該在消費者/訂戶窗口中看到消息Hello world 。

編寫您的第一個MQTT應用程序

對于此示例，我將編寫一個小型Java應用程序，因為它是我在全局項目中使用的語言。

Maven依賴

將Eclipse Paho依賴項添加到您的Maven項目中

<dependency><groupId>org.eclipse.paho</groupId><artifactId>org.eclipse.paho.client.mqttv3</artifactId><version>1.1.0</version> </dependency>

發布消息

發布消息非常容易，創建一個MqttClient并將其用于發布主題。

MqttClient client = new MqttClient("tcp://localhost:1883", MqttClient.generateClientId()); client.connect(); MqttMessage message = new MqttMessage(); message.setPayload("Hello world from Java".getBytes()); client.publish("iot_data", message); client.disconnect();

您還有許多其他選項，可以在發布消息時使用的配置，例如安全性，服務質量（QoS）等。 但是在這篇文章中，我只想簡單地展示發布和使用MQTT消息有多么容易。

消費信息

要使用消息，您需要實現org.eclipse.paho.client.mqttv3.MqttCallback ，它將接收消息并在Subscriber應用程序的MqttClient中使用此Callback類。

回調類：

public class SimpleMqttCallBack implements MqttCallback {public void connectionLost(Throwable throwable) {System.out.println("Connection to MQTT broker lost!");}public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {System.out.println("Message received:\n\t"+ new String(mqttMessage.getPayload()) );}public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {// not used in this example} }

在訂閱服務器應用程序中使用此回調類，如下所示：

MqttClient client=new MqttClient("tcp://localhost:1883", MqttClient.generateClientId()); client.setCallback( new SimpleMqttCallBack() ); client.connect();

像發布者一樣，我使用的代理和客戶端沒有任何選擇（QoS，安全性）。

生成并運行應用程序

1-獲取示例代碼

從GitHub克隆項目

$ git clone https://github.com/tgrall/mqtt-sample-java.git

2-使用Apache Maven構建項目：

這個項目是一個簡單的Java應用程序，它使用Eclipse Paho庫運行發布者和訂閱者。

$ mvn clean package

為方便起見，示例程序項目被設置為使maven包目標生成單個可執行文件/mqtt-sample ，其中包括所有示例程序和依賴項。

3-運行訂閱服務器

訂閱者將接收并打印在iot_data主題上發布的所有消息。

$ ./target/mqtt-sample subscriber

4-運行發布者

使用以下命令運行發布者，第二個參數是要發布的消息

$ ./target/mqtt-sample publisher "My first MQTT message..."

結論

在本文中，您學習了如何：

• 安裝并啟動MQTT經紀人Mosquitto
• 創建用Java開發的發布者和訂閱者

選擇本文非常簡單，可以快速運行您的第一個MQTT應用程序。 我寫這篇文章是我正在從事的全球物聯網項目的一部分，該項目將捕獲設備數據，并使用MQTT和MapR Streams將其發布到MapR融合數據平臺中。 這就是為什么我在應用程序中使用Java。 您可以使用任何MQTT客戶端庫來構建發布者和訂閱者。

翻譯自: https://www.javacodegeeks.com/2017/01/getting-started-mqtt-java.html

總結

以上是生活随笔為你收集整理的MQTT和Java入门的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。