阿裡雲微服務消息隊列MQTT管控API本地測試Quick Start

Step By Step

1、裝置端建立連接配接進行消息收發

2、添加pom.xml依賴

3、內建測試

一、裝置端建立連接配接進行消息收發

• 參考官方Demo： MQ4IoTSendMessageToMQ4IoTUseSignatureMode 完整正常的消息收發，確定裝置線上。
• 控制台快速檢視

二、添加pom.xml依賴

<dependencies>
        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>aliyun-java-sdk-core</artifactId>
            <version>4.1.1</version>
        </dependency>

        <dependency>
            <groupId>com.aliyun</groupId>
            <artifactId>onsmqtt20200420</artifactId>
            <version>1.0.1</version>
        </dependency>
    </dependencies>           

三、內建測試

• 3.1 CodeSample

import com.aliyun.onsmqtt20200420.models.*;
import com.aliyun.teaopenapi.models.*;
import com.google.gson.Gson;

public class Sample {

    /**
     * 使用AK&SK初始化賬号Client
     * @param accessKeyId
     * @param accessKeySecret
     * @return Client
     * @throws Exception
     */
    public static com.aliyun.onsmqtt20200420.Client createClient(String accessKeyId, String accessKeySecret) throws Exception {
        Config config = new Config()
                // 您的AccessKey ID
                .setAccessKeyId(accessKeyId)
                // 您的AccessKey Secret
                .setAccessKeySecret(accessKeySecret);
        // 通路的域名
//        config.endpoint = "onsmqtt.cn-qingdao.aliyuncs.com";
        config.endpoint = "onsmqtt.cn-beijing.aliyuncs.com";
        return new com.aliyun.onsmqtt20200420.Client(config);
    }

    public static void main(String[] args_) throws Exception {java.util.List<String> args = java.util.Arrays.asList(args_);
        com.aliyun.onsmqtt20200420.Client client = Sample.createClient("<access key>", "<access secret>");
        QuerySessionByClientIdRequest querySessionByClientIdRequest = new QuerySessionByClientIdRequest()
                .setClientId("GID_demo1@@@DEVICE_001")
                .setInstanceId("post-cn-st*********");
        // 複制代碼運作請自行列印 API 的傳回值
        QuerySessionByClientIdResponse response = client.querySessionByClientId(querySessionByClientIdRequest);
//        System.out.println(response.body.onlineStatus);
        System.out.println(new Gson().toJson(response.body));
    }
}           

• 3.2 The Result

{"onlineStatus":true,"requestId":"87D17FA5-F1F9-48F3-893C-BD70C8CA3DED"}           

更多參考

QuerySessionByClientId 服務接入點 阿裡雲常見參數擷取位置