mqtt java
MQTT（MQ遥测传输）是一种轻量级的发布/订阅消息传递协议。 MQTT在物联网应用程序中得到了广泛使用，因为它被设计为在占用空间小的系统上运行在远程位置。
MQTT 3.1是OASIS标准，您可以在http://mqtt.org/上找到所有信息。
本文将指导您完成运行第一个MQTT应用程序的各个步骤：
- 安装并启动MQTT代理
- 编写一个发布消息的应用程序
- 编写使用消息的应用程序
先决条件
- 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.git2-使用Apache Maven构建项目：
这个项目是一个简单的Java应用程序，它使用Eclipse Paho库运行发布者和订阅者。
$ mvn clean package 为了方便起见，示例程序项目被设置为使maven包目标生成单个可执行文件/mqtt-sample ，其中包括所有示例程序和依赖项。
3-运行订阅服务器
订阅者将接收并打印在iot_data主题上发布的所有消息。
$ ./target/mqtt-sample subscriber4-运行发布者
使用以下命令运行发布者，第二个参数是要发布的消息
$ ./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
