开发者社区> taro_秋刀鱼> 正文

阿里云物联网管理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列表

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

相关文章
什么是阿里云服务器管理软件?如何管理?
云服务器(Elastic Compute Service ,简称ECS )是阿里云提供的性能卓越、稳定可靠、弹性扩展的IaaS (Infrastructure as a Service )级别云计算服务。
336 0
产品百科 | RTC Android SDK 如何进行音频管理
阿里云 RTC SDK 为您提供开启或关闭耳返功能、设置耳返音量的方法,通过本章节,您可以了解其实现方法。
88 0
阿里云物联网平台基于iOS Link kit SDK做OTA升级
第一次在平台写文章,如有错误,请多多包涵
271 0
产品百科 | RTC iOS SDK 如何进行音频管理
阿里云 RTC SDK 为您提供开启或关闭耳返功能、设置耳返音量的方法,通过本章节,您可以了解其实现方法。
95 0
使用developer kit 初步打通阿里生活物联网平台
最近小编又发现了一块新大陆,阿里智能生活平台,那么什么是阿里智能生活平台呢。阿里的官方解释如下:生活物联网平台,顾名思义就是应用于生活,以解决家电设备快速智能化的问题。平台针对家电智能化的设备连接、移动端控制、设备管理、数据统计等问题,打包阿里云多款产品,提供了一整套配置化方案,大幅减低“设备-云端-App”的开发成本。
1797 0
Node.js SDK 使用方法及代码示例
本文介绍了如何使用阿里云视觉智能开放平台相关服务的Node.js SDK,具体包括SDK的获取和安装方法以及SDK代码示例。
466 0
【云栖号案例 | 物联网&人工智能】鸿达公司高效复工稳产 生产管理效率提升50%
疫情期间,制造业面临巨大生存压力。企业选择方案中三个SaaS模块化应用,进行了有效的复工复产安排,帮助企业复工生产管理效率提升50%以上。
1273 0
阿里云联合思普瑞上线平安社区服务平台 提供物联网一站式管理
2019年6月11日,阿里云联合蚂蚁金服、思普瑞集团携手研发的平安社区服务平台正式上线。
17021 0
+关注
taro_秋刀鱼
博客园主页:https://home.cnblogs.com/u/taro/
244
文章
13
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载