====== std.net.mqtt ======

MQTT 3.1.1 (ISO/IEC 20922) ist ein schlankes Publish/Subscribe-Protokoll, das speziell für IoT- und M2M-Kommunikation mit geringer Bandbreite und instabilen Verbindungen entwickelt wurde. Clients verbinden sich mit einem Broker und tauschen Nachrichten über Topics aus. Die Unit unterstützt QoS-Stufen 0 (at most once), 1 (at least once) und 2 (exactly once) sowie alle MQTT-Kontrollpakete.

Einsatzbereiche sind Sensornetze, Smart-Home-Systeme, Telemetrie-Plattformen, industrielle Steuerungen (IIoT) und Edge-Computing-Umgebungen mit vielen leichtgewichtigen Clients.

<code lyx>
import std.net.mqtt;

var conn: MQTTConn := MQTTConnect("broker.example.com", 1883, "sensor-01");
MQTTPublish(conn, "sensors/temperature", "23.4", 4, 0);
MQTTDisconnect(conn);
</code>

----

===== Imports =====

  * ''std.net.socket''
  * ''std.net.dns''
  * ''std.net.types''

----

===== Konstanten =====

^ Name ^ Typ ^ Wert ^ Sichtbarkeit ^
| ''MQTT_PORT'' | ''int64'' | ''1883'' | pub |
| ''MQTTS_PORT'' | ''int64'' | ''8883'' | pub |
| ''MQTT_PKT_CONNECT'' | ''int64'' | ''1'' | pub |
| ''MQTT_PKT_CONNACK'' | ''int64'' | ''2'' | pub |
| ''MQTT_PKT_PUBLISH'' | ''int64'' | ''3'' | pub |
| ''MQTT_PKT_PUBACK'' | ''int64'' | ''4'' | pub |
| ''MQTT_PKT_PUBREC'' | ''int64'' | ''5'' | pub |
| ''MQTT_PKT_PUBREL'' | ''int64'' | ''6'' | pub |
| ''MQTT_PKT_PUBCOMP'' | ''int64'' | ''7'' | pub |
| ''MQTT_PKT_SUBSCRIBE'' | ''int64'' | ''8'' | pub |
| ''MQTT_PKT_SUBACK'' | ''int64'' | ''9'' | pub |
| ''MQTT_PKT_UNSUBSCRIBE'' | ''int64'' | ''10'' | pub |
| ''MQTT_PKT_UNSUBACK'' | ''int64'' | ''11'' | pub |
| ''MQTT_PKT_PINGREQ'' | ''int64'' | ''12'' | pub |
| ''MQTT_PKT_PINGRESP'' | ''int64'' | ''13'' | pub |
| ''MQTT_PKT_DISCONNECT'' | ''int64'' | ''14'' | pub |
| ''MQTT_QOS_AT_MOST_ONCE'' | ''int64'' | ''0'' | pub |
| ''MQTT_QOS_AT_LEAST_ONCE'' | ''int64'' | ''1'' | pub |
| ''MQTT_QOS_EXACTLY_ONCE'' | ''int64'' | ''2'' | pub |
| ''MQTT_RC_ACCEPTED'' | ''int64'' | ''0'' | pub |
| ''MQTT_RC_UNACCEPTABLE_PROTOCOL'' | ''int64'' | ''1'' | pub |
| ''MQTT_RC_IDENTIFIER_REJECTED'' | ''int64'' | ''2'' | pub |
| ''MQTT_RC_SERVER_UNAVAILABLE'' | ''int64'' | ''3'' | pub |
| ''MQTT_RC_BAD_USERNAME_PASSWORD'' | ''int64'' | ''4'' | pub |
| ''MQTT_RC_NOT_AUTHORIZED'' | ''int64'' | ''5'' | pub |

----

===== Typen =====

==== MQTTConn (struct) ====

^ Feld ^ Typ ^

==== MQTTPacket (struct) ====

^ Feld ^ Typ ^


----

===== Funktionen =====

^ Signatur ^ Sichtbarkeit ^ Beschreibung ^
| ''MQTTStrLen(s: int64): int64'' | pub | Länge eines C-Strings berechnen |
| ''MQTTWriteRemainingLen(buf: int64, pos: int64, length: int64): int64'' | pub | Variable Restlänge in Puffer schreiben |
| ''MQTTReadRemainingLen(buf: int64, pos: int64): int64'' | pub | Variable Restlänge aus Puffer lesen |
| ''MQTTWriteString(buf: int64, pos: int64, str: int64, len: int64): int64'' | pub | UTF-8-String mit Länge in Puffer schreiben |
| ''MQTTReadString(buf: int64, pos: int64): int64'' | pub | UTF-8-String aus Puffer lesen |
| ''MQTTNextPacketId(): int64'' | pub | Nächste eindeutige Paket-ID erzeugen |
| ''MQTTBuildConnect(clientId: int64, keepAlive: int64, username: int64, password: int64): int64'' | pub | CONNECT-Paket aufbauen |
| ''MQTTPublish(topic: int64, payload: int64, payloadLen: int64, qos: int64, retain: int64): int64'' | pub | PUBLISH-Paket aufbauen |
| ''MQTTBuildSubscribe(topic: int64, qos: int64): int64'' | pub | SUBSCRIBE-Paket aufbauen |
| ''MQTTBuildUnsubscribe(topic: int64): int64'' | pub | UNSUBSCRIBE-Paket aufbauen |
| ''MQTTBuildPingReq(): int64'' | pub | PINGREQ-Paket aufbauen |
| ''MQTTBuildDisconnect(): int64'' | pub | DISCONNECT-Paket aufbauen |
| ''MQTTSend(conn: TCPConn, pkt: int64, pktLen: int64): int64'' | pub | MQTT-Paket über TCP senden |
| ''MQTTRecv(conn: TCPConn): int64'' | pub | MQTT-Paket über TCP empfangen |
| ''MQTTParseConnack(buf: int64): int64'' | pub | CONNACK-Antwort parsen und prüfen |
| ''MQTTParsePublish(buf: int64): MQTTPacket'' | pub | PUBLISH-Paket parsen |
| ''MQTTConnect(host: int64, port: int64, clientId: int64): MQTTConn'' | pub | Verbindung zu Broker aufbauen |
| ''MQTTSubscribe(mqtt: MQTTConn, topic: int64, qos: int64): int64'' | pub | Topic beim Broker abonnieren |
| ''MQTTPublishMsg(mqtt: MQTTConn, topic: int64, payload: int64, payloadLen: int64, qos: int64): int64'' | pub | Nachricht auf Topic veröffentlichen |
| ''MQTTReceive(mqtt: MQTTConn): MQTTPacket'' | pub | Nächstes eingehendes Paket empfangen |
| ''MQTTSendPing(mqtt: MQTTConn): int64'' | pub | Keep-Alive-Ping an Broker senden |
| ''MQTTDisconnect(mqtt: MQTTConn)'' | pub | Verbindung zum Broker trennen |
| ''MQTTPacketFree(pkt: MQTTPacket)'' | pub | Paket-Speicher freigeben |