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"}