阿里云物联网管理SDK使用示例

简介: 目前阿里云的绝大部分服务都提供了管理资源的Rest API,针对相应的API也做了SDK的封装,且版本也在不断的迭代更新。管理API SDK的统一GitHub地址链接。关于IoT SDK的使用,之前官方也给出了示例参考,但是该示例使用的SDK版本为5.0.0,且这个版本的SDK中没有DeleteProductRequest类的实现,下面演示使用目前最新版本:6.5.0关于产品的创建及删除操作,其它操作类似。

概述

目前阿里云的绝大部分服务都提供了管理资源的Rest API,针对相应的API也做了SDK的封装,且版本也在不断的迭代更新。管理API SDK的统一GitHub地址链接。关于IoT SDK的使用,之前官方也给出了示例参考,但是该示例使用的SDK版本为5.0.0,且这个版本的SDK中没有DeleteProductRequest类的实现,下面演示使用目前最新版本:6.5.0关于产品的创建及删除操作,新建Topic间的消息路由关系、查询向指定Topic订阅消息的目标Topic操作,其它操作类似。

pom依赖

        <!--核心依赖-->
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-core</artifactId>
            <version>3.5.0</version>
        </dependency>

        <!--管理API SDK调用问题-->
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-iot</artifactId>
            <version>6.5.0</version>
        </dependency>

Java示例代码

import com.aliyuncs.AcsResponse;
import com.aliyuncs.DefaultAcsClient;
import com.aliyuncs.RpcAcsRequest;
import com.aliyuncs.exceptions.ClientException;
import com.aliyuncs.iot.model.v20180120.CreateProductRequest;
import com.aliyuncs.iot.model.v20180120.CreateProductResponse;
import com.aliyuncs.iot.model.v20180120.DeleteProductRequest;
import com.aliyuncs.iot.model.v20180120.DeleteProductResponse;
import com.aliyuncs.profile.DefaultProfile;
import com.aliyuncs.profile.IClientProfile;

public class IoTDemo {

    public static void main(String[] args) {

        String productName = "iottestdemo123456";
        String productKey = "******";
        Integer nodeType = 0;
//      createProductTest(productName,nodeType);
        deleteProductTest(productKey);
        System.out.println("删除成功");
    }


    /**
     * 创建产品
     * @param productName 产品名称
     * @param nodeType 产品描述
     * @return 产品的PK
     */
    public static String createProductTest(String productName, Integer nodeType) {
        CreateProductRequest request = new CreateProductRequest();
        request.setProductName(productName);

        request.setNodeType(nodeType);//节点的类型,0标识设备,1标识网关
        CreateProductResponse response = (CreateProductResponse)executeTest1(request);
        if (response != null && response.getSuccess() != false) {
            System.out.println("创建产品成功!productKey:" + response.getProductKey());
            return response.getProductKey();
        } else {
            System.out.println("创建产品失败!requestId:" + response.getRequestId() + "原因:" + response.getErrorMessage());
        }
        return null;
    }

    /**
     * 删除产品
     * @param productKey 产品key
     * @return 产品的PK,可以在管理门户获取
     */
    public static Boolean deleteProductTest(String productKey) {
        DeleteProductRequest request = new DeleteProductRequest();
        request.setProductKey(productKey);
        DeleteProductResponse response = (DeleteProductResponse)executeTest1(request);
        if (response != null && response.getSuccess() != false) {
            System.out.println("删除产品成功!productKey:" + response.getSuccess());
            return response.getSuccess();
        } else {
            System.out.println("创建产品失败!requestId:" + response.getRequestId() + "原因:" + response.getErrorMessage());
        }
        return false;
    }
    
    public static AcsResponse executeTest1(RpcAcsRequest request) {

        DefaultAcsClient client = null;
        String regionId = "cn-shanghai";
        String accessKeyID = "********";
        String accessKeySecret = "********";
        String productCode = "Iot";
        String domain = "iot.cn-shanghai.aliyuncs.com";
        IClientProfile profile = DefaultProfile.getProfile(regionId, accessKeyID, accessKeySecret);
        try {
            DefaultProfile.addEndpoint(regionId, regionId, productCode, domain);
        } catch (ClientException e) {
            e.printStackTrace();
        }
        // 初始化client
        client = new DefaultAcsClient(profile);

        System.out.println("client 初始化完成!");

        AcsResponse response = null;
        try {
            response = client.getAcsResponse(request);
        } catch (Exception e) {
            System.out.println("执行失败:e:" + e.getMessage());
        }
        return response;
    }

    /**
     * 新建Topic间的消息路由关系
     */
    public static void CreateTopicRouteTable() {
        CreateTopicRouteTableRequest request = new CreateTopicRouteTableRequest();
        request.setSrcTopic("/a1D8NwXCe56/device1/user/TopicToTopicDemo"); // 源Topic,即被订阅的Topic。
        List<String> dstTopics = new ArrayList<String>();
        dstTopics.add("/a1D8NwXCe56/ceshi/user/TopicToTopicDemo"); // 目标Topic列表,即从SrcTopic订阅消息的Topic列表。
        request.setDstTopics(dstTopics);
        CreateTopicRouteTableResponse response = (CreateTopicRouteTableResponse)executeTest1(request);
        if (response != null && response.getSuccess() != false) {
            System.out.println("CreateTopicRouteTable 成功:" + response.getSuccess());
        } else {
            System.out.println("CreateTopicRouteTable, requestId:" + response.getRequestId() + "原因:" + response.getErrorMessage());
        }
    }

