linux连接mqtt后如何在其它函数中使用MQTTAsync_send函数

在Linux上使用MQTT协议并利用`paho-mqtt-c`库连接到MQTT服务器后，要在其他函数中使用`MQTTAsync_send()`函数，你需要首先初始化异步客户端，然后创建消息并注册回调处理发送结果。以下是一个简单的步骤：

1. **包含头文件**:

   #include <stdio.h>
   #include "mosquitto.h"

2. **初始化MQTT客户端**:

   MQTTClient *client;
   int result;

   client = mqtt_new();
   if (client == NULL) {
       perror("Failed to create MQTT client");
       return -1;
   }
   
   result = mqtt_connect(client, "your_broker_address", 1883, NULL); // 连接信息
   if (result != MOSQ_ERR_SUCCESS) {
       fprintf(stderr, "Connection failed: %s\n", mosquitto_strerror(result));
       mqtt_destroy(client);
       return -1;
   }

3. **设置异步消息发送**:

   void message_sent_callback(void *obj, MQTTMessage *msg) {
       printf("Message sent successfully: %.*s\n", msg->payloadlen, (char *)msg->payload);
   }

   MQTTAsync_message *msg指针;
   msg = mqtt_async_message_new(client, topic.c_str(), payload.c_str(), strlen(payload), false /* retain */, &message_sent_callback, NULL /* context */);

4. **在需要的地方发送消息**:

   int send_result;
   MQTTAsync_send(client, msg, &send_result);
   if (send_result != MQTTASYNC_SUCCESS) {
       // Handle error
       printf("Sending failed: %d (%s)\n", send_result, mqtt_errno_description(send_result));
   }

   mqtt_async_free(&msg);

5. **记得管理生命周期**:
确保在不需要的时候关闭连接和释放资源：

   // 在适当的位置关闭连接
   mqtt_disconnect(client);
   mqtt_destroy(client);

每个函数中使用`MQTTAsync_send()`之前，需要先确保消息已经通过`mqtt_async_message_new()`构造，并且客户端处于连接状态。