鸿蒙OS开发实战：【ArkTS 实现MQTT协议(2)】

软件说明

协议传输通道仅为TCPSocket
基于HarmonyOS SDK API 9开发
开发语言：ArkTS，TypeScript

应用操作说明

测试首页

“连接” : 用于连接远端服务器。具备“连接 & 断开” 两个功能
“设置” : 用于添加更多主题
“订阅” & “解除” : 仅用于默认主题“Harvey2024”
“发布” : 发布消息前，用来设置消息QoS 和主题
“发送” : 发布已输入的文字

主题设置页

“+” : 添加主题

2. 主题列表，长按可删除主题

运行中的首页

接口使用说明

学习前准备：

开始前熟悉鸿蒙文档

鸿蒙OS开发	更多内容↓点击	HarmonyOS与OpenHarmony技术
鸿蒙技术文档	《鸿蒙NEXT星河版开发学习文档》

搜狗高速浏览器截图20240326151547.png

连接

//构建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()

最后呢，很多开发朋友不知道需要学习那些鸿蒙技术？鸿蒙开发岗位需要掌握那些核心技术点？为此鸿蒙的开发学习必须要系统性的进行。

而网上有关鸿蒙的开发资料非常的少，假如你想学好鸿蒙的应用开发与系统底层开发。你可以参考这份资料，少走很多弯路，节省没必要的麻烦。由两位前阿里高级研发工程师联合打造的《鸿蒙NEXT星河版OpenHarmony开发文档》里面内容包含了（ArkTS、ArkUI开发组件、Stage模型、多端部署、分布式应用开发、音频、视频、WebGL、OpenHarmony多媒体技术、Napi组件、OpenHarmony内核、Harmony南向开发、鸿蒙项目实战等等）鸿蒙（Harmony NEXT）技术知识点

如果你是一名Android、Java、前端等等开发人员，想要转入鸿蒙方向发展。可以直接领取这份资料辅助你的学习。下面是鸿蒙开发的学习路线图。