MQTT Engine

Cams cihaz filosu için MQTT. MQTT Engine, EMQX arkasında çalışan, paylaşılan devam ve varlık konularına abone olan, olayları HTTP ve TCP aktarımlarıyla aynı devam işlem hattına yönlendiren ve sunucudan cihaza komut zarfları yayımlayan bir arka uç tüketicisidir.

Başlayın Geliştirici dokümanları

Genel bakış

Devam olaylarını alan ve cihaz komutlarını bir EMQX broker üzerinden ileten MQTT aktarım motoru — büyük bağlı filolar için tasarlandı.

MQTT Engine, Cams motor ailesindeki MQTT aktarımıdır; HTTP ve kalıcı TCP'nin karşılığıdır. Bir EMQX broker'ının arkasında arka uç tüketicisi olarak çalışır: api/mqtt/v1/{sn}/ altındaki paylaşılan devam ve varlık konularına abone olur, her olayı paylaşılan işlem hattına yönlendirir ve sunucudan cihaza komutları komut konusunda ileriye dönük uyumlu JSON zarfları olarak yayımlar. EMQX, cihaz TLS oturumlarını, kimlik doğrulamayı, QoS'u ve last-will'i sonlandırır; büyük filolar için birden fazla motor örneği EMQX paylaşılan abonelikleri ile yük dengelenir.

SERVICEMQTTEMQXTLSJSONC++

Kullanıldığı yerler:Filo, Ulaşım ve Sürücüler Etkinlikler, Festivaller ve Stadyumlar

MQTT konu şeması (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":{} }

Yetenekler

Neler yapar

MQTT ile Veri Alımı

Paylaşılan olay konularına abone olur ve her devam olayını HTTP ve TCP ile aynı depolama ve push işlem hattına yönlendirir.

Varlık Takibi

Varlık konusunu ve last-will'i tüketir; böylece broker'ın algıladığı bağlantı kopmaları cihazı çevrimdışı olarak işaretler.

Komut Gönderme

Kuyruğa alınan sunucudan cihaza komutları cihaz bazındaki komut konusunda QoS 1 ile JSON zarfları olarak yayımlar.

Yatay Ölçekleme

EMQX paylaşılan abonelikleri, büyük cihaz filoları için devam verisini birden fazla motor örneği arasında dengeler.

Özellikler

Her şey dahil

Devam için MQTT aktarım ön ucu; HTTP ve yerel TCP motorlarıyla eş düzeyde
Uygulama ve EMQX ACL ile uyumlu api/mqtt/v1/{sn}/{evt|cmd|st} konu şeması
EMQX arkasında arka uç tüketicisi: paylaşılan abonelikler N örnek arasında yük dengeler
Yükü HTTP punch gövdesiyle aynı olan devam olaylarını paylaşılan işlem hattına alır
Durum konusu üzerinden varlık ve last-will; kopmalar cihazları çevrimdışı olarak işaretler
İleriye dönük uyumlu {id, op, data} JSON zarfı olarak QoS 1 ile sunucudan cihaza komut gönderimi
CA doğrulamalı broker'a TLS; motor bir cihaz seri numarası değil, bir arka uç hesabı kullanır
Eclipse Paho C++ üzerinde çapraz platform derleme (Linux ve Windows)

MQTT Engine ile geliştirin

Bir anahtar alın, dokümanları okuyun ve yayına alın. Ekibimiz ilk entegrasyonunuzda yardımcı olur.

Bir mühendisle görüşün WhatsApp

SSS

Sık sorulan sorular

MQTT Engine, EMQX ile nasıl ilişkilidir?

EMQX; cihaz TLS oturumlarını, kimlik doğrulamayı, QoS'u ve last-will'i sonlandıran broker olmaya devam eder. MQTT Engine, devam verisini almak için paylaşılan konulara abone olan ve cihazlara komut yayımlayan bir arka uç tüketicisidir.

Birden fazla MQTT Engine örneği çalıştırabilir miyim?

Evet. EMQX paylaşılan abonelikleri, devam ve varlık konularını çalışan tüm örnekler arasında dengeler; dolayısıyla örnek ekleyerek ölçeklendirirsiniz.

Sunucudan cihaza komut formatı nedir?

Komut konusunda QoS 1 ile bir JSON zarfı {id, op, data}; op yegâne zorunlu alandır ve ileriye dönük uyumluluk için bilinmeyen op'lar eski cihazlar tarafından yok sayılır.