MQTT Engine

MQTT para la flota de dispositivos Cams. MQTT Engine es un consumidor de backend tras EMQX que se suscribe a los topics compartidos de asistencia y presencia, canaliza los eventos al mismo pipeline de asistencia que los transportes HTTP y TCP y publica envoltorios de comandos del servidor al dispositivo.

Empezar Documentación para desarrolladores

Descripción general

Un motor de transporte MQTT que ingiere eventos de asistencia y envía comandos a los dispositivos mediante un broker EMQX, pensado para grandes flotas conectadas.

MQTT Engine es el transporte MQTT de la familia de motores de Cams, el complemento de HTTP y del TCP persistente. Se ejecuta como consumidor de backend tras un broker EMQX: se suscribe a los topics compartidos de asistencia y presencia bajo api/mqtt/v1/{sn}/, canaliza cada evento al pipeline compartido y publica comandos del servidor al dispositivo en el topic de comandos como envoltorios JSON compatibles hacia adelante. EMQX termina las sesiones TLS de los dispositivos, la autenticación, el QoS y el last-will; varias instancias del motor se reparten la carga mediante las suscripciones compartidas de EMQX para flotas grandes.

SERVICIOMQTTEMQXTLSJSONC++

Se usa en:Flotas, transporte y conductores Eventos, festivales y estadios

Esquema de topics MQTT (EMQX)

# device -> server (attendance)
api/mqtt/v1/{sn}/evt   { "user_id":"1001", "att_time":"...", "att_state":1 }
# device -> server (presence / LWT)
api/mqtt/v1/{sn}/st    { "online": true }
# server -> device (command)
api/mqtt/v1/{sn}/cmd   { "id":"c1", "op":"sync_user", "data":{} }

Capacidades

Qué hace

Ingesta por MQTT

Se suscribe a los topics de eventos compartidos y canaliza cada evento de asistencia al mismo pipeline de almacenamiento y envío que HTTP y TCP.

Seguimiento de presencia

Consume el topic de presencia y el last-will para que las desconexiones detectadas por el broker marquen un dispositivo como sin conexión.

Envío de comandos

Publica los comandos en cola del servidor al dispositivo en el topic de comandos de cada dispositivo como envoltorios JSON con QoS 1.

Escalado horizontal

Las suscripciones compartidas de EMQX reparten la asistencia entre varias instancias del motor para grandes flotas de dispositivos.

Funciones

Todo incluido

Front-end de transporte MQTT para la asistencia, par de los motores HTTP y TCP nativos
Esquema de topics api/mqtt/v1/{sn}/{evt|cmd|st} alineado con la app y la ACL de EMQX
Consumidor de backend tras EMQX: las suscripciones compartidas reparten la carga entre N instancias
Ingiere eventos de asistencia con un payload idéntico al cuerpo del fichaje HTTP en el pipeline compartido
Presencia y last-will mediante el topic de estado para que las desconexiones marquen los dispositivos como sin conexión
Envío de comandos del servidor al dispositivo como un envoltorio JSON {id, op, data} compatible hacia adelante con QoS 1
TLS hacia el broker con verificación de CA; el motor usa una cuenta de backend, no un número de serie de dispositivo
Compilación multiplataforma (Linux y Windows) sobre Eclipse Paho C++

Desarrolla con MQTT Engine

Consigue una clave, lee la documentación y publica. Nuestro equipo te ayuda con tu primera integración.

Habla con un ingeniero WhatsApp

Preguntas frecuentes

¿Cómo se relaciona MQTT Engine con EMQX?

EMQX sigue siendo el broker que termina las sesiones TLS de los dispositivos, la autenticación, el QoS y el last-will. MQTT Engine es un consumidor de backend que se suscribe a topics compartidos para ingerir asistencia y publica comandos a los dispositivos.

¿Puedo ejecutar varias instancias de MQTT Engine?

Sí. Las suscripciones compartidas de EMQX reparten los topics de asistencia y presencia entre todas las instancias en ejecución, de modo que escalas añadiendo instancias.

¿Cuál es el formato de los comandos del servidor al dispositivo?

Un envoltorio JSON {id, op, data} en el topic de comandos con QoS 1, donde op es el único campo obligatorio y los dispositivos más antiguos ignoran las op desconocidas por compatibilidad hacia adelante.