AI 助理
备案控制台
开发者社区 物联网 文章 正文

阿里云物联网平台远程配置功能JAVA 示例参考

2019-09-01 5172
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 很多场景下，开发者需要更新设备的配置信息，包括设备的系统参数、网络参数、本地策略等。通常情况下，是通过固件升级的方式更新设备的配置信息。但是，这将加大固件版本的维护工作，并且需要设备中断运行以完成更新。

概述

很多场景下，开发者需要更新设备的配置信息，包括设备的系统参数、网络参数、本地策略等。通常情况下，是通过固件升级的方式更新设备的配置信息。但是，这将加大固件版本的维护工作，并且需要设备中断运行以完成更新。为了解决上述问题，物联网平台提供了远程配置更新的功能，设备无需重启或中断运行即可在线完成配置信息的更新。本文主要演示如何使用JAVA SDK实现两种应用场景。

原理说明

1、物联网平台提供的远程配置功能，支持：

  • 开启/关闭远程配置。
  • 在线编辑配置文件，并管理版本。
  • 批量更新设备配置信息。
  • 设备主动请求更新配置信息。

2、流程图
_

3、远程配置大致分为三部分：

  • 生成配置文件：您在物联网平台控制台编辑并保存配置信息。
  • 推送配置文件：您在物联网平台控制台批量推送配置信息给设备。设备接收后，修改本地配置文件。
  • 设备主动请求配置信息：设备主动向云端请求新的配置文件，并进行更新。

远程配置使用分为两种场景，一种是云端推送配置信息给设备端，一种是设备端主动请求配置信息。根据场景的不同，远程配置的步骤也有所区别。

场景一：云端推送配置信息给设备端

1、设备端业务代码实现

import com.aliyun.alink.dm.api.DeviceInfo;
import com.aliyun.alink.dm.api.InitResult;
import com.aliyun.alink.dm.api.IoTApiClientConfig;
import com.aliyun.alink.linkkit.api.ILinkKitConnectListener;
import com.aliyun.alink.linkkit.api.IoTMqttClientConfig;
import com.aliyun.alink.linkkit.api.LinkKit;
import com.aliyun.alink.linkkit.api.LinkKitInitParams;
import com.aliyun.alink.linksdk.cmp.connect.channel.MqttSubscribeRequest;
import com.aliyun.alink.linksdk.cmp.core.base.AMessage;
import com.aliyun.alink.linksdk.cmp.core.base.ConnectState;
import com.aliyun.alink.linksdk.cmp.core.listener.IConnectNotifyListener;
import com.aliyun.alink.linksdk.cmp.core.listener.IConnectSubscribeListener;
import com.aliyun.alink.linksdk.tools.AError;

public class DeviceCOTADemo1 {