    /**
     *  查询向指定Topic订阅消息的目标Topic
     */
    public static void QueryTopicRouteTable() {
        QueryTopicRouteTableRequest request = new QueryTopicRouteTableRequest();
        request.setActionName("QueryTopicRouteTable");
        request.setTopic("/a1D8NwXCe56/device1/user/TopicToTopicDemo"); // 要查询的源Topic,即发布消息的Topic。
        QueryTopicRouteTableResponse response = (QueryTopicRouteTableResponse)executeTest1(request);
        if (response != null && response.getSuccess() != false) {
            System.out.println("QueryTopicRouteTable 成功:" + response.getSuccess());
            System.out.println(response.getDstTopics());
        } else {
            System.out.println("CreateTopicRouteTable, requestId:" + response.getRequestId() + "原因:" + response.getErrorMessage());
        }
    }
}

注意

当前阶段国内只有上海地区支持IoT服务,用户只需要根据需求替换AK及IoT的信息即可。删除产品的前提是产品中没有设备,管理门户目前删除产品需要短信验证码,直接使用SDK调用不需要验证码。

参考链接

IoT SDK Demo

API列表

相关实践学习
钉钉群中如何接收IoT温控器数据告警通知
本实验主要介绍如何将温控器设备以MQTT协议接入IoT物联网平台,通过云产品流转到函数计算FC,调用钉钉群机器人API,实时推送温湿度消息到钉钉群。
阿里云AIoT物联网开发实战
本课程将由物联网专家带你熟悉阿里云AIoT物联网领域全套云产品,7天轻松搭建基于Arduino的端到端物联网场景应用。 开始学习前,请先开通下方两个云产品,让学习更流畅: IoT物联网平台:https://iot.console.aliyun.com/ LinkWAN物联网络管理平台:https://linkwan.console.aliyun.com/service-open
相关文章
|
13天前
|
网络协议 安全 调度
阿里云公共DNS发布支持鸿蒙系统版的SDK
阿里云公共DNS发布支持鸿蒙系统版SDK,赋能鸿蒙开发者快速接入阿里云公共DNS服务。公共DNS将帮助接入的鸿蒙应用免除LocalDNS劫持困扰、解析加速、精准调度。
|
编解码 安全 算法
基于W800 SDK实战智能生活平台接入|学习笔记
快速学习基于W800 SDK实战智能生活平台接入
345 0
基于W800 SDK实战智能生活平台接入|学习笔记
|
域名解析 安全 网络协议
阿里云 IoT 模组安全 SDK 集成范例
本文档介绍如何使用资源极低的 ESP32/8266 WiFi 模组进行前期开发联调与 BSP 无关的业务功能。方便开发人员快速上手。在基本业务功能端到端调试完毕之后再将标准的 C 语言程序移植到 cat1 或者 NBIoT 无线模组开发环境进行后续 BSP 的开发或者适配。
881 0
HH
|
物联网 API 开发工具
物联网平台之python语言的设备端接入、云端sdk集成调用
本文介绍如何调用Python语言的Paho MQTT类库,将设备接入阿里云物联网平台,并进行消息收发。 以及物联网平台提供Python语言的云端SDK供开发人员使用。本文介绍云端Python SDK的安装和配置,及使用Python SDK调用云端API的示例。
HH
760 0
物联网平台之python语言的设备端接入、云端sdk集成调用
|
人工智能 移动开发 运维
阿里云物联网开发工具IoT Studio发布升级版 新增移动可视化能力
近日,阿里云AIoT物联网应用开发工具IoT Studio 发布了升级版,全面支持物联网平台企业实例功能、新增移动可视化能力,同时,丰富了解决方案模版,帮助用户经济高效的完成物联网应用开发,提高物联网行业的生产力。
475 0
阿里云物联网开发工具IoT Studio发布升级版 新增移动可视化能力
|
物联网 Java API
物联网平台 - 云端API使用方式
物联网平台提供云端管理产品、设备、分组、Topic、规则、设备影子等API接口,和从云端发布消息的API接口。使用云端SDK,向API的服务端地址发送HTTPS/HTTP GET或POST请求,并按照API接口说明,在请求中加入相应请求参数来调用API。物联网平台根据请求的处理情况,返回处理结果
654 0
物联网平台 - 云端API使用方式
|
存储 物联网 数据挖掘
阿里云物联网平台 - iot studio调用 “新版本数据分析” 接口展示设备数据
物联网数据分析LA(Link Analytics)是阿里云为物联网开发者提供的数据智能分析产品,针对物联网数据特点,提供海量数据的存储备份、资产管理、报表分析和数据服务等能力,帮助企业用户更容易地挖掘物联网数据中的价值
504 0
阿里云物联网平台 - iot studio调用 “新版本数据分析” 接口展示设备数据
|
SQL 存储 数据采集
阿里云物联网平台 - iot studio调用 “老版本数据分析” 接口展示设备数据
老版本数据分析:是阿里云为物联网开发者提供的设备智能分析服务,全链路覆盖了设备数据采集、管理(存储)、清洗、分析等环节,有效降低了数据分析门槛,实现了设备数据与业务数据的融合分析透视
340 0
阿里云物联网平台 - iot studio调用 “老版本数据分析” 接口展示设备数据
|
XML 物联网 Java
阿里云物联网平台之云端API调用(即云端开发)
本文介绍如何调用物联网平台的云端API,很多时候控制台上操作不太方便,需要通过API调用来完成或者通过调用API封装接口,以做到二次开发等。如产品管理,设备管理,规则创建等。分别介绍通过common SDK和iot SDK的使用。
5357 0
阿里云物联网平台之云端API调用(即云端开发)
|
移动开发 安全 物联网
阿里云物联网平台C-SDK 4.x OTA升级示例
本篇文章演示如何使用C-SDK 4.x Demo 做OTA升级
1077 0
阿里云物联网平台C-SDK 4.x OTA升级示例

热门文章

最新文章

相关产品

  • 物联网平台