华为云应用侧Android Studio开发

{
    "auth": {
        "identity": {
            "methods": [
                "password"
            ],
            "password": {
                "user": {
                    "domain": {
                        "name": "IAMDomain"        //IAM用户所属账号名
                    },
                    "name": "IAMUser",             //IAM用户名
                    "password": "IAMPassword"      //IAM用户密码
                }
            }
        },
        "scope": {
           "project": {
                "name": "xxxxxxxx"
            }
        }
    }
}

其中IAM用户名为“IAMUser”，IAM用户密码为“IAMPassword”，所属账号名为“IAMDomain”，在本次实验中个参数如下：

<uses-permission android:name="android.permission.INTERNET" />

private static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
private static final OkHttpClient client = new OkHttpClient(); // 假设OkHttpClient是线程安全的，可以作为静态成员

// 方法签名修改为接受必要的参数
public String getIAMToken(String huaweiName, String iamIname, String iamPassword, String iamTokenUrl) throws IOException {
    // 构建JSON请求体
    String jsonBody = String.format("{\"auth\": {\"identity\": {\"methods\": [\"password\"],\"password\": {\"user\": {\"domain\": {\"name\": \"%s\"},\"name\": \"%s\",\"password\": \"%s\"}}},\"scope\": {\"project\": {\"name\": \"cn-north-4\"}}}}",
            huaweiName, iamIname, iamPassword);

    RequestBody body = RequestBody.create(jsonBody, JSON);

    // 构建请求
    Request request = new Request.Builder()
            .url(iamTokenUrl)
            .post(body)
            .addHeader("Content-Type", "application/json")
            .build();

    // 发送请求并处理响应
    try (Response response = client.newCall(request).execute()) {
        if (!response.isSuccessful()) {
            // 输出错误内容
            System.out.println("Unexpected code " + response);
            throw new IOException("Unexpected code " + response);
        }

        // 从响应头中提取IAM令牌
        String iamToken = response.header("X-Subject-Token");
        if (iamToken == null || iamToken.isEmpty()) {
            // 记录警告日志（如果没有找到令牌）
            throw new IOException("IAM token not found");
        }

        return iamToken;
    } catch (IOException e) {
        // 记录异常日志
        throw e; // 重新抛出异常以便调用者可以处理
    }
}

POST https://{endpoint}/v5/iot/{project_id}/devices/{device_id}/commands

{
  "service_id" : "reboot",
  "command_name" : "ON_OFF",
  "paras" : {
    "value" : "ON"
  }
}

private static String IOTDA_ENDPOINT_CMD = "https://iotda.cn-north-4.myhuaweicloud.com/v5/iot/%s/devices/%s/commands";

public void sendDeviceCommand(String commandPayload,String token, Callback callback) {
    MediaType JSON = MediaType.parse("application/json; charset=utf-8");
    RequestBody body = RequestBody.create(JSON, commandPayload);
    IOTDA_ENDPOINT_CMD = String.format(IOTDA_ENDPOINT_CMD, project_id,device_id);
    Request request = new Request.Builder()
            .url(IOTDA_ENDPOINT_CMD)
            .post(body)
            .addHeader("Content-Type", "application/json")
            .addHeader("X-Auth-Token", token)
            .build();

    client.newCall(request).enqueue(callback);
}

@Override
public void onClick(View view) {
    final Thread t = new Thread() {
        @Override
        public void run() {
            try {
                IoTDAUtils hw = new IoTDAUtils();

                str_cmd = String.format(str_cmd, service_id,command_name,paras);
                System.out.println(str_cmd);
                hw.sendDeviceCommand(str_cmd,AUTH_TOKEN,new Callback() {
                    @Override
                    public void onFailure(Call call, IOException e) {
                        // 处理网络错误或请求失败
                        runOnUiThread(() -> tev.setText("Error: " + e.getMessage()));
                    }

                    @Override
                    public void onResponse(Call call, Response response) throws IOException {
                        if (response.isSuccessful()) {
                            // 处理成功的响应并更新UI
                            String responseBody = response.body().string();
                            runOnUiThread(() -> tev.setText("Device Shadow: " + responseBody));
                        } else {
                            // 处理不成功的响应（如认证失败、资源未找到等）
                            runOnUiThread(() -> tev.setText("Request failed: " + response.code()));
                        }
                    }
                });
            } catch (Exception e) {
                e.printStackTrace();
                System.out.println("错误" + e.getMessage().toString());
            }
        }};
    t.start();
}

package com.example.huawei_iotda_app;

import java.io.IOException;

import okhttp3.Call;
import okhttp3.Callback;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;

public class IoTDAUtils {
    private static final MediaType JSON = MediaType.parse("application/json; charset=utf-8");
    private static final OkHttpClient client = new OkHttpClient();


    public String getIAMToken(String huaweiName, String iamIname, String iamPassword, String iamTokenUrl) throws IOException {
        // 构建JSON请求体
        String jsonBody = String.format("{\"auth\": {\"identity\": {\"methods\": [\"password\"],\"password\": {\"user\": {\"domain\": {\"name\": \"%s\"},\"name\": \"%s\",\"password\": \"%s\"}}},\"scope\": {\"project\": {\"name\": \"cn-north-4\"}}}}",
                huaweiName, iamIname, iamPassword);
        RequestBody body = RequestBody.create(jsonBody, JSON);
        // 构建请求
        Request request = new Request.Builder()
                .url(iamTokenUrl)
                .post(body)
                .addHeader("Content-Type", "application/json")
                .build();

        // 发送请求并处理响应
        try (Response response = client.newCall(request).execute()) {
            if (!response.isSuccessful()) {
                // 输出错误内容
                System.out.println("Unexpected code " + response);
                throw new IOException("Unexpected code " + response);
            }

            // 从响应头中提取IAM令牌
            String iamToken = response.header("X-Subject-Token");
            if (iamToken == null || iamToken.isEmpty()) {
                // 记录警告日志（如果没有找到令牌）
                throw new IOException("IAM token not found");
            }
            return iamToken;
        } catch (IOException e) {
            // 记录异常日志
            throw e; // 重新抛出异常以便调用者可以处理
        }
    }

    public void getDeviceShadow(String token,String url,Callback callback) {
        Request request = new Request.Builder()
                .url(url)
                .addHeader("Content-Type", "application/json")
                .addHeader("X-Auth-Token", token)  // 注意：这里应该使用有效的认证令牌
                .build();

        Call call = client.newCall(request);
        call.enqueue(callback);
    }

    public void sendDeviceCommand(String commandPayload,String token,String url, Callback callback) {
        MediaType JSON = MediaType.parse("application/json; charset=utf-8");
        RequestBody body = RequestBody.create(JSON, commandPayload);

        Request request = new Request.Builder()
                .url(url)
                .post(body)
                .addHeader("Content-Type", "application/json")
                .addHeader("X-Auth-Token", token)
                .build();

        client.newCall(request).enqueue(callback);
    }
}