demo 工程

本文主要以Java為例,面向初次接觸OneNET消息佇列MQ的開發者,演示如何搭建測試工程

准備條件

  • 請確認本地已經正確安裝JDK 與IDE 環境,若未完成,請先下載安裝

  • 請確認已經正確開通消息佇列MQ服務並創建服務資源,若未完成,請參考快速入門完成服務開通與資源創建

下載demo 工程

下載demo工程 並解壓,解壓後可以看到本地新增了OneNET-MQ-demo資料夾

配置 demo 工程

  1. 在IDE(以Eclipse 為例)中,選擇File -> Import,選擇Import 類型為Existing Maven Projects

  2. 點擊Next,點擊Browse,選擇解壓後的OneNET-MQ-demo資料夾

  3. 點擊Finish,完成工程導入

    demo 工程導入時需要載入依賴的jar包,整個導入過程需要等待約1分鐘

配置demo 變量

請按照如下說明,根據在平台創建的資源參數,修改MqClient.java 中的MqClient 類

demo中45 - 47行:

String userName = "你的MQ實例名稱";
String mqTopic = "你創建的topic名稱";
String mqSub = "你創建的訂閱名稱";

81 - 83行:

String userName = "你的MQ實例名稱";
String accessKey = "你的MQ access_key";
String expirationTime = "你自訂的鑒權參數過期時間";

注:如需手動回復puback,請將MqClient.java 中第25行manualAcks 設置為true,並在PushCallback類中的messageArrived的介面中手動回復

 private boolean manualAcks = false;

運行demo

配置規則引擎並生產消息,運行MqClient類,連接服務並消費佇列中的消息,成功後,可以在console 中觀察到成功消費的消息

个搜索结果,搜索内容 “

    0 个搜索结果,搜索内容 “