LWip MQTT编程

LWIP (Lightweight IP) 是一个专门为嵌入式系统设计的轻量级TCP/IP协议栈，而MQTT（Message Queuing Telemetry Transport）是一种专为物联网设计的轻量级消息传递协议。在STM32开发板上使用Lwip进行MQTT编程通常涉及以下步骤[^1]:

1. **配置Lwip**: 首先，你需要在STM32的Lwip配置中启用MQTT支持。这通常包括设置合适的内存分配策略和网络接口。

// 在 lwipopts.h 中启用 MQTT 功能
#define LWIP_SOCKET 1
#define LWIP_TCP 1
#define LWIP_MQTT 1

2. **初始化Lwip**: 然后在应用程序中初始化Lwip堆栈和MQTT模块。

void mqtt_init(void) {
    // 初始化 LwIP
    esp_err_t err = lwip_init();
    if (err != ESP_OK) {
        // 处理错误
    }

    // 初始化 MQTT 连接
    mqtt_client_config_t mqtt_cfg = MQTT_CLIENT_DEFAULT;
    mqtt_err_t mqtt_err = mqtt_client_new(&mqtt_cfg, &client);
    if (mqtt_err != MQTT_OK) {
        // 处理错误
    }
}

3. **连接到MQTT服务器**: 使用`mqtt_client_connect()`函数连接到MQTT服务器。

void connect_to_mqtt_server(void) {
    struct sockaddr_in server_addr;
    // 设置服务器地址和端口
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(MQTT_SERVER_PORT);
    inet_pton(AF_INET, MQTT_SERVER_IP, &server_addr.sin_addr);

    mqtt_err_t err = mqtt_client_connect(client, (struct ip_addr *)&server_addr, sizeof(server_addr), 5000);
    if (err != MQTT_OK) {
        // 处理连接错误
    }
}

4. **发送和接收消息**: 使用`mqtt_client_publish()`发送消息，`mqtt_msg_callback()`处理接收到的消息。

void publish_message(const char* topic, const char* message) {
    mqtt_msg_info_t msg_info = {MQTT_MSG_ID_NONE, NULL, strlen(message)};
    mqtt_err_t err = mqtt_client_publish(client, topic, &msg_info, strlen(message), 0, NULL);
    if (err != MQTT_OK) {
        // 处理发布错误
    }
}

void handle_msg(mqtt_msg_handle_t msg) {
    // 处理接收到的消息
    printf("Received message on topic %s: %.*s\n", mqtt_msg_topic(msg), (int)mqtt_msg_len(msg), mqtt_msg_payload(msg));
}

5. **断开连接和清理**: 当不再需要连接时，记得调用`mqtt_client_disconnect()`并清理资源。

void disconnect_from_mqtt(void) {
    mqtt_err_t err = mqtt_client_disconnect(client);
    if (err != MQTT_OK) {
        // 处理断开错误
    }

    mqtt_client_destroy(client);
    client = NULL;
}