【HarmonyOS 5】鸿蒙中如何使用MQTT

简介: MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是一种轻量级、基于发布 / 订阅(Publish/Subscribe)模式的即时通讯协议,专为资源受限的物联网(IoT)设备和低带宽、高延迟或不可靠网络环境设计。


##鸿蒙开发能力 ##HarmonyOS SDK应用服务##鸿蒙金融类应用 (金融理财#

一、MQTT是什么?

MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是一种轻量级、基于发布 / 订阅(Publish/Subscribe)模式的即时通讯协议,专为资源受限的物联网(IoT)设备和低带宽、高延迟或不可靠网络环境设计。

目前在物联网,车载,即时通讯,JG领域用的很多。MQTT模式是有个服务器,若干个客户端,订阅Topic作为事件ID,用来订阅广播,发送广播。类似于EventHub和Emitter的发布订阅机制。使用起来很简单。

二、MQTT在鸿蒙中怎么使用?

在鸿蒙(HarmonyOS)中使用MQTT协议主要通过官方提供的@ohos/mqtt库实现。
https://ohpm.openharmony.cn/#/cn/detail/@ohos%2Fmqtt

配置依赖:

ohpm install @ohos/mqtt
或者在oh-package.json5中配置:
  "dependencies": {
        "@ohos/mqtt":"2.0.18",
  }

记得配置网络权限:

在module.json5中配置:
    "requestPermissions":[
      {
        "name" : "ohos.permission.INTERNET",
        "reason": "$string:reason_net",
        "usedScene": {
          "abilities": [
            "FormAbility"
          ],
          "when":"inuse"
        }
      }
    ]
  1. 创建MQTT客户端
    @ohos/mqtt 库的官方文档,该库提供了 同步(MqttClient) 和 异步(MqttAsync) 两种客户端实现。推荐使用 异步客户端(MqttAsync) 以适配 HarmonyOS 的异步编程模型。
import { MqttAsync, MqttConnectOptions } from '@ohos/mqtt';
// 初始化客户端
const mqttClient = MqttAsync.createMqtt({
  clientId: 'device_001', // 唯一客户端ID
  persistenceType: 1, // 内存持久化
});
// 连接参数配置
const connectOptions: MqttConnectOptions = {
  connectTimeout: 30, // 连接超时时间(秒)
  keepAliveInterval: 60, // 心跳间隔(秒)
  username: 'user', // 用户名(可选)
  password: 'password', // 密码(可选)
  cleanStart: true, // 清除会话
  // 若使用TLS,需配置证书
  // enableServerCertAuth: true,
  // caFile: 'ca.crt',
  // clientCertFile: 'device.crt',
  // clientKeyFile: 'device.key',
};
  1. MQTT的连接与断开
// 异步回调方式
mqttClient.connect(connectOptions, (err, data) => {
  if (err) {
    console.error('连接失败:', err);
    return;
  }
  console.log('连接成功:', data);
});
// Promise方式
mqttClient.connect(connectOptions)
  .then(data => console.log('连接成功:', data))
  .catch(err => console.error('连接失败:', err));
// 断开连接
mqttClient.disconnect();
  1. 发布和订阅消息
const publishOptions = {
  topic: 'home/temperature',
  qos: 1, // 服务质量等级(0/1/2)
  payload: JSON.stringify({ value: 25.5 }), // 消息负载
  // 可选:设置消息过期时间(毫秒)
  // messageExpiryInterval: 3600000,
};
// 异步回调方式
mqttClient.publish(publishOptions, (err, data) => {
  if (err) {
    console.error('消息发布失败:', err);
    return;
  }
  console.log('消息发布成功:', data);
});
// Promise方式
mqttClient.publish(publishOptions)
  .then(data => console.log('消息发布成功:', data))
  .catch(err => console.error('消息发布失败:', err));
const subscribeOptions = {
  topic: 'home/temperature',
  qos: 1, // 服务质量等级
};
// 订阅并设置消息回调
mqttClient.subscribe(subscribeOptions, (err, data) => {
  if (err) {
    console.error('订阅失败:', err);
    return;
  }
  console.log('订阅成功:', data);
});
// 接收消息的回调
mqttClient.on('message', (topic, payload) => {
  console.log(`收到消息 [${topic}]:`, payload);
  // 处理消息负载(如解析JSON)
  const data = JSON.parse(payload.toString());
  // 更新UI或业务逻辑
});


三、源码DEMO示例:

import { MqttAsync } from '@ohos/mqtt';
// ---------------------- 基础配置(MQTT 3.1.1 协议) ----------------------
const BROKER_URL = 'mqtt://test.mosquitto.org:1883'; // 公共测试Broker(支持MQTT 3.1.1)
const CLIENT_ID = 'HarmonyOS-MQTT3-Demo';           // 客户端ID(需唯一)
const TOPIC = 'harmonyos/classic/test';             // 订阅/发布主题
const QOS = 1;                                      // 服务质量等级(0/1/2)
// ---------------------- 创建异步客户端 ----------------------
    let client = MqttAsync.createMqtt({
      url: BROKER_URL,
      clientId: CLIENT_ID,
      // 客户端持久化类型(0=文件系统,1=内存,2=自定义)
      persistenceType: 1 // 使用内存持久化(轻量设备推荐)
    })
