Paho-MQTT Java接入示例_使用Paho接入物联网平台_设备接入_最佳实践

准备开发环境

本示例使用的开发环境如下：

操作系统：macOS
JDK版本：JDK8
集成开发环境：IntelliJ IDEA社区版

下载Java语言的Paho MQTT库

在Maven工程中添加如下依赖：

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

接入物联网平台

单击打开MqttSign.java，下载阿里云提供的计算MQTT连接参数所需的源码。

MqttSign.java文件定义了MqttSign类，类说明如下：

原型：
```
class MqttSign
```
功能：
用于计算设备接入物联网平台的MQTT连接参数username、password和clientid。

成员：


类型定义	方法描述
public void	`calculate(String productKey, String deviceName, String deviceSecret)` 根据设备的productKey、deviceName和deviceSecret计算出MQTT连接参数username、password和clientid。
public String	`getUsername()` 用于获取MQTT建连参数username。
public String	`getPassword()` 用于获取MQTT建连参数password。
public String	`getClientid()` 用于获取MQTT建连参数clientid。

打开IntelliJ IDEA，创建项目。
将MqttSign.java导入项目中。

在项目中，添加实现设备接入物联网平台的程序文件。

您需编写程序调用MqttSign.java中的MqttSign类计算MQTT连接参数，实现接入物联网平台和通信。

开发说明和示例代码如下：

调用MqttSign计算MQTT连接参数。

String productKey = "a1X2bEn****";
String deviceName = "example1";
String deviceSecret = "ga7XA6KdlEeiPXQPpRbAjOZXwG8y****";

// 计算MQTT连接参数。
MqttSign sign = new MqttSign();
sign.calculate(productKey, deviceName, deviceSecret);

System.out.println("username: " + sign.getUsername());
System.out.println("password: " + sign.getPassword());
System.out.println("clientid: " + sign.getClientid());

调用Paho MQTT客户端连接物联网平台。

//接入物联网平台的域名。
String port = "443";
String broker = "ssl://" + productKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com" + ":" + port;

// Paho MQTT客户端。
MqttClient sampleClient = new MqttClient(broker, sign.getClientid(), persistence);

// Paho MQTT连接参数。
MqttConnectOptions connOpts = new MqttConnectOptions();
connOpts.setCleanSession(true);
connOpts.setKeepAliveInterval(180);
connOpts.setUserName(sign.getUsername());
connOpts.setPassword(sign.getPassword().toCharArray());
sampleClient.connect(connOpts);
System.out.println("Broker: " + broker + " Connected");

说明代码中的地域代码（cn-shanghai），需设置为您的物联网平台设备所在地域代码。地域代码表达方法，请参见地域和可用区。

发布消息。

以下示例代码上报物模型属性LightSwitch。

// Paho MQTT发布消息。
String topic = "/sys/" + productKey + "/" + deviceName + "/thing/event/property/post";
String content = "{\"id\":\"1\",\"version\":\"1.0\",\"params\":{\"LightSwitch\":1}}";
MqttMessage message = new MqttMessage(content.getBytes());
message.setQos(0);
sampleClient.publish(topic, message);

物模型通信数据格式，请参见设备属性、事件、服务。

如果您要使用自定义Topic通信，请参见什么是Topic。

订阅Topic，获取云端下发消息。

以下示例中，订阅的是上报属性值后，物联网平台返回应答消息的Topic。

class MqttPostPropertyMessageListener implements IMqttMessageListener {
    @Override
    public void messageArrived(String var1, MqttMessage var2) throws Exception {
        System.out.println("reply topic  : " + var1);
        System.out.println("reply payload: " + var2.toString());
    }
}
...
// Paho MQTT消息订阅。
String topicReply = "/sys/" + productKey + "/" + deviceName + "/thing/event/property/post_reply";
sampleClient.subscribe(topicReply, new MqttPostPropertyMessageListener());

关于设备、服务器和物联网平台的通信方式介绍，请参见通信方式概述。

编译项目。

示例Demo

使用Demo代码程序接入物联网平台。

下载Demo代码包，并解压缩。
打开IntelliJ IDEA，导入Demo包中的示例工程aiot-java-demo。
在src/main/java/com.aliyun.iot/App中，修改设备信息为您的设备信息。
- 将productKey、deviceName和deviceSecret替换为您的设备证书信息。
- 将String broker = "ssl://" + productKey + ".iot-as-mqtt.cn-shanghai.aliyuncs.com" + ":" + port;中的地域代码（cn-shanghai）替换为您的物联网平台设备所在地域代码。地域代码表达方法，请参见地域和可用区。
运行App程序。
运行成功日志如下图所示。
在物联网平台控制台上，可查看设备状态和日志。
- 选择设备管理 > 设备，可看到该设备的状态显示为在线。
- 选择监控运维 > 日志服务，可查看云端运行日志和设备本地日志日志。详情请参见云端运行日志、设备本地日志。

错误码

如果设备通过MQTT协议接入物联网平台失败，请根据错误码排查问题。服务端错误码说明，请参见错误排查。

Paho-MQTT Java接入示例

前提条件

准备开发环境

下载Java语言的Paho MQTT库

接入物联网平台

示例Demo

错误码