MQTT Clients mit Paho C verbinden

MQTTAsync_disconnect(client, NULL);
MQTTAsync_destroy(&client);

MQ3.1.1

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include "MQTTAsync.h"

#definieren Sie ADDRESS "tcp://localhost:1883"
#definieren TOPIC "Sensor/Temperatur"
#define PAYLOAD "180"
#define QOS 1
#define TIMEOUT 10000L

int fertig = 0;

Leer generieren_clientid(char *str, int str_length)
{\cHFFFF}
srand(time(NULL));
const char *alphanum = *PREFIX = "kristallmq_";
Strncpy(str, PREFIX, strlen(PREFIX));
für (int i = 0; i < (str_length-strlen(PREFIX)); ++i)
str[10 + i] = alphanum[rand() % 62]; // 62 ist die Länge des alphanums Zeichen
}
Str[str_length] = '\0';
}

Leere onDisconnect(void* Kontext, MQTTAsync_successData* Antwort
{\cHFFFF}
printf("Erfolgsame Trennung\n");
Fertig = 1;
}

Leere auf Abonnieren(void* Kontext, MQTTAsync_successData* Antwort
{\cHFFFF}
printf("Beschreiben Sie erfolgreich\n");
}

ungültig aufConnectFailure(void* Kontext, MQTTAsync_failureData* Antwort
{\cHFFFF}
printf("Connect fail, rc %d\n", Antwort? Antwort>code : 0);
Fertig = 1;
}

Leere onConnect(void* Kontext, MQTTAsync_successData* Antwort
{\cHFFFF}
printf("Erfolgreiche Verbindung\n");
}

int msgarrvd(void *context, char *topicName, int topicLen, MQTTAsync_message *Nachrichten)
{\cHFFFF}
int i;
char* payloadptr;
printf("Message eingetroffen\n");
printf(" Thema: %s\n", topName);
printf("-Nachricht: ");
payloadptr = message->payload;
für(i=0; i(i++)
(STÖHNT)
putchar(*payloadptr++)
}
putchar('n');
MQTTAsync_freeMessage(&message);
MQTTAsync_free(topicName);
Rückgabe 1;
}

int main(int argc, char* argv[])
(STÖHNT)
• Der Kunde
Char-Client[21];
(clientid, 20)
MQTTAsync Client;
MQTTAsync_create(&client, ADDRESS, clientid, MQTTCLIENT_PERSISTENCE_NONE, NULL;
MQTTAsync_setCallbacks(Client, NULL, NULL, msgarrvd, NULL);

MQTTAsync_connectOptionen conn_opts = MQTTAsync_connectOptionen_initializer;
conn_opts.keepAliveInterval = 60;
conn_opts.cleansession = 1;
conn_opts.onSuccess = onConnect;
Der Präsident Ausfall = onConnectFailure;
conn_opts.context = Client;
int rc;
wenn ((rc = MQTTAsync_connect(client, &conn_opts))) MQTTASYNC_SUCCESS)
(STÖHNT)
printf("Failed to start connect, return code %d\n", rc);
Ausstieg (EXIT_FAILURE)
}
Schlaf(1);

Ich bin hier.
MQTTAsync_responseOptionen sub_opts = MQTTAsync_responseOptionen_initializer;
sub_opts.onSuccess = onSubscribe;
sub_opts.context = Client;
wenn ((rc = MQTTAsync_subscribe(client, TOPIC, QOS, Θ_opts))) MQTTASYNC_SUCCESS)
(STÖHNT)
printf("Failing to abonnieren, return code %d\n", rc);
Ausstieg (EXIT_FAILURE)
}

Englisch
MQTTAsync_message pubmsg = MQTTAsync_message_initializer;
pubmsg.payload = PAYLOAD;
pubmsg.payloadlen = strlen(PAYLOAD);
pubmsg.qos = QOS;
Pubmsg.retained = 0;
wenn (rc = MQTTAsync_sendMessage(client, TOPIC, &pubmsg, NULL)) MQTTASYNC_SUCCESS)
(STÖHNT)
printf("Failed to start sendMessage, return code %d\n", rc);
Ausstieg (EXIT_FAILURE)
}

(!vollendet)
#if definiert(WIN32) || definiert(WIN64)
Schlaf(100)
#else
Verwendungep(10000L)
#endif
MQTTAsync_destroy(&client);
Rückgabe rc;
}

MQTT 5

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include "MQTTAsync.h"

#definieren Sie ADDRESS "tcp://localhost:1883"
#definieren TOPIC "Sensor/Feuchtigkeit"
#define PAYLOAD "20.3"
#define QOS 1
#define TIMEOUT 10000L

int fertig = 0;

Leer generieren_clientid(char *str, int str_length)
{\cHFFFF}
srand(time(NULL));
const char *alphanum = *PREFIX = "kristallmq_";
Strncpy(str, PREFIX, strlen(PREFIX));
für (int i = 0; i < (str_length-strlen(PREFIX)); ++i)
str[10 + i] = alphanum[rand() % 62]; // 62 ist die Länge des alphanums Zeichen
}
Str[str_length] = '\0';
}

