设为首页收藏本站
开启辅助访问 切换到宽版

 找回密码
 立即注册

QQ登录

只需一步，快速开始

热门： 51单片机 | 24小时必答区 | 单片机教程 | 单片机DIY制作 | STM32 | Cortex M3 | 模数电子 | 电子DIY制作 | 音响/功放 | 拆机乐园 | Arduino | 嵌入式OS | 程序设计

搜索
»论坛 › 嵌入式/单片机论坛 › Arduino › arduino IDE开发ESP8266 MQTT代码
返回列表 发新帖
查看: 2744|回复: 5
收起左侧

arduino IDE开发ESP8266 MQTT代码

  [复制链接]
ID:706228 发表于 2021-11-9 16:52 | 显示全部楼层 |阅读模式
arduino IDE开发ESP8266开发版终于可以手机远程控制LED点亮了
  1. #include <ESP8266WiFi.h>
  2. #include <PubSubClient.h>

  4. // 设置wifi接入信息(请根据您的WiFi信息进行修改)
  5. const char* ssid = "可用WiFi";
  6. const char* password = "密码";
  7. const char* mqttServer = "";
  8. // 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案
  9. WiFiClient wifiClient;
  10. PubSubClient mqttClient(wifiClient);

  12. // ****************************************************
  13. // 注意！以下需要用户根据然也物联平台信息进行修改！否则无法工作!
  14. // ****************************************************
  15. const char* mqttUserName = "自己的";         // 服务端连接用户名(需要修改)
  16. const char* mqttPassword = "自己的";          // 服务端连接密码(需要修改)
  17. const char* clientId = "自己的";          // 客户端id (需要修改)
  18. const char* subTopic = "自己/led_kz";        // 订阅主题(需要修改)
  19. const char* pubTopic = "自己/led_zt";        // 订阅主题(需要修改)
  20. const char* willTopic = "自己/led_yz";       // 遗嘱主题名称(需要修改)
  21. // ****************************************************

  23. //遗嘱相关信息
  24. const char* willMsg = "esp8266 offline";        // 遗嘱主题信息
  25. const int willQos = 0;                          // 遗嘱QoS
  26. const int willRetain = false;                   // 遗嘱保留

  28. const int subQoS = 1;            // 客户端订阅主题时使用的QoS级别（截止2020-10-07，仅支持QoS = 1，不支持QoS = 2）
  29. const bool cleanSession = false; // 清除会话（如QoS>0必须要设为false）

  31. bool ledStatus = HIGH;
  32. //int pushButton =D3;
  33. void setup() {
  34.   pinMode(LED_BUILTIN, OUTPUT);  // 设置板上LED引脚为输出模式
  35.   //pinMode(pushButton, INPUT);
  36.   digitalWrite(LED_BUILTIN, ledStatus);  // 启动后关闭板上LED
  37.   Serial.begin(9600);                    // 启动串口通讯
  38.   
  39.   //设置ESP8266工作模式为无线终端模式
  40.   WiFi.mode(WIFI_STA);
  41.   
  42.   // 连接WiFi
  43.   connectWifi();
  44.   
  45.   // 设置MQTT服务器和端口号
  46.   mqttClient.setServer(mqttServer, 1883);
  47.   mqttClient.setCallback(receiveCallback);

  49.   // 连接MQTT服务器
  50.   connectMQTTserver();
  51. }

  53. void loop() {
  54.   // 如果开发板未能成功连接服务器，则尝试连接服务器
  55.   if (!mqttClient.connected()) {
  56.     connectMQTTserver();
  57.   }

  59.    // 处理信息以及心跳
  60.    mqttClient.loop();
  61.   /* pushButton = digitalRead(LED_BUILTIN); //读取引脚2电平状态并将其赋值给布尔变量
  62.   
  63.   if (!pushButton){          //对布尔变量进行逻辑非运算，并根据运算结构点亮或者熄灭LED
  64.     digitalWrite(LED_BUILTIN, HIGH); //布尔变量数值为假（false）时点亮LED
  65.   } else {
  66.     digitalWrite(LED_BUILTIN, LOW);  //布尔变量数值为真（true）时熄灭LED
  67.   }*/
  68.    
  69. }

  71. // 连接MQTT服务器并订阅信息
  72. void connectMQTTserver(){
  73.   // 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）
  74.   

  76.   /* 连接MQTT服务器
  77.   boolean connect(const char* id, const char* user,
  78.                   const char* pass, const char* willTopic,
  79.                   uint8_t willQos, boolean willRetain,
  80.                   const char* willMessage, boolean cleanSession);
  81.   若让设备在离线时仍然能够让qos1工作，则connect时的cleanSession需要设置为false               
  82.                   */
  83.   if (mqttClient.connect(clientId, mqttUserName,
  84.                          mqttPassword, willTopic,
  85.                          willQos, willRetain, willMsg, cleanSession)) {
  86.     Serial.print("MQTT Server Connected. ClientId: ");
  87.     Serial.println(clientId);
  88.     Serial.print("MQTT Server: ");
  89.     Serial.println(mqttServer);   
  90.    
  91.     subscribeTopic(); // 订阅指定主题
  92.   } else {
  93.     Serial.print("MQTT Server Connect Failed. Client State:");
  94.     Serial.println(mqttClient.state());
  95.     delay(5000);
  96.   }   
  97. }

  99. // 收到信息后的回调函数
  100. void receiveCallback(char* topic, byte* payload, unsigned int length) {
  101.   Serial.print("Message Received [");
  102.   Serial.print(topic);
  103.   Serial.print("] ");
  104.   for (int i = 0; i < length; i++) {
  105.     Serial.print((char)payload[i]);
  106.   }
  107.   Serial.println("");
  108.   Serial.print("Message Length(Bytes) ");
  109.   Serial.println(length);

  111.   if ((char)payload[0] == '1') {     // 如果收到的信息以“1”为开始
  112.     ledStatus = LOW;
  113.     digitalWrite(BUILTIN_LED, ledStatus);  // 则点亮LED。
  114.   } else {
  115.     ledStatus = HIGH;                           
  116.     digitalWrite(BUILTIN_LED, ledStatus); // 否则熄灭LED。
  117.   }

  119.   pubMQTTmsg();
  120. }

  122. // 订阅指定主题
  123. void subscribeTopic(){

  125.   
  126.   // 通过串口监视器输出是否成功订阅主题以及订阅的主题名称
  127.   // 请注意subscribe函数第二个参数数字为QoS级别。这里为QoS = 1
  128.   if(mqttClient.subscribe(subTopic, subQoS)){
  129.     Serial.print("Subscribed Topic: ");
  130.     Serial.println(subTopic);
  131.   } else {
  132.     Serial.print("Subscribe Fail...");
  133.   }  
  134. }

  136. // 发布信息
  137. void pubMQTTmsg(){
  138.   char* pubMessage;
  139.   
  140.   if (ledStatus == LOW){
  141.     pubMessage = "LED ON";
  142.   } else {
  143.     pubMessage = "LED OFF";
  144.   }

  146.   // 实现ESP8266向主题发布信息
  147.   if(mqttClient.publish(pubTopic, pubMessage)){
  148.     Serial.println("Publish Topic:");Serial.println(pubTopic);
  149.     Serial.println("Publish message:");Serial.println(pubMessage);   
  150.   } else {
  151.     Serial.println("Message Publish Failed.");
  152.   }
  153. }

  155. // ESP8266连接wifi
  156. void connectWifi(){

  158.   WiFi.begin(ssid, password);

  160.   //等待WiFi连接,成功连接后输出成功信息
  161.   while (WiFi.status() != WL_CONNECTED) {
  162.     delay(1000);
  163.     Serial.print(".");
  164.   }
  165.   Serial.println("");
  166.   Serial.println("WiFi Connected!");  
  167.   Serial.println("");
  168. }
复制代码

评分

参与人数 1黑币 +40 收起 理由
admin + 40 共享资料的黑币奖励！

查看全部评分

回复

使用道具 举报

ID:752974 发表于 2021-12-16 17:30 | 显示全部楼层
手机APP如何实现？
回复

使用道具 举报

ID:752974 发表于 2021-12-31 15:39 | 显示全部楼层
问题解决了，谢谢楼主分享的代码。
回复

使用道具 举报

ID:272158 发表于 2022-2-15 14:26 | 显示全部楼层
那个版本的arduino IDE好用些？？？？？
回复

使用道具 举报

ID:95059 发表于 2022-5-10 17:42 | 显示全部楼层
小兄弟谈谈你的感想！
回复

使用道具 举报

ID:858009 发表于 2022-8-3 16:13 | 显示全部楼层
想问一下怎么获取json长数据？，你这个如果获取1000字节的JSON数据是否也可以？
回复

使用道具 举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|小黑屋|51黑电子论坛 |51黑电子论坛6群 QQ 管理员QQ:125739409;技术交流QQ群281945664

Powered by 单片机教程网

快速回复 返回顶部 返回列表