Ejemplos de código

Ejemplo MQTT con Dart (Flutter)

Conecta apps de Dart y Flutter a un broker MQTT con el paquete mqtt_client. Empieza con el broker público gratuito y después apunta el mismo código a un broker privado y seguro en ConnectMQ.

Biblioteca
mqtt_client
Instalación
dart pub add mqtt_client # flutter pub add mqtt_client
Código fuente en GitHubmqtt-code-samples/dart-flutterClona los ejemplos completos y listos para ejecutar. Se agradecen estrellas y pull requests. Ver en GitHub

1. Pruébalo en el broker público gratuito

Sin necesidad de cuenta: conéctate a broker.connectmq.com en el puerto 1883 y empieza a publicar en segundos.

main.dart
import 'dart:convert';
import 'package:mqtt_client/mqtt_client.dart';
import 'package:mqtt_client/mqtt_server_client.dart';

Future<void> main() async {
  const topic = 'your-project/sensors/temperature'; // Usa un prefijo de topic único: cualquiera puede leer el broker público

  // Conectar al broker público gratuito (sin cuenta) (Cada cliente necesita un client ID único)
  final client = MqttServerClient.withPort('broker.connectmq.com', 'flutter-example', 1883);
  client.keepAlivePeriod = 30;
  await client.connect();

  // Suscribirse al topic de temperatura
  client.subscribe(topic, MqttQos.atLeastOnce);
  // Se ejecuta con cada mensaje de un topic suscrito
  client.updates!.listen((messages) {
    final message = messages.first.payload as MqttPublishMessage;
    final text = MqttPublishPayload.bytesToStringAsString(message.payload.message);
    print('${messages.first.topic}: $text');
  });

  // Publicar una lectura en JSON
  final builder = MqttClientPayloadBuilder()..addString(jsonEncode({'temperature': 21.5}));
  client.publishMessage(topic, MqttQos.atLeastOnce, builder.payload!);
}

Broker MQTT público gratuito

El broker público es compartido: cualquiera puede suscribirse a tus topics. Nunca envíes por él contraseñas, datos personales ni información confidencial.

Acerca del broker MQTT público gratuito

2. Pasa a producción con ConnectMQ

Para dispositivos reales, usa un broker MQTT serverless privado en ConnectMQ en lugar del público: cifrado TLS, usuario y contraseña para cada dispositivo y control de acceso por topic, totalmente gestionado. Empieza con el plan Free, sin tarjeta.

Sustituye YOUR_BROKER_HOST, YOUR_USERNAME y YOUR_PASSWORD por los valores de tu panel de ConnectMQ.

main.dart
import 'dart:convert';
import 'package:mqtt_client/mqtt_client.dart';
import 'package:mqtt_client/mqtt_server_client.dart';

Future<void> main() async {
  const topic = 'your-project/sensors/temperature';

  // Conectar a tu broker privado de ConnectMQ en el puerto 8883 (Cada cliente necesita un client ID único)
  final client = MqttServerClient.withPort('YOUR_BROKER_HOST', 'flutter-example', 8883);
  client.keepAlivePeriod = 30;
  // TLS: el almacén de CA del sistema verifica el certificado del broker
  client.secure = true;
  // Usuario y contraseña de tu panel de ConnectMQ
  await client.connect('YOUR_USERNAME', 'YOUR_PASSWORD');

  // Suscribirse al topic de temperatura
  client.subscribe(topic, MqttQos.atLeastOnce);
  // Se ejecuta con cada mensaje de un topic suscrito
  client.updates!.listen((messages) {
    final message = messages.first.payload as MqttPublishMessage;
    final text = MqttPublishPayload.bytesToStringAsString(message.payload.message);
    print('${messages.first.topic}: $text');
  });

  // Publicar una lectura en JSON
  final builder = MqttClientPayloadBuilder()..addString(jsonEncode({'temperature': 21.5}));
  client.publishMessage(topic, MqttQos.atLeastOnce, builder.payload!);
}

Preguntas frecuentes sobre MQTT con Dart (Flutter)

¿Cómo conecto Dart (Flutter) a un broker MQTT?

Instala mqtt_client, conéctate al host del broker en el puerto 1883 (o 8883 con TLS), suscríbete a un topic y publica mensajes en él. Los ejemplos de esta página se conectan al broker público gratuito broker.connectmq.com y a un broker privado de ConnectMQ.

¿Hay un broker MQTT gratuito para probar Dart (Flutter)?

Sí. broker.connectmq.com es un broker MQTT público y gratuito que no requiere cuenta. Cualquiera puede leer sus topics, así que úsalo solo para pruebas y con un prefijo de topic único.

¿Cómo protejo una conexión MQTT con Dart (Flutter)?

Conéctate mediante TLS en el puerto 8883 con un usuario y una contraseña de tu panel de ConnectMQ, y asigna a cada dispositivo sus propias credenciales y permisos de topic en lugar de usar el broker público.

Broker MQTT público gratuito

Prueba cualquier ejemplo en broker.connectmq.com: sin registro, con MQTT 3.1.1 y 5, TCP, TLS y WebSocket.

Acerca del broker MQTT público gratuito

MQTT serverless seguro para producción

Cuando llegue el momento de usar dispositivos reales, ejecuta el mismo código en un broker de ConnectMQ privado y totalmente gestionado, con TLS y credenciales por dispositivo.

Empieza gratis

Tu broker MQTT privado, a unos pocos clics

Crea una cuenta, obtén las credenciales de tu broker y conecta tu primer dispositivo, sin servidores que instalar, parchear ni escalar.

MQTT sobre WebSocket: conecta un navegador a un broker MQTT con MQTT.js

Los navegadores no pueden abrir sockets TCP directos, así que las aplicaciones web hablan MQTT sobre WebSocket. Construye un cliente de navegador y un cliente Node.js funcionales contra broker.connectmq.com y aprende a resolver los errores de conexión más comunes.

9 min de lectura