IoT Platform:Java SDK の使用

呼び出し手順

1. SDK クライアントを初期化します。詳細については、「SDK の初期化」をご参照ください。

2. API 呼び出し用に、 request という名前の ${API name}+"Request" オブジェクトインスタンスを作成します。

3. request オブジェクトの set+${Request parameter name} メソッドを呼び出して、必須のリクエストパラメーターを設定します。

4. response という名前の ${API name}+"Response" オブジェクトインスタンスを作成します。 client オブジェクトの ${API name}(request) メソッドを呼び出して、レスポンスを取得します。レスポンスには、サーバーからの body と headers が含まれます。

5. response オブジェクトの body メンバーの get+${Response parameter name} メソッドを呼び出して、レスポンスパラメーターの値を取得します。

   たとえば、 response.getBody().getSuccess() は成功フラグを取得します。 Success は、共通のレスポンスパラメーターです。その他の共通レスポンスパラメーターには、 RequestId、 ErrorMessage、 Code などがあります。

6. catch() メソッドを使用して例外を処理します。

IoT Platform クラウド API の完全なリストについては、「API リスト」をご参照ください。リクエストおよびレスポンスパラメーターの説明については、各 API のドキュメントをご参照ください。

次の例では、Pub API を使用してトピックにメッセージを公開します。リクエストパラメーターの詳細については、「Pub」をご参照ください。

PubRequest request = new PubRequest()
    .setIotInstanceId("${iotInstanceId}")
    .setProductKey("${productKey}")
    .setMessageContent(Base64.getEncoder().encodeToString("hello world".getBytes()))
    .setTopicFullName("/${productKey}/${deviceName}/user/get")
    .setQos(0);// QoS 0 と QoS 1 をサポートしています。 
try {
    PubResponse response = client.pub(request);
    // レスポンスには、サーバー側の body と headers が含まれます。 
    // この呼び出しのリクエスト ID を取得します。
    System.out.println(response.getBody().getRequestId());
    // 呼び出しが成功したかどうかを確認します。
    System.out.println(response.getBody().getSuccess());
    
    // 呼び出しは成功しました。
    if (response.getBody().getSuccess()) {
        // クラウドからメッセージ ID を取得します。
        System.out.println(response.getBody().getMessageId());
        
        // ビジネスロジックを実装します。
        
    } 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 {
    /**
     * AccessKey ID と AccessKey シークレットを使用してクライアントを初期化します。
     */
    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 シークレット。
                .setAccessKeySecret(accessKeySecret);
        // エンドポイントについては、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(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"), System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
            PubRequest request = new PubRequest()
                .setIotInstanceId("${iotInstanceId}")
                .setProductKey("${productKey}")
                .setMessageContent(Base64.getEncoder().encodeToString("hello world".getBytes()))
                .setTopicFullName("/${productKey}/${deviceName}/user/get")
                .setQos(0);// QoS 0 と QoS 1 をサポートしています。 
            
            PubResponse response = client.pub(request);            
            // この呼び出しのリクエスト ID を取得します。
      System.out.println(response.getBody().getRequestId());
      // 呼び出しが成功したかどうかを確認します。
      System.out.println(response.getBody().getSuccess());
            
         // 呼び出しは成功しました。
       if (response.getBody().getSuccess()) {
          // クラウドからメッセージ ID を取得します。
          System.out.println(response.getBody().getMessageId());
        
          // ビジネスロジックを実装します。
      } 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();
        }
    }
}