物联网平台服务端订阅Java SDK解读

1、使用服务端订阅功能，需在控制台上进行设置，选择要推送的消息类型。

2、在Maven工程项目中添加依赖，如下所示。

<dependencies> <!-- Aliyun core --> <dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-core</artifactId> <version>4.3.5</version> </dependency> <dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-iot</artifactId> <version>6.11.0</version> </dependency> <!-- iot message client --> <dependency> <groupId>com.aliyun.openservices</groupId> <artifactId>iot-client-message</artifactId> <version>1.1.3</version> </dependency> <!-- 日志 --> <dependency> <groupId>ch.qos.logback</groupId> <artifactId>logback-classic</artifactId> <version>1.2.3</version> </dependency> </dependencies>

3、使用自己账号的accessKey、accessSecret、regionId、uid初始化客户端。

 // 阿里云accessKey String accessKey = "xxxxxxxxxxxxxxxx"; // 阿里云accessSecret String accessSecret = "xxxxxxxxxxxxxxxxxx"; // regionId String regionId = "cn-shanghai"; // 阿里云uid String uid = "xxxxxxxxxxxxxxx"; // endPoint: https://${uid}.iot-as-http2.${region}.aliyuncs.com String endPoint = "https://" + uid + ".iot-as-http2." + regionId + ".aliyuncs.com"; // 连接配置 Profile profile = Profile.getAccessKeyProfile(endPoint, regionId, accessKey, accessSecret); // 构造客户端 MessageClient client = MessageClientFactory.messageClient(profile);

4、设置消息接收接口。
需要注意的是，目前服务端订阅还无法过滤消息，也就是说该账号下的所有产品下的所有设备的消息都会被订阅到（前提是在第一步设置了要推送的消息类型）。
但是可以针对特定Topic发布上来的消息做单独的业务处理（如下面的messageCallback），其他没有设置特殊回调的消息，统一走公共的接口（也就是下面的messageCallbackComm）

 MessageCallback messageCallbackComm = new MessageCallback() { @Override public Action consume(MessageToken messageToken) { Message m = messageToken.getMessage(); System.out.println("This is common callback!"); System.out.println("topic : " + m.getTopic()); System.out.println("receive : " + new String(m.getPayload())); System.out.println(" "); return MessageCallback.Action.CommitSuccess; } }; MessageCallback messageCallback = new MessageCallback() { @Override public Action consume(MessageToken messageToken) { Message m = messageToken.getMessage(); System.out.println("topic : " + m.getTopic()); System.out.println("receive : " + new String(m.getPayload())); return MessageCallback.Action.CommitSuccess; } }; String topic = "xxxxxxxxxxxxxxxx"; client.setMessageListener(topic,messageCallback); client.connect(messageCallbackComm);

5、举例。
假设代码中的topic设置为设备属性上报的Topic（/sys/${productKey}/${deviceName}/thing/event/property/post）
那么设备进行上报属性的操作，在服务端收到的消息是messageCallback中打印的内容。
对于设备的其他行为（比如上下线），在服务端收到的消息是messageCallbackComm中打印的内容（也就是包括了This is common callback!这句话）