MQTT Engine

MQTT untuk armada perangkat Cams. MQTT Engine adalah consumer backend di balik EMQX yang berlangganan topik absensi dan kehadiran bersama, mengalirkan event ke pipeline absensi yang sama dengan transport HTTP dan TCP, serta menerbitkan envelope perintah server-ke-perangkat.

Mulai Dokumentasi pengembang

Ikhtisar

Engine transport MQTT yang menerima event absensi dan mengirim perintah perangkat melalui broker EMQX — dibuat untuk armada terhubung berskala besar.

MQTT Engine adalah transport MQTT dalam keluarga engine Cams, pasangan dari HTTP dan TCP persisten. Engine ini berjalan sebagai consumer backend di balik broker EMQX: berlangganan topik absensi dan kehadiran bersama di bawah api/mqtt/v1/{sn}/, mengalirkan setiap event ke pipeline bersama, dan menerbitkan perintah server-ke-perangkat pada topik perintah sebagai envelope JSON yang kompatibel ke depan. EMQX menangani sesi TLS perangkat, autentikasi, QoS, dan last-will; beberapa instance engine melakukan load-balance melalui shared subscription EMQX untuk armada besar.

LAYANANMQTTEMQXTLSJSONC++

Digunakan di:Armada, Transportasi & Pengemudi Acara, Festival & Stadion

Skema topik 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":{} }

Kemampuan

Apa yang dilakukannya

Ingest melalui MQTT

Berlangganan topik event bersama dan mengalirkan setiap event absensi ke pipeline penyimpanan dan push yang sama dengan HTTP dan TCP.

Lacak Kehadiran Perangkat

Mengonsumsi topik kehadiran dan last-will sehingga pemutusan koneksi yang terdeteksi broker menandai perangkat offline.

Kirim Perintah

Menerbitkan perintah server-ke-perangkat yang diantrekan pada topik perintah per perangkat sebagai envelope JSON pada QoS 1.

Skala Horizontal

Shared subscription EMQX melakukan load-balance absensi ke beberapa instance engine untuk armada perangkat besar.

Fitur

Semua sudah termasuk

Front-end transport MQTT untuk absensi, sejajar dengan engine HTTP dan TCP native
Skema topik api/mqtt/v1/{sn}/{evt|cmd|st} selaras dengan aplikasi dan ACL EMQX
Consumer backend di balik EMQX: shared subscription melakukan load-balance ke N instance
Menerima event absensi dengan payload identik dengan body absen HTTP ke pipeline bersama
Kehadiran dan last-will melalui topik status sehingga pemutusan koneksi menandai perangkat offline
Pengiriman perintah server-ke-perangkat sebagai envelope JSON {id, op, data} yang kompatibel ke depan pada QoS 1
TLS ke broker dengan verifikasi CA; engine menggunakan akun backend, bukan serial perangkat
Build lintas platform (Linux dan Windows) di atas Eclipse Paho C++

Bangun dengan MQTT Engine

Ambil kunci, baca dokumentasi, dan rilis. Tim kami membantu integrasi pertama Anda.

Bicara dengan engineer WhatsApp

FAQ

Pertanyaan umum

Bagaimana hubungan MQTT Engine dengan EMQX?

EMQX tetap menjadi broker yang menangani sesi TLS perangkat, autentikasi, QoS, dan last-will. MQTT Engine adalah consumer backend yang berlangganan topik bersama untuk menerima absensi dan menerbitkan perintah ke perangkat.

Bisakah saya menjalankan beberapa instance MQTT Engine?

Ya. Shared subscription EMQX melakukan load-balance topik absensi dan kehadiran ke semua instance yang berjalan, sehingga Anda melakukan penskalaan dengan menambah instance.

Apa format perintah server-ke-perangkat?

Envelope JSON {id, op, data} pada topik perintah di QoS 1, di mana op adalah satu-satunya kolom wajib dan op yang tidak dikenal diabaikan oleh perangkat lama demi kompatibilitas ke depan.