物联网平台的Java SDK让开发人员可以方便地使用Java程序操作物联网平台。开发者可以使用Maven依赖添加SDK,也可以下载安装包到本地直接安装。
安装SDK
安装Java开发环境。
您可以从Java 官方网站下载,并按说明安装Java开发环境。
安装IoT Java SDK。
访问Apache Maven 官网下载Maven软件。
添加Maven项目依赖。
最新版IoT Java SDK的Maven依赖坐标:
<!-- https://mvnrepository.com/artifact/com.aliyun/aliyun-java-sdk-iot --> <dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-iot</artifactId> <version>7.28.0</version> </dependency>
阿里云Java SDK公共包Maven依赖坐标:
<dependency> <groupId>com.aliyun</groupId> <artifactId>aliyun-java-sdk-core</artifactId> <version>3.5.1</version> </dependency>
初始化SDK
首先创建IClientProfile对象profile,存放SDK初始化信息,然后创建DefaultAcsClient对象实例client,通过DefaultAcsClient(profile)
方法,加载profile中的SDK信息,完成SDK客户端初始化。
String accessKey = "${accessKey}";
String accessSecret = "${accessSecret}";
IClientProfile profile = DefaultProfile.getProfile("${RegionId}", accessKey, accessSecret);
DefaultAcsClient client = new DefaultAcsClient(profile); //初始化SDK客户端。
参数 | 说明 |
accessKey | 您账号的AccessKey ID。 您可在阿里云官网控制台AccessKey管理中创建或查看您的AccessKey。 |
accessSecret | 您账号的AccessKey Secret。 |
profile | profile对象用于存放SDK初始化信息,其中 您可在物联网平台控制台左上方,查看当前服务所在地域。 |
以调用华东2(上海)地域的API为例,初始化代码如下。
String accessKey = "${accessKey}";
String accessSecret = "${accessSecret}";
IClientProfile profile = DefaultProfile.getProfile("cn-shanghai", accessKey, accessSecret);
DefaultAcsClient client = new DefaultAcsClient(profile);
发起调用
物联网平台云端SDK为每个API封装两个类,分别命名为${API名称}+"Request"
和${API名称}+"Response"
。
${API名称}+"Request"
:用于API的调用请求。通过该类的对象实例request
,使用set+${请求参数的名称}
方法,设置请求参数值。${API名称}+"Response"
:使用DefaultAcsClient对象实例client的getAcsResponse(request)
方法,承载API的调用结果。通过该类的对象实例response
,使用get+${返回参数的名称}
的方法,可获取对应返回参数的值。例如:
response.getSuccess()
用于获取是否调用成功的标识,其中Success为API的通用返回参数。通用返回参数还包含RequestId、ErrorMessage和Code。
有关request
中请求参数说明,及response
中返回参数说明,请参见对应API文档。
本文以调用Pub接口发布消息到Topic为例。
以下代码中${iotInstanceId}
为实例ID值。您可在物联网平台控制台的实例概览页面,查看当前实例的ID值。
若有ID值,必须传入该ID值,否则调用API会失败。
若无实例概览页面或ID值,则无需传入。您需删除IotInstanceId相关的请求代码,或传入空值
""
,否则调用API会失败。实例的详细内容,请参见实例概述。
PubRequest request = new PubRequest();
request.setIotInstanceId("${iotInstanceId}");
request.setProductKey("${productKey}");
request.setMessageContent(Base64.encodeBase64String("hello world".getBytes()));
request.setTopicFullName("/${productKey}/${deviceName}/user/get");
request.setQos(0); //目前支持QoS0和QoS1。
try
{
PubResponse response = client.getAcsResponse(request);
System.out.println(response.getSuccess());
System.out.println(response.getCode());
System.out.println(response.getErrorMessage());
}
catch (ServerException e)
{
e.printStackTrace();
}
catch (ClientException e)
{
System.out.println("ErrCode:" + e.getErrCode());
System.out.println("ErrMsg:" + e.getErrMsg());
e.printStackTrace();
}