    public static void main(String[] args) {
        String regionId = "cn-shanghai";
        DeviceInfo deviceInfo = new DeviceInfo();
        deviceInfo.productKey = "******";
        deviceInfo.deviceName = "******";
        deviceInfo.deviceSecret = "********";

        LinkKitInitParams params = new LinkKitInitParams();
        IoTMqttClientConfig config = new IoTMqttClientConfig();
        config.productKey = deviceInfo.productKey;
        config.deviceName = deviceInfo.deviceName;
        config.deviceSecret = deviceInfo.deviceSecret;
        config.channelHost = deviceInfo.productKey + ".iot-as-mqtt." + regionId + ".aliyuncs.com:1883";
        params.mqttClientConfig = config;
        params.connectConfig = new IoTApiClientConfig();
        params.deviceInfo = deviceInfo;

        /**建立连接**/
        LinkKit.getInstance().init(params, new ILinkKitConnectListener() {
            @Override
            public void onError(AError aError) {
                System.out.println("初始化失败 " + aError.getMsg());
            }

            @Override
            public void onInitDone(InitResult initResult) {

                System.out.println("初始化成功 " + initResult.tsl);

                String pd = deviceInfo.productKey + "/" + deviceInfo.deviceName;

                // 1、cota 请求 Topic
                String requestcotaTopic = "/sys/"+pd+"/thing/config/push";

                // 订阅Topic
                MqttSubscribeRequest upgradeTopicRequest = new MqttSubscribeRequest();
                upgradeTopicRequest.topic = requestcotaTopic;
                upgradeTopicRequest.isSubscribe = true;

                // 直接做Topic的订阅
                LinkKit.getInstance().subscribe(upgradeTopicRequest, new IConnectSubscribeListener(){
                    @Override
                    public void onSuccess() {
                        System.out.println("cota订阅成功");
                    }

                    @Override
                    public void onFailure(AError aError) {
                        System.out.println("直接订阅失败" + aError.getMsg());
                    }
                });

                // 注册ota下行监听
                LinkKit.getInstance().registerOnNotifyListener(new IConnectNotifyListener() {
                    @Override
                    public void onNotify(String s, String s1, AMessage aMessage) {

                        System.out.println("cota 监听响应:");
                        System.out.println(new String((byte[])aMessage.getData()));
                    }

                    @Override
                    public boolean shouldHandle(String s, String s1) {
                        return false;
                    }

                    @Override
                    public void onConnectStateChange(String s, ConnectState connectState) {
                        System.out.println("连接状态发生变化 ：" + s + connectState);
                    }
                });

            }
        });
    }
}

2、管理门户配置远程控制，详细步骤参考链接。

_

3、启动设备端程序，管理门户批量更新，设备端获取信息(批量更新频率限制：一小时内仅允许操作一次)：

{"method":"thing.config.push","id":"1296799269","params":{"getType":"file","configId":"92eb82a17a7441111f7dcb830e93ed79","sign":"568e9211117eedc9eadbc2907719fe2086348f572ddd3f373d6f297ba5aba4d1","configSize":12,"signMethod":"Sha256","url":"https://otx-devicecenter-thing-config-cn-shanghai-online.oss-cn-shanghai.aliyuncs.com/11zisMUtYDk/1567338668042_gz2Qs7hl?Expires=1567340568&OSSAccessKeyId=1111113rx5dg2JBm&Signature=S0LS9H%1111zJqTg%2Fphf19%2BfE%2F2bs%3D"},"version":"1.0"}

场景二：设备主动请求配置信息

1、设备端业务代码实现

import com.aliyun.alink.dm.api.DeviceInfo;
import com.aliyun.alink.dm.api.InitResult;
import com.aliyun.alink.dm.api.IoTApiClientConfig;
import com.aliyun.alink.linkkit.api.ILinkKitConnectListener;
import com.aliyun.alink.linkkit.api.IoTMqttClientConfig;
import com.aliyun.alink.linkkit.api.LinkKit;
import com.aliyun.alink.linkkit.api.LinkKitInitParams;
import com.aliyun.alink.linksdk.cmp.connect.channel.MqttPublishRequest;
import com.aliyun.alink.linksdk.cmp.connect.channel.MqttSubscribeRequest;
import com.aliyun.alink.linksdk.cmp.core.base.AMessage;
import com.aliyun.alink.linksdk.cmp.core.base.ARequest;
import com.aliyun.alink.linksdk.cmp.core.base.AResponse;
import com.aliyun.alink.linksdk.cmp.core.base.ConnectState;
import com.aliyun.alink.linksdk.cmp.core.listener.IConnectNotifyListener;
import com.aliyun.alink.linksdk.cmp.core.listener.IConnectSendListener;
import com.aliyun.alink.linksdk.cmp.core.listener.IConnectSubscribeListener;
import com.aliyun.alink.linksdk.tools.AError;

public class DeviceCOTADemo2 {

