調用步驟

1. 已完成SDK客戶端初始化。具體內容，請參見初始化SDK。

2. 創建對應API的調用請求，生成${API名稱}+"Request"類對象實例request。

3. 通過對象實例request，使用set+${請求參數的名稱}方法，設置API所需的請求參數值。

4. 創建${API名稱}+"Response"類的對象實例response承載響應結果：使用Client對象實例client的${API名稱}(request)方法，獲取API對應request的響應結果，包含服務端響應的body和headers。

5. 通過對象實例response的body成員對象，使用get+${返回參數的名稱}方法，可獲取對應返回參數的值。

   例如：response.getbody.getSuccess()用于獲取是否調用成功的標識，其中Success為API的通用返回參數。通用返回參數還包含RequestId、ErrorMessage和Code。

6. 使用catch()方法處理異常報錯。

物聯網平臺云端API，請參見API列表。有關request中請求參數說明，及response中返回參數說明，請參見對應API文檔。

本文以調用Pub接口發布消息到Topic為例。請求參數信息，請參見Pub。

PubRequest request = new PubRequest()
    .setIotInstanceId("${iotInstanceId}")
    .setProductKey("${productKey}")
    .setMessageContent(Base64.getEncoder().encodeToString("hello world".getBytes()))
    .setTopicFullName("/${productKey}/${deviceName}/user/get")
    .setQos(0);//目前支持QoS0和QoS1。 
try {
    PubResponse response = client.pub(request);
    // response中包含服務端響應的body和headers。 
    //獲取本次調用requestId。
    System.out.println(response.getBody().getRequestId());
    //調用是否成功。
    System.out.println(response.getBody().getSuccess());
    
    //調用成功。
    if (response.getBody().getSuccess()) {
        //獲取云端消息ID。
        System.out.println(response.getBody().getMessageId());
        
        //do業務邏輯。
        
    } else {
    //調用失敗。            
        //獲取調用失敗錯誤碼。
        System.out.println(response.getBody().getCode());
        //獲取調用失敗錯誤描述。
        System.out.println(response.getBody().getErrorMessage());
     }
} catch (TeaException error) {
    //服務端業務異常。
    System.out.println(error.getCode());
    System.out.println(error.getMessage());
} catch (Exception e) {
    //其他運行時異常。
    e.printStackTrace();
}

完整示例代碼

import com.aliyun.iot20180120.Client;
import com.aliyun.iot20180120.models.PubRequest;
import com.aliyun.iot20180120.models.PubResponse;
import com.aliyun.tea.TeaException;
import com.aliyun.teaopenapi.models.Config;
import java.util.Base64;

public class IotSdkDemo {
    /**
     * 使用AK&SK初始化Client。
     */
    private static Client createClient(String accessKeyId, String accessKeySecret) throws Exception {
        com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
                // 必填，您的 AccessKey ID
                .setAccessKeyId(accessKeyId)
                // 必填，您的 AccessKey Secret
                .setAccessKeySecret(accessKeySecret);
        // Endpoint 請參考 https://api.aliyun.com/product/Iot
        config.endpoint = "iot.cn-beijing.aliyuncs.com";
        return new Client(config);
    }

    public static void main(String[] args) {
        try {
            Client client = createClient(accessKey, accessKeySecret);
            PubRequest request = new PubRequest()
                .setIotInstanceId("${iotInstanceId}")
                .setProductKey("${productKey}")
                .setMessageContent(Base64.getEncoder().encodeToString("hello world".getBytes()))
                .setTopicFullName("/${productKey}/${deviceName}/user/get")
                .setQos(0);//目前支持QoS0和QoS1。 
            
            PubResponse response = client.pub(request);            
            //獲取本次調用requestId。
      System.out.println(response.getBody().getRequestId());
      //調用是否成功。
      System.out.println(response.getBody().getSuccess());
            
         //調用成功。
       if (response.getBody().getSuccess()) {
          //獲取云端消息ID。
          System.out.println(response.getBody().getMessageId());
        
          //do業務邏輯。
      } else {
       //調用失敗。            
          //獲取調用失敗錯誤碼。
             System.out.println(response.getBody().getCode());
          //獲取調用失敗錯誤描述。
          System.out.println(response.getBody().getErrorMessage());
      }
        } catch (TeaException error) {
            //服務端業務異常。
      System.out.println(error.getCode());
      System.out.println(error.getMessage());
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}