На веб-сайте Eclipse Paho MQTT разработчики предоставляют пример клиента (http://www.eclipse.org/paho/files/mqttdoc/MQTTClient/html/pubsync.html), который делает следующее:
- Создать клиентский объект с указанными параметрами
- Подключить клиент с указанными параметрами подключения
- Публикация MQTT-сообщения
- Отключить клиент
- Уничтожить клиентский объект
Это хорошо работает, если все, что вы хотите, это опубликовать одно сообщение.
В моем коде есть функция, которая содержит почти тот же код, что и в вышеупомянутом примере, однако функция многократно вызывается из main(), так как мне нужно публиковать большое количество сообщений одно за другим. Проблема в том, что если я использую код точно так же, как в примере, каждый раз, когда вызывается моя функция, создается новое соединение, которое вскоре после этого уничтожается. Это происходит снова и снова и снова, пока функция вызывается неоднократно, вызывая огромные накладные расходы.
Есть ли способ проверить, был ли уже создан клиентский объект, и если да, то не делать этого снова, а использовать существующий?
Насколько я понимаю, это должна делать функция MQTTClient_isConnected(): noreferrer">https://www.eclipse.org/paho/files/mqttdoc/MQTTClient/html/_m_q_t_t_client_8h.html#ad9e40bdb7149ee3e5d075db7f51a735f Но если я попробую так, я получу ошибку сегментации:
if (!MQTTClient_isConnected(client)) {
MQTTClient_create(&client, mqtt.addr, CLIENT_ID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
conn_opts.keepAliveInterval = 20;
conn_opts.cleansession = 1;
conn_opts.username = TOKEN;
if (MQTTClient_connect(client, &conn_opts) != MQTTCLIENT_SUCCESS) {
printf("\n==> Connection to MQTT Broker failed.\n");
MQTTClient_destroy(&client);
exit(EXIT_FAILURE);
}
}
[ИЗМЕНИТЬ]
Вот простой демонстрационный код, который лучше иллюстрирует то, что я пытаюсь сделать:
#include <stdio.h>
#include <MQTTClient.h>
MQTTClient client;
void publish_MQTT() {
MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;
MQTTClient_message pubmsg = MQTTClient_message_initializer;
MQTTClient_deliveryToken token;
char *payload = (char *)calloc(1024, sizeof(char));
strcpy(payload, "hello");
printf("DEBUG_BEFORE >> MQTTClient_isConnected(client) = %d\n", MQTTClient_isConnected(client)); // DEBUG OUTPUT
if (!MQTTClient_isConnected(client)) {
MQTTClient_create(&client, addr, CLIENT_ID, MQTTCLIENT_PERSISTENCE_NONE, NULL);
conn_opts.keepAliveInterval = 20;
conn_opts.cleansession = 1;
conn_opts.username = TOKEN;
if (MQTTClient_connect(client, &conn_opts) != MQTTCLIENT_SUCCESS) {
fprintf(stderr, RED "\n==> Connection to MQTT Broker failed.\n" RESET_CL);
MQTTClient_destroy(&client);
free(payload);
exit(EXIT_FAILURE);
}
}
printf("DEBUG_AFTER >> MQTTClient_isConnected(client) = %d\n", MQTTClient_isConnected(client)); // DEBUG OUTPUT
pubmsg.payload = payload;
pubmsg.payloadlen = strlen(payload);
pubmsg.qos = QOS;
pubmsg.retained = 0;
MQTTClient_publishMessage(client, TOPIC, &pubmsg, &token);
MQTTClient_waitForCompletion(client, token, TIMEOUT);
//MQTTClient_disconnect(client, 10000);
//MQTTClient_destroy(&client);
free(payload);
}
int main(void) {
for (i=0; i<1000; i++) {
publish_MQTT();
}
return 0;
}
Пожалуйста, игнорируйте тот факт, что параметр addr никогда не указывается (в моем реальном коде это так) или что довольно бесполезно указывать сообщение в функции publish_MQTT() (в моем реальном коде данные передаются из main() в эту функцию). ).
