軟件說明

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

應(yīng)用操作說明

測試首頁

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

主題設(shè)置頁

1. “+” : 添加主題

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

運(yùn)行中的首頁

接口使用說明

學(xué)習(xí)前準(zhǔn)備：

開始前熟悉鴻蒙文檔

連接

//構(gòu)建MQTT CONNECT參數(shù)
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)

發(fā)布消息

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

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

消息監(jiān)聽

//錯(cuò)誤信息
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結(jié)果消息
    if (msg.value == 0) {
       //成功
    } else {
      Prompt.showToast({ message: '連接失敗' })
    }

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

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

    //訂閱主題結(jié)果 
    let packet = msg.value as MQTTPacketStruct

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

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

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

    //收到服務(wù)端數(shù)據(jù)包，即 接收到消息
    let packet = msg.value as MQTTPacketStruct

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

    //客戶端發(fā)送給服務(wù)端數(shù)據(jù)包
    let packet = msg.value as MQTTPacketStruct

  }
})

斷開服務(wù)

HarmonyOSSocket.get().disconnect()

審核編輯 黃宇