如何使用C/C++实现Raspberry Pi Pico W与MQTT Broker的连接？

一、官方pico-examples核心模块解析 #

官方pico_w示例里的关键模块是WiFi驱动与lwIP网络栈：

• wifi_connect示例：负责初始化cyw43无线芯片、建立WiFi连接，核心函数cyw43_arch_init初始化硬件，cyw43_arch_wifi_connect_async异步发起WiFi连接，cyw43_arch_wait_for_event处理网络事件循环。
• http_client示例：展示基于lwIP的TCP客户端通信，这是MQTT协议的基础（MQTT构建在TCP之上）。

二、C/C++实现MQTT连接步骤 #

1. 环境配置 #

确保Pico SDK已启用pico_w组件，在CMakeLists.txt中添加：

set(PICO_BOARD pico_w)
target_link_libraries(your_project_name
        pico_cyw43_arch_lwip_threadsafe_background
        pico_stdlib
        lwip_apps_mqtt
)

2. WiFi连接实现 #

复用官方WiFi连接逻辑，确保设备成功接入局域网：

#include "pico/cyw43_arch.h"

static bool wifi_connected = false;

static void wifi_connect_callback(cyw43_arch_event_t event, uint32_t status) {
    if (event == CYW43_ARCH_EVENT_CONNECTED) {
        wifi_connected = true;
    } else if (event == CYW43_ARCH_EVENT_DISCONNECTED) {
        wifi_connected = false;
        // 可添加重连逻辑
    }
}

void init_wifi() {
    cyw43_arch_init();
    cyw43_arch_enable_sta_mode();
    cyw43_arch_set_event_callback(wifi_connect_callback);
    cyw43_arch_wifi_connect_async(WIFI_SSID, WIFI_PASSWORD, CYW43_AUTH_WPA2_AES_PSK);
    
    // 等待WiFi连接完成
    while (!wifi_connected) {
        cyw43_arch_wait_for_event(NULL);
    }
}

3. MQTT客户端集成与HiveMQ连接 #

使用lwIP自带的MQTT客户端组件（无需额外第三方库），实现连接、订阅、发布：

#include "lwip/apps/mqtt.h"
#include "lwip/netif.h"

#define MQTT_BROKER "your-hivemq-broker-address"
#define MQTT_PORT 1883
#define MQTT_CLIENT_ID "pico-w-client"
#define MQTT_TOPIC "test/topic"

static struct mqtt_client mqtt_client;
static ip_addr_t broker_ip;

// MQTT事件回调
static void mqtt_event_cb(struct mqtt_client *client, void *arg, mqtt_event_t event) {
    switch (event) {
        case MQTT_EVENT_CONNECTED:
            printf("Connected to HiveMQ broker\n");
            // 订阅主题
            mqtt_subscribe(client, MQTT_TOPIC, 0);
            break;
        case MQTT_EVENT_DISCONNECTED:
            printf("Disconnected from broker\n");
            break;
        case MQTT_EVENT_PUBLISH_RECEIVED:
            {
                struct mqtt_message *msg = (struct mqtt_message*)arg;
                printf("Received message on %s: %.*s\n", msg->topic, msg->payload_len, (char*)msg->payload);
                mqtt_free_message(msg);
            }
            break;
        default:
            break;
    }
}

void init_mqtt() {
    // 解析HiveMQ broker地址
    netconn_gethostbyname(MQTT_BROKER, &broker_ip);
    
    // 初始化MQTT客户端
    mqtt_client_init(&mqtt_client, &broker_ip, MQTT_PORT, mqtt_event_cb, NULL);
    
    // 配置连接参数
    struct mqtt_connect_client_info_t client_info = {0};
    client_info.client_id = MQTT_CLIENT_ID;
    // 若HiveMQ需认证，添加用户名密码
    // client_info.username = "your-username";
    // client_info.password = "your-password";
    
    // 发起MQTT连接
    mqtt_connect(&mqtt_client, &client_info);
}

// 发布消息函数
void mqtt_publish_message(const char* topic, const char* payload) {
    mqtt_publish(&mqtt_client, topic, payload, strlen(payload), 0, false);
}

4. 主函数逻辑 #

int main() {
    stdio_init_all();
    
    // 初始化WiFi
    init_wifi();
    printf("WiFi connected\n");
    
    // 初始化MQTT并连接HiveMQ
    init_mqtt();
    
    // 事件循环
    while (true) {
        cyw43_arch_wait_for_event(NULL);
        mqtt_client_tick(&mqtt_client, 1000);
        
        // 每隔5秒发布一条测试消息
        static uint32_t last_publish = 0;
        if (time_us_32() - last_publish > 5000000) {
            mqtt_publish_message(MQTT_TOPIC, "Hello from Pico W!");
            last_publish = time_us_32();
        }
    }
    
    cyw43_arch_deinit();
    return 0;
}

三、与Arduino Adafruit_MQTT_Client的对应关系 #

四、注意事项 #

• 若使用HiveMQ的TLS加密端口（8883），需启用Pico W的TLS支持，在CMakeLists.txt中添加pico_cyw43_arch_lwip_tls替代pico_cyw43_arch_lwip_threadsafe_background，并配置证书。
• 确保HiveMQ broker允许Pico W的IP地址接入，若使用云HiveMQ，需在控制台配置允许的客户端来源。

内容的提问来源于stack exchange，提问作者Mr I