    public static void main(String[] args) {
        String regionId = "cn-shanghai";
        DeviceInfo deviceInfo = new DeviceInfo();
        deviceInfo.productKey = "******";
        deviceInfo.deviceName = "******";
        deviceInfo.deviceSecret = "********";

        LinkKitInitParams params = new LinkKitInitParams();
        IoTMqttClientConfig config = new IoTMqttClientConfig();
        config.productKey = deviceInfo.productKey;
        config.deviceName = deviceInfo.deviceName;
        config.deviceSecret = deviceInfo.deviceSecret;
        config.channelHost = deviceInfo.productKey + ".iot-as-mqtt." + regionId + ".aliyuncs.com:1883";
        params.mqttClientConfig = config;
        params.connectConfig = new IoTApiClientConfig();
        params.deviceInfo = deviceInfo;

        /**建立连接**/
        LinkKit.getInstance().init(params, new ILinkKitConnectListener() {
            @Override
            public void onError(AError aError) {
                System.out.println("初始化失败 " + aError.getMsg());
            }

            @Override
            public void onInitDone(InitResult initResult) {

                System.out.println("初始化成功 " + initResult.tsl);

                String pd = deviceInfo.productKey + "/" + deviceInfo.deviceName;

                // 1、设备端订阅Topic：/sys/${productKey}/${deviceName}/thing/config/get_reply
                String requestcotaTopic = "/sys/"+pd+"/thing/config/get_reply";
                MqttSubscribeRequest upgradeTopicRequest = new MqttSubscribeRequest();
                upgradeTopicRequest.topic = requestcotaTopic;
                upgradeTopicRequest.isSubscribe = true;
                LinkKit.getInstance().subscribe(upgradeTopicRequest, new IConnectSubscribeListener(){
                    @Override
                    public void onSuccess() {
                        System.out.println("ota订阅成功");
                    }

                    @Override
                    public void onFailure(AError aError) {
                        System.out.println("直接订阅失败" + aError.getMsg());
                    }
                });

                // 注册下行监听
                LinkKit.getInstance().registerOnNotifyListener(new IConnectNotifyListener() {
                    @Override
                    public void onNotify(String s, String s1, AMessage aMessage) {

                        System.out.println("cota 监听响应:");
                        System.out.println(new String((byte[])aMessage.getData()));
                    }

                    @Override
                    public boolean shouldHandle(String s, String s1) {
                        return false;
                    }

                    @Override
                    public void onConnectStateChange(String s, ConnectState connectState) {
                        System.out.println("连接状态发生变化 ：" + s + connectState);
                    }
                });

                // 4、设备通过Topic /sys/${productKey}/${deviceName}/thing/config/get主动查询最新的配置信息
                String requestTopic = "/sys/"+pd+"/thing/config/get";

                System.out.println("发送消息" + requestTopic);

                // 订阅Topic
                MqttPublishRequest request = new MqttPublishRequest();
                request.topic = requestTopic;
                request.payloadObj = "{\"id\":\"123\",\"method\":\"thing.config.get\",\"params\":{\"getType\":\"file\",\"configScope\":\"product\"},\"version\":\"1.0\"}";

                // 直接做Topic的发送
                LinkKit.getInstance().publish(request, new IConnectSendListener() {
                    @Override
                    public void onResponse(ARequest aRequest, AResponse aResponse) {
                        System.out.println("请求发送成功 " + aResponse.getData());
                    }

                    @Override
                    public void onFailure(ARequest aRequest, AError aError) {
                        System.out.println("请求发送成功 " + aError.getMsg());
                    }
                });
            }
        });
    }
}

2、运行结果(/sys/${productKey}/${deviceName}/thing/config/get_reply 订阅获取的内容)

