成都市建设领域信用系统网站,赶集直招找工作,wordpress 农历小工具,电子商务网站建设源码MQTT#xff08;MQ遥测传输#xff09;是一种轻量级的发布/订阅消息传递协议。 MQTT在物联网应用程序中得到了广泛使用#xff0c;因为它被设计为在占用空间小的系统上运行在远程位置。 MQTT 3.1是OASIS标准#xff0c;您可以在http://mqtt.org/上找到所有信息。 本文将指… MQTTMQ遥测传输是一种轻量级的发布/订阅消息传递协议。 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项目中 dependencygroupIdorg.eclipse.paho/groupIdartifactIdorg.eclipse.paho.client.mqttv3/artifactIdversion1.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 clientnew 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
