前提條件

• 安裝IDEA。

  請下載IntelliJ IDEA Ultimate版本，并參見IntelliJ IDEA說明進行安裝。更多信息，請參見下載地址。您也可以使用Eclipse，本文以IntelliJ IDEA為例。

• 安裝JDK 1.8或以上版本。更多信息，請參見安裝JDK。

• 創建資源。

  使用Demo工程收發消息，需要提前在控制臺創建資源信息，包括創建實例、創建Topic、創建Group、獲取AccessKey（包括AccessKey ID和AccessKey Secret）以及獲取接入點。

運行Demo工程

1. 下載并解壓Demo工程。

   下載地址，請參見Demo工程。解壓后可看到本地新增了mqtt-server-sdk-demo-main文件夾，java-demo\src\main\java\com\aliyun\openservices\lmq\example路徑下包含了消息收發的示例代碼。

   • MQTTProducerDemo類：云端服務向云消息隊列 MQTT 版服務端發送消息。

   • MQTTConsumerDemo類：云端服務從云消息隊列 MQTT 版服務端接收消息。

   • MQTTClientStatusNoticeProcessDemo類：云端服務接收客戶端上下線通知消息。

2. 將解壓好的Demo工程導入至IntelliJ IDEA。

3. 修改示例代碼，根據業務場景修改需要使用的示例代碼，將創建好的資源信息填寫至示例代碼中。

   說明

   在使用示例代碼前，需要配置環境變量，通過環境變量讀取訪問憑證。關于配置環境變量的方法，請參見配置訪問憑證。

   云消息隊列 MQTT 版的AccessKey ID和AccessKey Secret的環境變量名稱分別為MQTT_AK_ENV和MQTT_SK_ENV。

   // 云消息隊列 MQTT 版實例的接入點，具體填寫格式，請參見接口和參數說明。
   String domain = "domain";
   // 使用的協議和端口必須匹配，該參數值固定為5672。
   int port = "port";
   // 已創建好的云消息隊列 MQTT 版實例ID。
   String instanceId = "instanceId";
   // 您的RAM用戶的AccessKey ID和AccessKey Secret。
   // 阿里云賬號AccessKey擁有所有API的訪問權限，建議您使用RAM用戶進行API訪問或日常運維。
   // 強烈建議不要把AccessKey ID和AccessKey Secret保存到工程代碼里，否則可能導致AccessKey泄露，威脅您賬號下所有資源的安全。
   // 本示例以將AccessKey 和 AccessKeySecret 保存在環境變量為例說明。
   String accessKey = System.getenv("MQTT_AK_ENV");
   String secretKey = System.getenv("MQTT_SK_ENV");
   // 您已創建好的用于收發消息的父級Topic。
   String firstTopic = "firstTopic";
   // 若您需要使用子級Topic，可直接在代碼中設置，無需提前在控制臺創建。子級Topic命名規范，請參見名詞解釋。
   String secondTopic = "secondTopic";
   // 您已創建好的用于收發消息的Group ID。
   String mqttGroupId = "mqttGroupId";

4. 配置完成后，以Main方式運行步驟2中修改好的示例代碼。

結果驗證

運行Demo工程完成消息收發后，您可在云消息隊列 MQTT 版控制臺查詢消息軌跡，驗證消息收發結果。詳細信息，請參見消息軌跡查詢。