{"code":200,"data":{"configId":"a9415f2d6e444d7f9e60a3d46f11d566","configSize":18,"getType":"file","sign":"112f38e7345a2ac46d9f80a401886727f27de96ebf1c82b6825df4b31116ab02","signMethod":"Sha256","url":"https://otx-devicecenter-thing-config-cn-shanghai-online.oss-cn-shanghai.aliyuncs.com/11D8NwXCe56/1567337893929_gpUFnE69?Expires=1567339979&OSSAccessKeyId=11AIRY3rx5dg2JBm&Signature=1112qy8bOsa48elOQFt4qHQGaqk%3D"},"id":"123","method":"thing.config.get","version":"1.0"}

参考链接

远程配置

阿里云物联网平台NTP服务 JAVA 示例参考

文章标签：
物联网平台
云消息队列 MQ
物联网
Java
相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台，通过云产品流转到函数计算FC，调用钉钉群机器人API，实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品，7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前，请先开通下方两个云产品，让学习更流畅： IoT物联网平台：https://iot.console.aliyun.com/ LinkWAN物联网络管理平台：https://linkwan.console.aliyun.com/service-open
taro_秋刀鱼
目录
相关文章
三分钟热度的鱼
|
7月前
|
消息中间件 物联网 网络安全
MQTT常见问题之调用.net sdk 报“不知道这样的主机”如何解决
MQTT（Message Queuing Telemetry Transport）是一个轻量级的、基于发布/订阅模式的消息协议，广泛用于物联网（IoT）中设备间的通信。以下是MQTT使用过程中可能遇到的一些常见问题及其答案的汇总：
三分钟热度的鱼
194 2
芯在这
|
7月前
|
分布式计算 DataWorks Java
DataWorks操作报错合集之在使用MaxCompute的Java SDK创建函数时，出现找不到文件资源的情况，是BUG吗
DataWorks是阿里云提供的一站式大数据开发与治理平台，支持数据集成、数据开发、数据服务、数据质量管理、数据安全管理等全流程数据处理。在使用DataWorks过程中，可能会遇到各种操作报错。以下是一些常见的报错情况及其可能的原因和解决方法。
芯在这
88 0
sunrr
|
人工智能 Java 测试技术
地址标准化通过Java sdk接入通用经纬度查询之前已经调试成功，近期一直返回超时错误
地址标准化通过Java sdk接入通用经纬度查询之前已经调试成功，近期一直返回超时错误
sunrr
84 1
taro_秋刀鱼
|
4月前
|
Java API 数据中心
百炼平台Java 集成API上传文档到数据中心并添加索引
本文主要演示阿里云百炼产品，如何通过API实现数据中心文档的上传和索引的添加。
taro_秋刀鱼
113 3
AokSend接口-API
|
7月前
|
Java API Maven
email api java编辑方法？一文教你学会配置步骤
在Java开发中，Email API是简化邮件功能的关键工具。本文指导如何配置和使用Email API Java：首先，在项目中添加javax.mail-api和javax.mail依赖；接着，配置SMTP服务器和端口；然后，创建邮件，设定收件人、发件人、主题和正文；最后，使用Transport.send()发送邮件。借助Email API Java，可为应用添加高效邮件功能。
AokSend接口-API
79 1
浠博
|
自然语言处理 安全 Java
阿里云智能语音交互一句话识别Java SDK使用说明
一句话识别功能提供了对一分钟内的短语音进行识别，适用于对话聊天、控制口令、语音输入法、语音搜索等较短的语音识别场景。本文介绍如何使用阿里云智能语音服务提供的Java SDK，包括SDK的安装方法及SDK代码示例。
浠博
575 0
技术课堂的搬运工~
|
物联网 Java 开发工具
阿里云物联网平台远程配置功能JAVA 示例参考
本文主要演示如何使用JAVA SDK实现两种应用场景
技术课堂的搬运工~
405 0
阿里云物联网平台远程配置功能JAVA 示例参考
taro_秋刀鱼
|
JSON 算法 物联网
阿里云物联网平台独享实例一型一密免预注册Java使用示例
一型一密认证方式下，同一产品下所有设备可以烧录相同固件，包含相同的产品证书（ProductKey和ProductSecret）。设备发送激活请求时，物联网平台进行身份确认，认证通过，下发设备接入所需信息。一型一密包括设备预注册和非预注册两种方式，本文主要介绍独享实例非预注册的使用方式。
taro_秋刀鱼
890 0
阿里云物联网平台独享实例一型一密免预注册Java使用示例
taro_秋刀鱼
|
Java 开发工具 计算机视觉
阿里云地址标准化服务使用Java SDK示例
地址标准化（Address Purification）是依托阿里云海量的地址语料库，以及超强的NLP算法实力所沉淀出的高性能及高准确率的标准地址算法服务。该地址算法服务能解决一地多名，地址识别，地址真伪辨别等多种问题，为企业，政府机关以及开发者提供地址数据清洗，地址标准化能力，使地址数据更好的为业务提供支持。 本文分别使用服务SDK及Core SDK演示该服务的Java SDK调用方法。
taro_秋刀鱼
2895 0
阿里云地址标准化服务使用Java SDK示例
扬朋
如何获取会员信息（java版）-沙箱环境
说明： 本帖是利用支付宝沙箱测试获取会员信息接口，demo中会配置个人的沙箱账号信息，方便大家测试。 测试环境：JAVA1.5+，eclipse 接口文档：【查看】 沙箱环境测试改正式环境测试请修改网关为下方值 正式环境网关：[url]https://openapi.
扬朋
588 12

