Conectar clientes MQTT usando Paho C

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

MQTT 3.1.1

#include .stdio.h
#include יstdlib.h
*incluyen.
#incluye el tiempo indicado.h
#include ■unistd.h
#include "MQTTAsync.h"

#define ADDRESS "tcp://localhost:1883"
#define TOPIC "sensor/temperatura"
#define PAYLOAD "180"
#define QOS 1
#define TIMEOUT 10000L

int finished = 0;

void generate_clientid(char *str, int str_length)
{}
srand(time(NULL));
const char *alphanum = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz", *PREFIX = "crystalmq_"
strncpy(str, PREFIX, strlen(PREFIX));
para (int i = 0; i) (str_length-strlen(PREFIX)); ++i) {
str[10 + i] = alfanum[rand() % 62]; // 62 es la longitud del alfanum cuerda
}
str[str_length] = '\0';
}

vacio en Desconexión (void* context, MQTTAsync_successData* response)
{}
printf("Succesful disconnection\n");
terminado = 1;
}

invalid onSubscribe(void* context, MQTTAsync_successData* response)
{}
printf("Suscribir sucedió\n");
}

vacío enConnectFailure(void* context, MQTTAsync_failureData* response)
{}
printf("Connect falló, rc %d\n", respuesta ? response- iconocode : 0);
terminado = 1;
}

vacío enConnect(void* context, MQTTAsync_successData* response)
{}
printf("Succesful connection\n");
}

int msgarrvd(void *context, char *topicName, int topicLen, MQTTAsync_message *mensaje)
{}
int i;
char* payloadptr;
printf("Message arrived\n");
printf(" tema: %s\n", topicName);
printf(" mensaje: ");
payloadptr = mensaje- ratiopayload;
para(i=0; ipayloadlen; i+)
{}
putchar(*payloadptr++);
}
putchar('\n');
MQTTAsync_freeMessage( implicamessage);
MQTTAsync_free(topicName);
retorno 1;
}

int main(int argc, char* argv[])
{}
// Crear cliente
char clientid[21];
generate_clientid(clientid, 20);
MQTTAsync client;
MQTTAsync_create, ADDRESS, clientid, MQTTCLIENT_PERSISTENCE_NONE, NULL);
MQTTAsync_setCallbacks(cliente, NULL, NULL, msgarrvd, NULL);

MQTTAsync_connectOptions conn_opts = MQTTAsync_connectOptions_initializer;
conn_opts.keepAliveInterval = 60;
conn_opts.cleansession = 1;
conn_opts.onSucces = onConnect;
conn_opts.on Failure = onConnectFailure;
conn_opts.context = cliente;
int rc;
si (rc = MQTTAsync_connect(client, &conn_opts)) != MQTTASYNC_SUCCESS)
{}
printf("Failed to start connect, return code %d\n", rc);
(EXIT_FAILURE);
}
sueño(1);

// Suscribirse
MQTTAsync_responseOptions sub_opts = MQTTAsync_responseOptions_initializer;
sub_opts.onSucces = onSubscribe;
sub_opts.context = cliente;
si (rc = MQTTAsync_subscribe(cliente, TOPIC, QOS, ⊂_opts)) != MQTTASYNC_SUCCESS)
{}
printf("Failed to subscribe, return code %d\n", rc);
(EXIT_FAILURE);
}

// Publish
MQTTAsync_message pubmsg = MQTTAsync_message_initializer;
pubmsg.payload = PAYLOAD;
pubmsg.payloadlen = strlen(PAYLOAD);
pubmsg.qos = QOS;
pubmsg.retained = 0;
si (rc = MQTTAsync_sendMessage(cliente, TOPIC, &pubmsg, NULL))!= MQTTASYNC_SUCCESS)
{}
printf("Failed to start sendMessage, return code %d\n", rc);
(EXIT_FAILURE);
}

Mientras (!finished)
#if defined(WIN32) tención eterna definida(WIN64)
(100 años);
#else
usleep(10000L);
#endif
MQTTAsync_destroy (cliente);
retorno rc;
}

MQTT 5

#include .stdio.h
#include יstdlib.h
*incluyen.
#incluye el tiempo indicado.h
#include ■unistd.h
#include "MQTTAsync.h"

#define ADDRESS "tcp://localhost:1883"
#define TOPIC "sensor/humidity"
Define PAYLOAD 20.3
#define QOS 1
#define TIMEOUT 10000L

int finished = 0;

void generate_clientid(char *str, int str_length)
{}
srand(time(NULL));
const char *alphanum = "0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz", *PREFIX = "crystalmq_"
strncpy(str, PREFIX, strlen(PREFIX));
para (int i = 0; i) (str_length-strlen(PREFIX)); ++i) {
str[10 + i] = alfanum[rand() % 62]; // 62 es la longitud del alfanum cuerda
}
str[str_length] = '\0';
}

