IoT Platform:IoT Platform SDK for Java の使用

手順

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

2. リクエスト${API名} + "Request" クラスの インスタンスを生成して、API リクエストを作成します。

3. set+${リクエスト パラメーター} メソッドを リクエスト インスタンスで呼び出して、リクエスト パラメーターを指定します。

4. レスポンス${API名} + "Response" クラスの ${API名}(リクエスト)クライアント本文ヘッダー インスタンスを作成してレスポンスを取得します。 インスタンスの メソッドを呼び出して、API リクエストに対するレスポンスを取得します。レスポンスには、サーバーから返された と が含まれます。

5. 本文レスポンスget+${[レスポンス パラメーター]} インスタンスの オブジェクトを使用し、 メソッドを呼び出して、レスポンスパラメーターの値を取得します。

   たとえば、response.getBody.getSuccess() メソッドが呼び出され、Success パラメーターの値が取得されます。このパラメーターは一般的なレスポンスパラメーターであり、呼び出しが成功したかどうかを示します。一般的なレスポンスパラメーターには、RequestId、ErrorMessage、および Code も含まれます。

6. catch() メソッドを呼び出して、例外を処理します。

IoT Platform の API 操作の詳細については、「関数別の操作リスト」をご参照ください。各 API 操作のリクエストパラメーターとレスポンスパラメーターの詳細については、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);
// サーバーから返された本文とヘッダーを含むレスポンス。
// リクエストの ID を取得します。
    System.out.println(response.getBody().getRequestId());
    // 呼び出しが成功したかどうかを確認します。
    System.out.println(response.getBody().getSuccess());

    // 呼び出しが成功しました。
    if (response.getBody().getSuccess()) {
        // IoT Platform から送信されたメッセージの ID を取得します。
        System.out.println(response.getBody().getMessageId());

        // else 文。

    } 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 Secret を使用してクライアントを初期化します。
     */
    private static Client createClient(String accessKeyId, String accessKeySecret) throws Exception {
        Config config = new Config();
        config.accessKeyId = accessKeyId;
        config.accessKeySecret = accessKeySecret;
        // リージョンの ID。
        config.regionId = "cn-shanghai";
        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);            
            // リクエストの ID を取得します。
      System.out.println(response.getBody().getRequestId());
      // 呼び出しが成功したかどうかを確認します。
      System.out.println(response.getBody().getSuccess());

         // 呼び出しが成功しました。
       if (response.getBody().getSuccess()) {
          // IoT Platform から送信されたメッセージの ID を取得します。
          System.out.println(response.getBody().getMessageId());

          // else 文。
      } 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();
        }
    }
}