軟件說明

1. 協議傳輸通道僅為TCPSocket
2. 基于HarmonyOS SDK API 9開發
3. 開發語言：ArkTS，TypeScript

應用操作說明

測試首頁

1. “連接” : 用于連接遠端服務器。具備“連接 & 斷開” 兩個功能
2. “設置” : 用于添加更多主題
3. “訂閱” & “解除” : 僅用于默認主題“Harvey2024”
4. “發布” : 發布消息前，用來設置消息QoS 和 主題
5. “發送” : 發布已輸入的文字

主題設置頁

1. “+” : 添加主題

2. 主題列表，長按可刪除主題

運行中的首頁

接口使用說明

學習前準備：

開始前熟悉鴻蒙文檔

連接

//構建MQTT CONNECT參數
let CMD = MQTTConnect.create()
  .setClientIdentifier('Harvey鴻蒙') //客戶端名字
  .buildPacket()

//配置Socket并且完成連接
HarmonyOSSocket.get()
  .socketCfg({
    address: {
      address: this.sec1IP + "." + this.sec2IP + "." + this.sec3IP + "." + this.sec4IP,
      port: 1883
    }
  },
  )
  .connectCfg(CMD)
  .connect()

訂閱主題

let options: SubscribeTopicNameOptions[] = [
  { topicName: this.currentPublishTopicName} //主題名稱
]

HarmonyOSSocket.get().subscribeTopic(options)

發布消息

//構建MQTT PUBLISH參數
let publishConfig = MQTTPublish.create()
  .setQoS(this.currentPublishQoS) 
  .setTopicName(this.currentPublishTopicName)

HarmonyOSSocket.get()
               .publishCfg(publishConfig)
               .sendMessageByString(this.inputMessage)

消息監聽

//錯誤信息
getContext().eventHub.on(MQTTCommon.EVENTHUB_MQTT_APP_ERROR_MSG, (value) = > {
  this.errorMessage = value
})

//
getContext().eventHub.on(MQTTCommon.EVENTHUB_MQTT_CMD_STATUS_MSG, (msg) = > {
  if (msg.action === 'connect') { //MQTT CONNECT結果消息
    if (msg.value == 0) {
       //成功
    } else {
      Prompt.showToast({ message: '連接失敗' })
    }

  } else if (msg.action === 'close') {
    //1. TCPSocket 關閉事件
    //2. MQTT 斷開命令已發送完畢

  } else if (msg.action == 'subscribeack') {

    //訂閱主題結果 
    let packet = msg.value as MQTTPacketStruct

  } else if (msg.action == 'unsubscribeack') {

    //解除主題訂閱結果 
    let packet = msg.value as MQTTPacketStruct

  } else if (msg.action == 'publish-s-to-c') {

    //收到服務端數據包，即 接收到消息
    let packet = msg.value as MQTTPacketStruct

  } else if (msg.action == 'publish-c-to-s') {

    //客戶端發送給服務端數據包
    let packet = msg.value as MQTTPacketStruct

  }
})

斷開服務

HarmonyOSSocket.get().disconnect()

審核編輯 黃宇