物联网

热门文章

最新文章

  • 1
    物联网技术在智能医疗的应用
  • 2
    阿里云物联网平台设备升级OTA演示
  • 3
    基于开源MQTT自主接入阿里云IoT平台（Python）
  • 4
    基于开源MQTT自主接入阿里云IoT平台（Java）
  • 5
    物联网为电信业带来千亿级新市场
  • 6
    创新探索，在物联网中进行持续部署
  • 7
    关于IoT网络的一些特征的探讨
  • 8
    AliOS Things 基于组件化思想的多bin特性
  • 9
    【视频】广州阿里云峰会回顾：物联网平台产品新功能
  • 10
    物联网通信协议的详解及选择建议
  • 1
    jdk8新特性-详情查看文档
    8
  • 2
    java中面向过程和面向对象区别?
    6
  • 3
    jar包目录介绍
    40
  • 4
    「Mac畅玩鸿蒙与硬件37」UI互动应用篇14 - 随机颜色变化器
    50
  • 5
    简单粗暴的正则表达式笔记
    44
  • 6
    「Mac畅玩鸿蒙与硬件36」UI互动应用篇13 - 数字滚动抽奖器
    43
  • 7
    5G物联网卡普及说明
    14
  • 8
    「Mac畅玩鸿蒙与硬件35」UI互动应用篇12 - 简易日历
    27
  • 9
    「Mac畅玩鸿蒙与硬件34」UI互动应用篇11 - 颜色选择器
    18
  • 10
    Java 中的注解（Annotations）：代码中的 “元数据” 魔法
    27

    • 相关产品

  • 物联网平台
    文档详情 产品详情

    • 相关课程

    更多
  • Java高级开发
  • 物联网平台开发全栈教程
  • 阿里云物联网平台开发
  • 物联网平台实战课程
  • 物联网平台云上开发
  • Java Web项目实战 - 图书商城

    • 相关电子书

    更多
  • JAVA 应用排查全景图
  • 阿里云物联网平台属性，事件，服务详解
  • Jpom一款低侵入式Java运维、监控软件

    • 相关实验场景

    更多
  • 快速体验智能体API应用
  • 函数计算入门-HelloWorld应用开发
  • 温控器设备接入IoT物联网平台与数据管理实践
  • 使用物联网平台远程管理运维设备
  • 阿里云平台上进行Java程序的编译与运行
  • 阿里云IoT小程序应用开发和组件实践
    • 下一篇
    阿里云无影云电脑免费试用，最长可试用3个月