MQTT是基于TCP/IP协议栈构建的异步通信消息协议,是一种轻量级的发布/订阅信息传输协议。本文档为您介绍通过阿里云物联网平台提供的设备端Java SDK,运行MQTT客户端的方法。
前提条件
- 下载Eclipse软件,并配置好Java环境。
- 此Demo为maven工程,请先安装maven。
操作步骤
- 参考下载设备端SDK,下载iotx-sdk-mqtt-java并解压。
- 打开Eclipse应用,选择,导入上一步解压后的Java SDK文件。
- 双击打开SimpleClient4IOT.java文件。
- 配置设备证书(ProductKey、DeviceName、DeviceSecret)和topic。修改deviceName、productKey、secret、subTopic、pubTopic变量,如下图所示。
说明 进入阿里云物联网控制台,单击物联网平台的
设备,选择
查看,获取以上信息。
subTopic和
pubTopic与上图保持一致即可。
private static String subTopic = "/" + productKey + "/" + deviceName + "/user/get";
private static String pubTopic = "/" + productKey + "/" + deviceName + "/user/update";
- 修改content,如下图所示。
String content1 = "{'content':'shoen1','age':'20'}";
String content2 = "{'content':'shoen2','age':'21'}";
String content3 = "{'content':'shoen3','age':'22'}";
MqttMessage message1 = new MqttMessage(content1.getBytes("utf-8"));
MqttMessage message2 = new MqttMessage(content2.getBytes("utf-8"));
MqttMessage message3 = new MqttMessage(content3.getBytes("utf-8"));
message1.setQos(0);
message2.setQos(0);
message3.setQos(0);
//System.out.println(System.currentTimeMillis() + "消息发布:---");
sampleClient.publish(pubTopic, message1);
sampleClient.publish(pubTopic, message2);
sampleClient.publish(pubTopic, message3);
- 单击运行。
运行成功后,返回如下信息。