amalgame-mqtt

Vue d'ensemble

Implémentation pure-AM du protocole MQTT 3.1.1 directement sur TCP brut. Idéal pour l'IoT et les pipelines de télémétrie : broker side compatible Mosquitto, HiveMQ, EMQX, AWS IoT Core.

Caractéristiques

• ✓Protocole MQTT 3.1.1 pur (CONNECT / SUBSCRIBE / PUBLISH / PINGREQ)
• ✓QoS 0 (fire-and-forget) en v1 — QoS 1/2 prévus
• ✓Wildcard + et # dans les topics
• ✓Retained messages et will-messages
• ✓TLS via amalgame-tls en option

Exemple

Exemple minimal d'utilisation — recopiable tel quel après l'install.

amc package add mqtt

let c = MqttClient.Connect("tcp://broker:1883", "client-42")
c.Subscribe("sensors/+/temp")
c.OnMessage(fn(topic, payload) {
    Console.WriteLine(topic + " → " + payload)
})
c.Publish("sensors/room1/temp", "21.5")

Packages liés