ESP8266接入阿里云（Arduino）

下载Arduino

下载链接一：Software | Arduino
下载连接二：Arduino IDE下载（2月21日更新到1.8.19）-Arduino中文社区 - Powered by Discuz!
安装好之后安装esp8266的包

---

安装ESP8266包

安装方式一：

• 在首选项开发板管理器里面添加
  
  
  
  • http://arduino.esp8266.com/stable/package_esp8266com_index.json
    
  • 
    
  •  
    
  
  
•  然后在开发板管理器界面搜索esp8266，运气好的话可能就搜索到了，反正我是从来没搜到过，下面介绍第二种安装方式
  
  
  
  • 
    
  • 
    
  
  

安装方式二：第3章 ESP8266-NodeMCU通过C/C++开发使用物联网 – 太极创客
从上述的网站中下载esp8266的插件，然后点击安装即可

---

安装MQTT包 

搜索pubsubclient，然后安装如下所示的包，版本自己选择

---

修改源文件（！！！） 

        这一步挺重要的，之前按照网上的教程装好上述的包之后还是一直连接不上阿里云，总是一直返回错误。后来找到一个教程说要修改源文件，然后就好了。不过我搞忘记在哪看到的了。具体步骤是：

• 找到包安装的位置
  
  
  
  • 第一个可能的位置（默认位置）：在C盘文档里面有个Arduino，然后点开里面有个libraries，安装的包都在这里面
    
  • 第二个可能的位置：就是可能自己选了一个目录，在首选项里面可以看到，然后包就会放在那个目录的libraries下
    
  
  
• 修改PubSubClient的头文件
  
  
  
  • 路径PubSubClient->src
    
    
    
    • 
      
    
    
  •  打开并修改如下
    
    
    
    • 
      
    • 包大小可以尽可能大一点，阿里云官方给的mqtt消息长度小于256k即可
      
      
      
      • 
        
      
      
    
    
  
  

---

连接测试

• 测试代码
  
  
  
  • 1. #include <ESP8266WiFi.h>
    2. /* 依赖 PubSubClient 2.4.0 */
    3. #include <PubSubClient.h>
    5. /* 连接您的WIFI SSID和密码 */
    6. #define WIFI_SSID         "WIFI名称"
    7. #define WIFI_PASSWD       "WIFI密码"
    9. /* 线上环境域名和端口号 */
    10. #define MQTT_SERVER       "你的域名"
    11. #define MQTT_PORT         1883//端口号
    12. #define MQTT_USRNAME      "你的username"
    13. #define CLIENT_ID         "你的clientId"
    14. #define MQTT_PASSWD       "你的password"
    16. //发布消息用的topic
    17. #define PubTopic "你的topic"
    19. unsigned long lastMs = 0;
    20. WiFiClient espClient;
    21. PubSubClient  client(espClient);
    23. //收到消息后的回调函数
    24. void callback(char *topic, byte *payload, unsigned int length)
    25. {
    26.   Serial.print("Message arrived [");
    27.   Serial.print(topic);
    28.   Serial.print("] ");
    29.   payload[length] = '\0';
    30.   Serial.println((char *)payload);
    32. }
    34. //wifi初始化
    35. void wifiInit()
    36. {
    37.   WiFi.mode(WIFI_STA);
    38.   WiFi.begin(WIFI_SSID, WIFI_PASSWD);
    39.   while (WiFi.status() != WL_CONNECTED)
    40.   {
    41.     delay(1000);
    42.     Serial.println("WiFi not Connect");
    43.   }
    45.   Serial.println("Connected to AP");
    46.   Serial.println("IP address: ");
    47.   Serial.println(WiFi.localIP());
    49.   Serial.print("espClient [");
    51.   client.setServer(MQTT_SERVER, MQTT_PORT);   /* 连接WiFi之后，连接MQTT服务器 */
    52.   client.setCallback(callback);
    53. }
    55. //发布一个字符串的消息
    56. void pubMsg(char *msg)
    57. {
    58.     boolean d = client.publish(PubTopic, msg);
    59.     if(d){
    60.       Serial.println("publish success");
    61.     }else{
    62.       Serial.println("publish fail");
    63.     }
    64. }
    66. //发布指定长度的字符消息
    67. void pubMsgLen(uint8_t *msg,int len)
    68. {
    69.     boolean d = client.publish(PubTopic,msg,len);
    70.     if(d){
    71.       Serial.println("publish success");
    72.     }else{
    73.       Serial.println("publish fail");
    74.     }
    75. }
    77. //连接到服务器
    78. void mqttCheckConnect()
    79. {
    80.   while (!client.connected())
    81.   {
    82.     Serial.println("Connecting to MQTT Server ...");
    83.     if (client.connect(CLIENT_ID, MQTT_USRNAME, MQTT_PASSWD))
    85.     {
    87.       Serial.println("MQTT Connected!");
    89.     }
    90.     else
    91.     {
    92.       Serial.print("MQTT Connect err:");
    93.       Serial.println(client.state());
    94.       delay(5000);
    95.     }
    96.   }
    97. }
    99. void setup()
    100. {
    101. /* initialize serial for debugging */
    102.     Serial.begin(115200); //开启串口
    103.     Serial.println("Demo Start");
    104.     wifiInit();//连接wifi
    105.     unsigned char i=0;
    106.     mqttCheckConnect();//连接阿里云
    107.     pubMsg("hello aliyun!");
    108. }
    110. // the loop function runs over and over again forever
    111. void loop()
    112. {
    113.   client.loop();//保持客户端的连接
    114. }

    复制代码
  
  
• 代码烧录好之后，在云平台就可以查看发送来的消息
  
  
  
  • 
    
  
  
• 我们再从云平台发送一条消息过去测试
  
  
  
  • 
    
  • 在串口调试界面可以看到
    
  • 
    
  
  

---

注意

   收到消息的速度与
   client.loop();//保持客户端的连接
  这句有很大关系  放入延时中可能会让接收消息也延迟
          

来源：https://blog.csdn.net/xyx0610/article/details/123934145
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！