// ---------------------- 核心功能实现 ----------------------
async function mqttCommunication() {
  try {
    // 1. 连接到Broker(异步方法,返回Promise)
    await client.connect({
      // MQTT 3.1.1 连接参数
      cleanSession: true,       // 清除会话(断开后不保留订阅和消息)
      connectTimeout: 30,       // 连接超时时间(秒)
      keepAliveInterval: 60,    // 心跳间隔(秒),维持长连接
      // 认证信息(若Broker需要)
      userName: 'user',         // 用户名(可选)
      password: 'password',     // 密码(可选)
    });
    console.log('[MQTT 3.1.1] 连接成功');
    // 2. 订阅主题(支持通配符,如 "home/+/temp")
      await client.subscribe({
        topic: TOPIC,
        qos: QOS
      });
    console.log(`[MQTT 3.1.1] 已订阅主题:${TOPIC}(QoS ${QOS})`);
    // 3. 发布消息(字符串或二进制 payload)
    const message = 'Hello from HarmonyOS with MQTT 3.1.1!';
    await client.publish({
      topic: TOPIC,
      payload: message,
      qos: QOS,
      retained: false, // 是否保留消息(Broker存储最后一条消息)
    });
    console.log(`[MQTT 3.1.1] 消息已发布:${message}`);
    // 4. 监听消息接收事件
      client.subscribe({
        topic: TOPIC,
        qos: QOS,
      },(MqttResponse)=>{
        console.log(`[接收消息] 主题:${MqttResponse}`);
      })
  } catch (err) {
    console.error('[MQTT 3.1.1] 操作失败:', err.message);
  }
}
// ---------------------- 启动连接 ----------------------
mqttCommunication();
// ---------------------- 断开连接(如页面销毁时调用) ----------------------
// client.disconnect();
相关实践学习
快速体验阿里云云消息队列RocketMQ版
本实验将带您快速体验使用云消息队列RocketMQ版Serverless系列实例进行获取接入点、创建Topic、创建订阅组、收发消息、查看消息轨迹和仪表盘。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
4月前
|
物联网 开发工具
【HarmonyOS】鸿蒙应用蓝牙功能实现 (二)
【HarmonyOS】鸿蒙应用蓝牙功能实现 (二)
121 9
【HarmonyOS】鸿蒙应用蓝牙功能实现 (二)
|
4月前
|
前端开发 JavaScript API
【HarmonyOS 5】鸿蒙跨平台开发方案详解(一)
2025年是鸿蒙生态迎来关键发展期。根据前几天的2025 HDC数据显示,鸿蒙原生应用数量已从2024年的2000款增长至5000款,微信鸿蒙版安装量突破1.2亿,公安部交管系统完成全国300城鸿蒙适配。
302 1
|
4月前
|
存储 安全 API
【HarmonyOS 5】鸿蒙应用隐私保护详解
【HarmonyOS 5】鸿蒙应用隐私保护详解
163 1
|
4月前
|
开发工具
【HarmonyOS 5】使用openCustomDialog如何禁止手势关闭的方案
openCustomDialog提供了onWillDismiss回调函数,当用户尝试通过滑动、点击外部、返回键等操作关闭弹窗时,会触发该回调。通过在回调中判断关闭原因并拦截操作,即可实现禁止手势关闭的效果。
125 1
|
4月前
|
人工智能 自然语言处理 IDE
【HarmonyOS 5】鸿蒙CodeGenie AI辅助编程工具详解
1、CodeGenie是什么? CodeGenie (代码精灵)作为鸿蒙DevEco IDE自带的AI辅助编码工具。
173 0
|
4月前
|
定位技术 开发工具 开发者
【HarmonyOS 5】桌面快捷方式功能实现详解
在移动应用开发中,如何让用户快速触达核心功能,是目前很常见的功能之一。 鸿蒙系统提供的**桌面快捷方式(Shortcuts)**功能,允许开发者为应用内常用功能创建直达入口,用户通过长按应用图标即可快速启动特定功能,大幅减少操作层级。 本文将结合地图导航场景,详细解析鸿蒙快捷方式的实现原理与开发流程。结合华为官方开源示例 DesktopShortcut 展开,该示例基于HarmonyOS 5.0实现,完整演示了地图导航场景的快捷方式开发流程。
236 0
|
4月前
|
监控 JavaScript 开发工具
【HarmonyOS 5】鸿蒙中@State的原理详解
@State 是 HarmonyOS ArkTS 框架中用于管理组件状态的核心装饰器,其核心作用是实现数据驱动 UI 的响应式编程模式。通过将变量标记为 @State,开发者可以确保当状态值发生变化时,依赖该状态的 UI 组件会自动重新渲染,从而保持数据与界面的实时同步。 @State 是 HarmonyOS ArkTS 实现响应式编程的大基础核心,可以说整个V1和V2都是围绕它来进行组合使用。
166 0
|
4月前
|
传感器 自动驾驶 物联网
【HarmonyOS 5】鸿蒙星闪NearLink详解
鸿蒙星闪NearLink Kit 是 HarmonyOS 提供的短距离通信服务,支持星闪设备间的连接、数据交互。例如,手机可作为中心设备与外围设备(如鼠标、手写笔、智能家电、车钥匙等)通过星闪进行连接。
130 0
|
4月前
|
移动开发 Dart 前端开发
【HarmonyOS 5】鸿蒙跨平台开发方案详解(二)
作为最早实现鸿蒙适配的跨平台框架,Flutter在社区推动下已形成较完整的技术方案。当前鸿蒙版Flutter已发布3.22.0-ohos版本,该版本基于Flutter 3.22.0核心。
264 0
|
移动开发 安全 Android开发
【HarmonyOS 5】鸿蒙mPaaS详解
mPaaS 是 Mobile Platform as a Service 的缩写,即移动开发平台。
291 0