物联网平台实用技巧:通过服务端订阅(HTTP/2)获取设备状态

简介: 物联网很多业务场景中,时常需要获取设备的实时状态,以便根据不同的状态(在线或离线)做不同的处理。阿里云物联网平台提供服务端订阅功能来获取设备的状态信息。本文介绍通过HTTP/2通道订阅获取设备状态的方法

产品推荐:阿里云物联网开发者工具(IoT Studio),立刻免费体验吧!  
 

原理

在物联网平台控制台,设置服务端订阅设备状态变化通知消息后,物联网平台会将该产品下的设备上下线消息推送到您的服务端。服务端通过HTTP/2 SDK接收设备状态变化消息。

流程图
image.png
说明 步骤1.1和2.1物联网平台判断是否已配控制台已配置服务端订阅设备状态变化通知。
设备状态变化通知消息的数据格式

    "status":"online|offline",
    "productKey":"al123455****",
    "deviceName":"deviceName1234",
    "time":"2018-08-31 15:32:28.205",
    "utcTime":"2018-08-31T07:32:28.205Z",
    "lastTime":"2018-08-31 15:32:28.195",
    "utcLastTime":"2018-08-31T07:32:28.195Z",
    "clientIp":"123.123.***.***"
}

订阅

在物联网平台控制台,设置HTTP/2服务端订阅设备状态变化通知。
1、登录物联网平台控制台。
2、左侧导航栏选择设备管理 > 产品。
3、在产品列表中,搜索到要配置服务端订阅的产品,并单击该产品对应的查看按钮。
4、在产品详情页,单击服务端订阅 > 设置。
5、选择推送的消息类型为设备状态变化通知,单击保存
image.png

接收

服务端通过HTTP/2 SDK接收设备状态消息。本示例以配置Java HTTP/2 SDK为例。

说明
仅支持JDK8。
如果同一个阿里云账号信息用于启动了多个HTTP/2 SDK,物联网平台会将设备状态消息随机推送到其中一个客户端。
在Maven项目中,添加以下pom依赖,安装阿里云IoT SDK。

  <groupId>com.aliyun.openservices</groupId>
  <artifactId>iot-client-message</artifactId>
  <version>1.1.3</version>
</dependency>
<dependency>
  <groupId>com.aliyun</groupId>
  <artifactId>aliyun-java-sdk-core</artifactId>
  <version>3.7.1</version>
</dependency>

Config.*参数值中,需传入您的阿里云账号AccessKey信息和设备信息。

  private static String accessKeyID = "Config.accessKey";
  // 您的阿里云账号AccesseKey Secret
  private static String accessKeySecret = "Config.accessKeySecret";
  // 您的阿里云账号ID
  private static String uid = "Config.uid";
  // regionId
  private static String regionId = "cn-shanghai";
  // endPoint: https://${uid}.iot-as-http2.${region}.aliyuncs.com
  private static String endPoint = "https://" + uid + ".iot-as-http2." + regionId + ".aliyuncs.com";

完整示例代码如下:

 * Copyright © 2019 Alibaba. All rights reserved.
 */
package com.aliyun.iot.demo.checkstatus;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.aliyun.openservices.iot.api.Profile;
import com.aliyun.openservices.iot.api.message.MessageClientFactory;
import com.aliyun.openservices.iot.api.message.api.MessageClient;
import com.aliyun.openservices.iot.api.message.callback.MessageCallback;
import com.aliyun.openservices.iot.api.message.entity.MessageToken;
import com.google.common.util.concurrent.ThreadFactoryBuilder;

public class GetDeviceStatusByH2 {

  // ===================需要用户填写的参数开始===========================
  // 修改Config.*的参数为您的账号信息
  // 各项信息的获取方式请参考 https://help.aliyun.com/document_detail/89227.html
  // 用户账号AccessKey
  private static String accessKeyID = "Config.accessKey";
  // 用户账号AccesseKeySecret
  private static String accessKeySecret = "Config.accessKeySecret";
  // 用户uid
  private static String uid = "Config.uid";
  // regionId
  private static String regionId = "cn-shanghai";
  // endPoint: https://${uid}.iot-as-http2.${region}.aliyuncs.com
  private static String endPoint = "https://" + uid + ".iot-as-http2." + regionId + ".aliyuncs.com";
  // ===================需要用户填写的参数结束===========================

