Saltar al contenido

Primeros pasos

GitHub

Puedes usar nuestro setup asistido por IA para instalar el plugin. Añade las skills de Capgo a tu herramienta de IA con el siguiente comando:

Ventana de terminal
npx skills add https://github.com/Cap-go/capgo-skills --skill capacitor-plugins

Luego usa el siguiente prompt:

Use the `capacitor-plugins` skill from `Cap-go/capgo-skills` to install the `@capgo/capacitor-mqtt` plugin in my project.

Si prefieres la configuración manual, instala el plugin ejecutando estos comandos y sigue las instrucciones de cada plataforma:

Ventana de terminal
npm install @capgo/capacitor-mqtt
npx cap sync
import { MqttBridge } from '@capgo/capacitor-mqtt';

Conéctate con TLS, activa la reconexión automática y suscríbete al topic de telemetría que publica tu backend.

import { MqttBridge } from '@capgo/capacitor-mqtt';
await MqttBridge.connect({
serverURI: 'ssl://broker.example.com',
port: 8883,
clientId: 'cap-app-1',
username: 'device-user',
password: 'device-secret',
setCleanSession: true,
connectionTimeout: 30,
keepAliveInterval: 60,
setAutomaticReconnect: true,
});
await MqttBridge.subscribe({ topic: 'devices/telemetry', qos: 1 });
  • TLS: coincide con serverURI el esquema requerido por el broker.
  • Background: reconexión tras la suspensión de la WebView en Android.
  • QoS: un QoS más alto consume más batería en redes móviles.

Consulta las definiciones de origen del contrato actual.

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);

Consulta las definiciones de origen del contrato actual.

import { MqttBridge } from '@capgo/capacitor-mqtt';
const result = await MqttBridge.disconnect();
console.log(result);

Consulta las definiciones de origen del contrato actual.

import { MqttBridge } from '@capgo/capacitor-mqtt';
const result = await MqttBridge.subscribe({
topic: 'topic',
qos: 1,
});
console.log(result);

Consulta las definiciones de la fuente para el contrato actual.

import { MqttBridge } from '@capgo/capacitor-mqtt';
const result = await MqttBridge.publish({
topic: 'topic',
payload: 'payload',
qos: 1,
retained: true,
});
console.log(result);
export type onConnectionLostListener = (x: { connectionStatus: string; reasonCode: number; message: string }) => void;
export type onConnectCompleteListener = (x: { reconnected: boolean; serverURI: string }) => void;
export type onMessageArrivedListener = (x: { topic: string; message: string }) => void;

Esta página se genera a partir del plugin src/definitions.ts. Vuelve a ejecutar el sync cuando el API público cambie en upstream.

Si estás usando Primeros pasos para planificar las operaciones del dashboard y de API, conéctalo con Uso de @capgo/capacitor-mqtt para la capacidad nativa en Uso de @capgo/capacitor-mqtt, Resumen de API para los detalles de implementación en API Overview, Introducción para los detalles de implementación en la Introducción, Claves de API para los detalles de implementación en las claves de API, y Dispositivos para el detalle de implementación en Devices.