Leere onDisconnect(void* Kontext, MQTTAsync_successData* Antwort
{\cHFFFF}
printf("Erfolgsame Trennung\n");
Fertig = 1;
}

ungültig aufConnectFailure(void* Kontext, MQTTAsync_failureData* Antwort
{\cHFFFF}
printf("Connect fail, rc %d\n", Antwort? Antwort>code : 0);
Fertig = 1;
}

Leere onConnect(void* Kontext, MQTTAsync_successData* Antwort
{\cHFFFF}
printf("Erfolgreiche Verbindung\n");
}

int msgarrvd(void *context, char *topicName, int topicLen, MQTTAsync_message *Nachrichten)
{\cHFFFF}
int i;
char* payloadptr;
printf("Message eingetroffen\n");
printf(" Thema: %s\n", topName);
printf("-Nachricht: ");
payloadptr = message->payload;
für(i=0; i(i++)
(STÖHNT)
putchar(*payloadptr++)
}
putchar('n');
MQTTAsync_freeMessage(&message);
MQTTAsync_free(topicName);
Rückgabe 1;
}

int main(int argc, char* argv[])
(STÖHNT)
• Der Kunde
Char-Client[21];
(clientid, 20)
MQTTAsync Client;
MQTTAsync_createOptionen create_opts = MQTTAsync_createOptionen_initializer;
create_opts.MQTTVersion = MQTTVERSION_5;
int rc = MQTTAsync_createWithOptionen(Client, ADDRESS, clientid, MQTTCLIENT_PERSISTENCE_NONE, NULL, &create_opts;
MQTTAsync_setCallbacks(Client, NULL, NULL, msgarrvd, NULL);

// KONNEKT Eigenschaften
MQTTAsync_connectOptionen conn_opts = MQTTAsync_connectOptionen_initializer5;
conn_opts.keepAliveInterval = 20;
conn_opts.cleanstart = 1;
conn_opts.onSuccess = onConnect;
Der Präsident Ausfall = onConnectFailure;
conn_opts.context = Client;

MQTTProperties props = MQTTProperties_initializer;
Englisch abbrechen
MQTTProperty property1;
Eigenschaften1.identifier = MQTTPROPERTY_CODE_SESSION_EXPIRY_INTERVAL;
Eigenschaften1.value.integer2 = 90;
MQTTProperties_add(&properties1)

// Maximale Packungsgröße
MQTTProperty property2;
property2.identifier = MQTTPROPERTY_CODE_MAXIMUM_PACKET_SIZE;
Eigenschaften2.value.integer4 = 4094;
MQTTProperties_add(&properties2);

conn_opts.connectProperties = &props
wenn ((rc = MQTTAsync_connect(client, &conn_opts))) MQTTASYNC_SUCCESS)
(STÖHNT)
printf("Failed to start connect, return code %d\n", rc);
Ausstieg (EXIT_FAILURE)
}
Schlaf(1);

Ich bin hier.
wenn (rc = MQTTAsync_subscribe(client, TOPIC, QOS, NULL)) MQTTASYNC_SUCCESS)
(STÖHNT)
printf("Failing to abonnieren, return code %d\n", rc);
Ausstieg (EXIT_FAILURE)
}
Schlaf(1);

Englisch
MQTTAsync_message pubmsg = MQTTAsync_message_initializer;
pubmsg.payload = PAYLOAD;
pubmsg.payloadlen = strlen(PAYLOAD);
pubmsg.qos = QOS;
Pubmsg.retained = 0;
Englisch Sie haben es geschafft
MQTTAsync_responseOptionen pub_opts = MQTTAsync_responseOptionen_initializer;
pub_opts.context = Client;
MQTTProperties pub_props = MQTTProperties_initializer;
MQTTProperty Eigenschaft3;
Eigenschaften3.identifier = MQTTPROPERTY_CODE_TOPIC_ALIAS;
Eigenschaften3.value.integer4 = 90;
MQTTProperties_add(&pub_property3);
pub_opts.properties = pub_properties;

wenn (rc = MQTTAsync_sendMessage(client, TOPIC, &pubmsg, &pub_opts))) MQTTASYNC_SUCCESS)
(STÖHNT)
printf("Failed to start sendMessage, return code %d\n", rc);
Ausstieg (EXIT_FAILURE)
}

Schlaf(1);

wenn (rc = MQTTAsync_unsubscribe(client, TOPIC, NULL))) MQTTASYNC_SUCCESS)
(STÖHNT)
printf("Failed to abbestellen, return code %d\n", rc);
Ausstieg (EXIT_FAILURE)
}
(!vollendet)
#if definiert(WIN32) || definiert(WIN64)
Schlaf(100)
#else
Verwendungep(10000L)
#endif
MQTTAsync_destroy(&client);
Rückgabe rc;
}

$ gcc -o mqtclient mqtclient.c -lpaho-mqt3a -lpaho-mqt3as
$ ./mqtclient