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

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

2020-04-03 648
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 本文主要演示如何使用JAVA SDK实现两种应用场景

作者：俏巴

概述

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

原理说明

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

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

2、流程图
image.png

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、管理门户配置远程控制，详细步骤参考链接。

image.png

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"}

参考链接
----
[远程配置](https://help.aliyun.com/document_detail/84891.html?spm=a2c4e.11153940.0.0.74486ec8BMciHh)
文章标签：
物联网平台
云消息队列 MQ
Java
开发工具
物联网
开发者
相关实践学习
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品，7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前，请先开通下方两个云产品，让学习更流畅： IoT物联网平台：https://iot.console.aliyun.com/ LinkWAN物联网络管理平台：https://linkwan.console.aliyun.com/service-open
技术课堂的搬运工~
目录
相关文章
路边两盏灯
|
11月前
|
Java 开发工具
【Azure Storage Account】Java Code访问Storage Account File Share的上传和下载代码示例
本文介绍如何使用Java通过azure-storage-file-share SDK实现Azure文件共享的上传下载。包含依赖引入、客户端创建及完整示例代码，助你快速集成Azure File Share功能。
路边两盏灯
705 6
啦啦啦191
|
12月前
|
IDE Java 关系型数据库
Java 初学者学习路线（含代码示例）
本教程为Java初学者设计，涵盖基础语法、面向对象、集合、异常处理、文件操作、多线程、JDBC、Servlet及MyBatis等内容，每阶段配核心代码示例，强调动手实践，助你循序渐进掌握Java编程。
啦啦啦191
1380 3
啦啦啦191
|
12月前
|
Java
java入门代码示例
本文介绍Java入门基础，包含Hello World、变量类型、条件判断、循环及方法定义等核心语法示例，帮助初学者快速掌握Java编程基本结构与逻辑。
啦啦啦191
790 0
Java API 开发者
442 0
啦啦啦191
|
安全 Java 网络安全
Java 实现 SMTP 协议调用的详细示例及实战指南 SMTP Java 调用示例
本文介绍了如何使用Java调用SMTP协议发送邮件，涵盖SMTP基本概念、JavaMail API配置、代码实现及注意事项，适合Java开发者快速掌握邮件发送功能集成。
啦啦啦191
1588 0
ap4694y9w
|
算法 搜索推荐 Java
Java中的Collections.shuffle()方法及示例
`Collections.shuffle()` 是 Java 中用于随机打乱列表顺序的方法，基于 Fisher-Yates 算法实现，支持原地修改。可选传入自定义 `Random` 对象以实现结果可重复，适用于抽奖、游戏、随机抽样等场景。
ap4694y9w
511 0
游客ib7xsk7hcucuo
|
Java
银行转账p图软件，对公转账截图生成器，java版开发银行模拟器【仅供学习参考】
这是一套简单的银行账户管理系统代码，包含`BankAccount`和`BankSystem`两个核心类。`BankAccount`负责单个账户的管理
游客ib7xsk7hcucuo
986 1
啦啦啦191
|
存储 安全 Java
应届生面试高频 Java 基础问题及实操示例解析
本文总结了Java基础面试中的高频考点，包括数据类型分类、final修饰符的三种用途、static关键字特性、==与equals的区别、Java只有值传递的特性、String的不可变性、Error与Exception的差异、程序初始化顺序规则，以及IO流的字节流/字符流分类。每个问题都配有简明定义和典型示例，如用final修饰变量示例、static方法调用限制说明等，帮助应聘者快速掌握核心概念和实际应用场景。
啦啦啦191
450 0
啦啦啦191
|
Java 关系型数据库 MySQL
2025 年互联网公司校招 Java 面试题总结及答案实操示例解析
本项目基于Spring Boot 3与Java 17技术栈，围绕校园招聘常见面试题，提供核心知识点的实操示例。涵盖多线程、RESTful API设计、数据库操作（Spring Data JPA）、事务管理及异常处理等。通过完整代码实现与运行步骤，帮助理解用户管理、线程池配置等实际应用场景。资源包含项目结构、关键代码示例（如User实体类、UserService服务层、ThreadService多线程实现）及数据库迁移脚本，适合深入学习与实践。环境要求：JDK 17+、Maven 3.8+、MySQL 8.0+。
啦啦啦191
505 3

物联网

热门文章

最新文章

  • 1
    使用MQTT客户端连接阿里云MQTT服务器
  • 2
    物联网+智慧城建，智慧城市建设的新动能
  • 3
    阿里云的物联网之路
  • 4
    阿里云联合思普瑞上线平安社区服务平台 提供物联网一站式管理
  • 5
    阿里云新推出 HiTSDB + IoT套件 物联网设备上云步入快车道
  • 6
    吃『派』那些事儿——阿里云物联网平台树莓派实战集锦
  • 7
    阿里云物联网消息透传设备端payLoad设置问题
  • 8
    庆科：从安全设计上突破，云上物联网操作系统进化之路
  • 9
    AliOS Things开发：让你的开发板支持AliOS Studio烧录
  • 10
    LoRaWAN开放式实验平台
  • 1
    从1688五大流量入口看B2B电商流量分发的结构化演进
    11
  • 2
    RFID成为电动车精细化治理的核心手段
    26
  • 3
    SEO多账号同机操作总被归并？从浏览器指纹原理拆解环境隔离的底层逻辑
    25
  • 4
    从源码级hook到同步器：社媒多账号环境隔离机制拆解
    22
  • 5
    云手机与指纹浏览器在Lazada运营中的分工解析
    24
  • 6
    为什么独立IP加独立指纹加Cookie隔离是亚马逊多店的底线
    28
  • 7
    Temu多店运营被判定关联？从浏览器指纹机制看环境隔离怎么做
    25
  • 8
    透明加密软件：不改变使用习惯的加密是怎么实现的
    31
  • 9
    DLP数据防泄漏软件：装在本机上的那一层凭什么管用
    26
  • 10
    数据全生命周期监控：数据走到哪一段，谁在看着
    29

    • 相关产品

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

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • JAVA开发手册1.5.0
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！