  private static ExecutorService executorService = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(),
      Runtime.getRuntime().availableProcessors() * 2, 60, TimeUnit.SECONDS, new LinkedBlockingQueue<>(100),
      new ThreadFactoryBuilder().setDaemon(true).setNameFormat("http2-downlink-handle-%d").build(),
      new ThreadPoolExecutor.AbortPolicy());

  /**
   * 1、设置服务端订阅
   * 2、启动本程序
   * 3、启动您的设备,使设备在线
   * 4、关闭您的设备,使设备离线
   * 5、查看本程序打印的日志
   * 
   * @param args
   */
  public static void main(String[] args) {

    // 连接配置
    Profile profile = Profile.getAccessKeyProfile(endPoint, regionId, accessKeyID, accessKeySecret);

    // 构造客户端
    MessageClient client = MessageClientFactory.messageClient(profile);

    // 消息回调处理
    MessageCallback messageCallback = new MessageCallback() {
      @Override
      public Action consume(MessageToken messageToken) {
        // 返回消费成功,业务另起线程处理,以免堵塞回调
        executorService.submit(() -> handleDownLinkMessage(messageToken));
        // 收到消息应该尽快return commitSuccess
        return MessageCallback.Action.CommitSuccess;
      }
    };

    // 本地过滤。物联网平台会将已订阅的全部设备消息推送下来,这里通过匹配Topic,过滤出要处理的消息
    // 这里只处理Topic为 /as/mqtt/status 开头的消息,其他消息也会收到但不处理
    // Topic及其对应的消息格式请参考 https://help.aliyun.com/document_detail/73736.html
    client.setMessageListener("/as/mqtt/status/#", messageCallback);

    // 通用回调,setMessageListener中未匹配的消息在这里处理
    MessageCallback messageCallbackCommon = new MessageCallback() {

      @Override
      public Action consume(MessageToken messageToken) {
        // 如果有业务处理,建议另起线程处理
        return MessageCallback.Action.CommitSuccess;
      }
    };

    // 数据接收
    client.connect(messageCallbackCommon);
  }

  private static void handleDownLinkMessage(MessageToken messageToken) {
    // 整个消息体内容是JSON
    String message = new String(messageToken.getMessage().getPayload());
    // 获取其中的status字段,就是设备在线状态
    JSONObject json = (JSONObject) JSON.parse(message);
    String deviceName = json.getString("deviceName");
    String status = json.getString("status");
    System.out.println("消息原始内容: " + message);
    System.out.println(deviceName + " 在线状态: " + status);
    // 其他自定义实现
  }
}

服务端接收订阅消息的Java HTTP/2 SDK配置详细说明,请参见开发指南(Java)。

相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
目录
相关文章
|
JavaScript
HTTP/2 协议-服务端主动推送消息
HTTP/2 协议-服务端主动推送消息
460 0
|
3月前
|
安全 网络协议 算法
HTTPS为什么可以穿越NAT端口映射设备
HTTPS能穿越NAT端口映射设备的原因在于,NAT设备仅在IP和端口层面进行地址转换,不对应用层协议(如TLS)的内容进行解析或干预。因此,HTTPS的加密通信可在客户端与服务器间直接建立,NAT设备充当透明中介,确保数据包正确路由,而不涉及加密或认证过程。这样即使没有在NAT设备上配置证书,HTTPS连接也能顺利建立并保持安全。
70 6
|
3月前
|
消息中间件 测试技术
通过轻量消息队列(原MNS)主题HTTP订阅+ARMS实现自定义数据多渠道告警
轻量消息队列(原MNS)以其简单队列模型、轻量化协议及按量后付费模式,成为阿里云产品间消息传输首选。本文通过创建主题、订阅、配置告警集成等步骤,展示了该产品在实际应用中的部分功能,确保消息的可靠传输。
81 2
|
4月前
|
网络协议 物联网 网络性能优化
物联网协议比较 MQTT CoAP RESTful/HTTP XMPP
【10月更文挑战第18天】本文介绍了物联网领域中四种主要的通信协议:MQTT、CoAP、RESTful/HTTP和XMPP,分别从其特点、应用场景及优缺点进行了详细对比,并提供了简单的示例代码。适合开发者根据具体需求选择合适的协议。
110 5
|
5月前
|
网络协议 物联网 网络性能优化
物联网江湖风云变幻!MQTT CoAP RESTful/HTTP XMPP四大门派谁主沉浮?
【9月更文挑战第3天】物联网(IoT)的兴起催生了多种通信协议,如MQTT、CoAP、RESTful/HTTP和XMPP,各自适用于不同场景。本文将对比这些协议的特点、优缺点,并提供示例代码。MQTT轻量级且支持QoS,适合大规模部署;CoAP基于UDP,适用于低功耗网络;RESTful/HTTP易于集成但不适合资源受限设备;XMPP支持双向通信,适合复杂交互应用。通过本文,开发者可更好地选择合适的物联网通信协议。
66 2
|
8月前
|
传感器 物联网
物联网协议概述:MQTT、CoAP 和 HTTP
【6月更文挑战第3天】探索物联网的三大协议——MQTT、CoAP 和 HTTP。MQTT 是高效的消息传递使者,适用于大规模、不稳定网络环境;CoAP 小巧灵活,适合资源有限的设备;HTTP 则是熟悉的网络通信老将。根据不同场景选择合适的协议,让物联网设备有效交流。示例代码展示它们的使用方式。
198 0
|
9月前
|
JSON 安全 网络安全
超详细的用户认证、权限、安全原理详解(认证、权限、JWT、RFC 7235、HTTPS、HSTS、PC端、服务端、移动端、第三方认证等等)
超详细的用户认证、权限、安全原理详解(认证、权限、JWT、RFC 7235、HTTPS、HSTS、PC端、服务端、移动端、第三方认证等等)
1261 0
|
9月前
|
数据安全/隐私保护 C++
c++实现http客户端和服务端的开源库以及Base64加密密码
c++实现http客户端和服务端的开源库以及Base64加密密码
126 0
|
JSON 网络协议 Java
springboot服务端接口公网远程调试 - 实现HTTP服务监听【端口映射】
前后端分离项目中,在调用接口调试时候,我们可以通过cpolar内网穿透将本地服务端接口模拟公共网络环境远程调用调试,本次教程我们以Java服务端接口为例。
125 0
springboot服务端接口公网远程调试 - 实现HTTP服务监听【端口映射】

相关产品

  • 物联网平台