vacio en Desconexión (void* context, MQTTAsync_successData* response)
{}
printf("Succesful disconnection\n");
terminado = 1;
}

vacío enConnectFailure(void* context, MQTTAsync_failureData* response)
{}
printf("Connect falló, rc %d\n", respuesta ? response- iconocode : 0);
terminado = 1;
}

vacío enConnect(void* context, MQTTAsync_successData* response)
{}
printf("Succesful connection\n");
}

int msgarrvd(void *context, char *topicName, int topicLen, MQTTAsync_message *mensaje)
{}
int i;
char* payloadptr;
printf("Message arrived\n");
printf(" tema: %s\n", topicName);
printf(" mensaje: ");
payloadptr = mensaje- ratiopayload;
para(i=0; ipayloadlen; i+)
{}
putchar(*payloadptr++);
}
putchar('\n');
MQTTAsync_freeMessage( implicamessage);
MQTTAsync_free(topicName);
retorno 1;
}

int main(int argc, char* argv[])
{}
// Crear cliente
char clientid[21];
generate_clientid(clientid, 20);
MQTTAsync client;
MQTTAsync_createOptions create_opts = MQTTAsync_createOptions_initializer;
create_opts.MQTTVersion = MQTTVERSION_5;
int rc = MQTTAsync_createConOpciones(clclient, ADDRESS, clientid, MQTTCLIENT_PERSISTENCE_NONE, NULL, &create_opts);
MQTTAsync_setCallbacks(cliente, NULL, NULL, msgarrvd, NULL);

/ Conjunto CONNECT Propiedades
MQTTAsync_connectOptions conn_opts = MQTTAsync_connectOptions_initializer5;
conn_opts.keepAliveInterval = 20;
conn_opts.cleanstart = 1;
conn_opts.onSucces = onConnect;
conn_opts.on Failure = onConnectFailure;
conn_opts.context = cliente;

MQTTProperties props = MQTTProperties_initializer;
// Intervalo de gastos de período de sesiones
MQTTProperty property1;
property1.identifier = MQTTPROPERTY_CODE_SESSION_EXPIRY_INTERVAL;
propiedad1.value.integer2 = 90;
MQTTProperties_add(corporaprops, &property1);

// Tamaño máximo del paquete
MQTTProperty property2;
propiedad2.identificador = MQTTPROPERTY_CODE_MAXIMUM_PACKET_SIZE;
property2.value.integer4 = 4094;
MQTTProperties_add(corporaprops, &property2);

conn_opts.connectProperties = &prop
si (rc = MQTTAsync_connect(client, &conn_opts)) != MQTTASYNC_SUCCESS)
{}
printf("Failed to start connect, return code %d\n", rc);
(EXIT_FAILURE);
}
sueño(1);

// Suscribirse
si (rc = MQTTAsync_subscribe(cliente, TOPIC, QOS, NULL)))!= MQTTASYNC_SUCCESS)
{}
printf("Failed to subscribe, return code %d\n", rc);
(EXIT_FAILURE);
}
sueño(1);

// Publish
MQTTAsync_message pubmsg = MQTTAsync_message_initializer;
pubmsg.payload = PAYLOAD;
pubmsg.payloadlen = strlen(PAYLOAD);
pubmsg.qos = QOS;
pubmsg.retained = 0;
// Set Publish Properties
MQTTAsync_responseOptions pub_opts = MQTTAsync_responseOptions_initializer;
pub_opts.context = cliente;
MQTTProperties pub_props = MQTTProperties_initializer;
MQTTProperty property3;
propiedad3.identifier = MQTTPROPERTY_CODE_TOPIC_ALIAS;
property3.value.integer4 = 90;
MQTTProperties_add( limitpub_props, &property3);
pub_opts.properties = pub_props;

si (rc = MQTTAsync_sendMessage(cliente, TOPIC, &pubmsg, &pub_opts))! = MQTTASYNC_SUCCESS)
{}
printf("Failed to start sendMessage, return code %d\n", rc);
(EXIT_FAILURE);
}

sueño(1);

si (rc = MQTTAsync_unsubscribe(cliente, TOPIC, NULL)) != MQTTASYNC_SUCCESS)
{}
printf("Failed to unsubscribe, return code %d\n", rc);
(EXIT_FAILURE);
}
Mientras (!finished)
#if defined(WIN32) tención eterna definida(WIN64)
(100 años);
#else
usleep(10000L);
#endif
MQTTAsync_destroy (cliente);
retorno rc;
}

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