arduino emqx连接 esp32c3

### Arduino EMQX 连接 ESP32-C3 示例教程 #### 准备工作 为了使ESP32-C3能够通过MQTT协议与EMQX服务器建立连接并交换数据，需完成如下准备工作： - 安装Arduino IDE，并按照指南配置好支持ESP32-C3的开发环境[^1]。 - 下载并安装用于处理MQTT消息传递的PubSubClient库以及Wi-Fi管理库。 #### 硬件设置 确保已准备好以下硬件组件： - ESP32-C3开发板一块； - USB转TTL串口线一根（用于上传程序到ESP32-C3）； #### 软件编写 创建一个新的Arduino项目，在其中加入必要的头文件来初始化网络连接和客户端对象。以下是具体的代码实现方式： ```cpp #include <WiFi.h> #include <PubSubClient.h> // WiFi参数定义 const char* ssid = "your_SSID"; // 替换成自己的SSID名称 const char* password = "your_PASSWORD"; // 替换成对应的密码 // MQTT Broker地址及相关信息设定 const char* mqtt_server = "broker.emqx.io"; const int mqtt_port = 1883; const char* client_id = "test_client"; // 创建WiFi客户端实例 WiFiClient espClient; // 初始化MQTT客户端, 并关联至上述创建好的WiFi客户端 PubSubClient client(espClient); void setup_wifi() { delay(10); Serial.println(); Serial.print("Connecting to "); Serial.println(ssid); WiFi.begin(ssid, password); // 开始尝试连接指定的WiFi热点 while (WiFi.status() != WL_CONNECTED) { delay(500); Serial.print("."); } randomSeed(micros()); Serial.println(""); Serial.println("WiFi connected"); Serial.println("IP address: "); Serial.println(WiFi.localIP()); } void reconnect() { // 循环直到成功重连上MQTT broker为止... while (!client.connected()) { Serial.print("Attempting MQTT connection..."); if (client.connect(client_id)) { Serial.println("connected"); // 成功后订阅主题topic/test client.subscribe("topic/test"); } else { Serial.print("failed, rc="); Serial.print(client.state()); Serial.println(" try again in 5 seconds"); delay(5000); } } } void callback(char* topic, byte* payload, unsigned int length) { Serial.print("Message arrived ["); Serial.print(topic); Serial.print("] "); for (int i=0;i<length;i++) { Serial.print((char)payload[i]); } Serial.println(); // 判断收到的消息是否为"on" if ((char*)payload == "on") { digitalWrite(BUILTIN_LED, LOW); } else { digitalWrite(BUILTIN_LED, HIGH); } } void setup() { pinMode(BUILTIN_LED, OUTPUT); // 设置内置LED引脚模式为输出 Serial.begin(115200); setup_wifi(); // 执行WiFi连接过程 client.setServer(mqtt_server, mqtt_port);// 设定MQTT服务端的相关属性 client.setCallback(callback); // 注册回调函数以响应来自Broker的通知事件 } void loop() { if (!client.connected()) { reconnect(); } client.loop(); static unsigned long lastMsg = 0; const unsigned long interval = 1000; if (millis() - lastMsg > interval) { lastMsg = millis(); String msg = "hello world!"; Serial.print("Publish message: "); Serial.println(msg); client.publish("topic/test", msg.c_str()); // 发布一条测试性质的消息给特定的主题 } } ``` 此段代码实现了基本的功能需求——即让ESP32-C3设备作为MQTT客户端向EMQX云端发送简单的字符串型消息，并监听由其他节点发布的相同主题下的更新通知。每当检测到来自外部的新指令时，则依据其内容控制板载指示灯的状态变化。 #### 测试验证 当一切准备就绪之后，可以将编译后的固件烧录进ESP32-C3芯片内运行起来看效果。正常情况下，应当能够在终端界面上观察到有关于WiFi接入状态、MQTT握手情况的日志记录，同时也可通过浏览器访问EMQX Dashboard界面查看在线设备列表里新增加了一个名为`test_client`的身份标识符。