使用 @capgo/capacitor-mqtt
用于 Android 和 iOS 端 MQTT 连接的 Capacitor 插件。
安装
bun add @capgo/capacitor-mqtt
bunx cap sync
bunx cap sync 将插件的原生 code 复制到你的原生项目中。每次升级插件后都要重新运行。
导入
import { MqttBridge } from '@capgo/capacitor-mqtt';
API 概览
| 方法 | 描述 |
|---|---|
connect |
查看源码定义以了解当前行为。 |
disconnect |
查看源码定义以了解当前行为。 |
subscribe |
查看源码定义以了解当前行为。 |
publish |
查看源码定义以了解当前行为。 |
示例
connect()
查看 API 参考文档以了解当前契约。
import { MqttBridge } from '@capgo/capacitor-mqtt';
const result = await MqttBridge.connect({
serverURI: 'https://example.com',
port: 8080,
clientId: 'client-id-123',
username: 'username',
password: 'password',
setCleanSession: true,
connectionTimeout: 1000,
keepAliveInterval: 1000,
setAutomaticReconnect: true,
});
console.log(result);
disconnect()
查看 API 参考文档以了解当前契约。
import { MqttBridge } from '@capgo/capacitor-mqtt';
const result = await MqttBridge.disconnect();
console.log(result);
subscribe()
查看 API 参考文档以了解当前契约。
import { MqttBridge } from '@capgo/capacitor-mqtt';
const result = await MqttBridge.subscribe({
topic: 'topic',
qos: 1,
});
console.log(result);
publish()
查看 API 参考文档以了解当前契约。
import { MqttBridge } from '@capgo/capacitor-mqtt';
const result = await MqttBridge.publish({
topic: 'topic',
payload: 'payload',
qos: 1,
retained: true,
});
console.log(result);
监听事件
addListener 会返回一个句柄。调用 handle.remove() 当屏幕卸载时。
完整参考文档
继续阅读：使用 @capgo/capacitor-mqtt
如果你正在使用 使用 @capgo/capacitor-mqtt 要规划原生插件工作，请将其与 @capgo/capacitor-mqtt 了解 @capgo/capacitor-mqtt 中的实现细节， 快速入门 有关“入门指南”中的实现细节， Capgo 插件目录 查看 Capgo 插件目录中的产品工作流， Capgo 提供的 Capacitor 插件 有关 Capgo 开发的 Capacitor 插件的实现细节，以及 添加或更新插件 有关添加或更新插件的实现细节。