$oc开头自定义Topic通信使用说明

使用流程&操作步骤

设备侧JAVA SDK使用示例

设备端可以通过集成华为云IoT提供的设备端SDK快速连接华为云IoTDA，并进行消息上报。以下示例为通过JAVA SDK实现设备连接到华为云IoTDA进行发布、订阅自定义Topic。以订阅"$oc/devices/" + device.getDeviceId() + "/user/wpy"为例。

1. 配置设备侧SDK的Maven依赖。

   <dependency>
   	<groupId>com.huaweicloud</groupId>
   	<artifactId>iot-device-sdk-java</artifactId>
   	<version>1.1.4</version>
   </dependency>

2. 配置设备侧SDK，设备连接参数。

   //加载iot平台的ca证书，获取连接参考：https://support.huaweicloud.com/devg-iothub/iot_02_1004.html#section3
   URL resource = MessageSample.class.getClassLoader().getResource("ca.jks");
   File file = new File(resource.getPath());
   
   //注意格式为：ssl://域名信息:端口号。
   //域名获取方式：登录华为云IoTDA控制台左侧导航栏“总览”页签，在选择的实例基本信息中，单击“接入信息”。选择8883端口对应的接入域名。
   String serverUrl = "ssl://localhost:8883";
   //在IoT平台创建的设备ID。
   String deviceId = "deviceId";
   //设备ID对应的密钥。
   String deviceSecret = "secret";
   //初始化设备连接
   IoTDevice device = new IoTDevice(serverUrl, deviceId, deviceSecret, file);
   if (device.init() != 0) {
       return;
   }

3. 上报设备消息：

   device.getClient().publishRawMessage(new RawMessage( "$oc/devices/" + device.getDeviceId() + "/user/wpy", "hello", 1), new ActionListener() {
       @Override
       public void onSuccess(Object context) {
           System.out.println("reportDeviceMessage success: ");
       }
       @Override
       public void onFailure(Object context, Throwable var2) {
           System.out.println("reportDeviceMessage fail: " + var2);
       }
   });

4. 订阅topic：

   device.getClient().subscribeTopic(new RawMessage("$oc/devices/" + device.getDeviceId() + "/user/wpy", new ActionListener() {
       @Override
       public void onSuccess(Object context) {
           System.out.println("subscribeTopic success: ");
       }
       @Override
       public void onFailure(Object context, Throwable var2) {
           System.out.println("subscribeTopic fail: " + var2);
       }
   }, 0);