阿里云微服务消息队列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
服务接入点
阿里云常见参数获取位置