当前位置:   article > 正文

STM32F103C8T6+ESP8266+MQTT使用最新版的oneNet可视化View实现远程控制(详细)_stm32控制esp8266联网的步骤 使用新版onenet

stm32控制esp8266联网的步骤 使用新版onenet

本篇所实现的功能是我毕业设计的一部分,用于记录我的学习过程,以免忘记操作过程!

所使用的相关硬件正点原子的esp8266模块、c8t6开发板一块、STLink v2、DHT11温湿度传感器一块、发光二级管一个、继电器两个

附上我的完整工程代码:代码

感谢博主:永栀哇

相关文章:1-ESP8266-AT指令初试化及部分基础知识2-STM32+ESP8266连接onenet并上传数据(HTTP)3-STM32+ESP8266连接onenet上传数据+远程控制(MQTT)

硬件接线:

 

最终呈现软硬件:

 

一、代码方面:(主要说明onenet.c和esp8266.c)

onenet.c中:

第一步要修改处

那么具体的三个参数在哪里找到捏?如下图,具体如何打开,在下文有表述:


第二步用于与oneNET端创建连接,此处无需修改

  1. //==========================================================
  2. // 函数名称: OneNet_DevLink
  3. //
  4. // 函数功能: 与onenet创建连接
  5. //
  6. // 入口参数: 无
  7. //
  8. // 返回参数: 1-成功 0-失败
  9. //
  10. // 说明: 与onenet平台建立连接
  11. //==========================================================
  12. _Bool OneNet_DevLink(void)
  13. {
  14. MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包
  15. unsigned char *dataPtr;
  16. _Bool status = 1;
  17. printf("OneNet_DevLink\r\nPROID: %s, AUIF: %s, DEVID:%s\r\n", PROID, AUTH_INFO, DEVID);
  18. if(MQTT_PacketConnect(PROID, AUTH_INFO, DEVID, 256, 0, MQTT_QOS_LEVEL0, NULL, NULL, 0, &mqttPacket) == 0)
  19. {
  20. ESP8266_SendData(mqttPacket._data, mqttPacket._len); //上传平台
  21. dataPtr = ESP8266_GetIPD(250); //等待平台响应
  22. if(dataPtr != NULL)
  23. {
  24. if(MQTT_UnPacketRecv(dataPtr) == MQTT_PKT_CONNACK)
  25. {
  26. switch(MQTT_UnPacketConnectAck(dataPtr))
  27. {
  28. case 0:printf("Tips: 连接成功\r\n");status = 0;break;
  29. case 1:printf("WARN: 连接失败:协议错误\r\n");break;
  30. case 2:printf("WARN: 连接失败:非法的clientid\r\n");break;
  31. case 3:printf("WARN: 连接失败:服务器失败\r\n");break;
  32. case 4:printf("WARN: 连接失败:用户名或密码错误\r\n");break;
  33. case 5:printf("WARN: 连接失败:非法链接(比如token非法)\r\n");break;
  34. default:printf("ERR: 连接失败:未知错误\r\n");break;
  35. }
  36. }
  37. }
  38. MQTT_DeleteBuffer(&mqttPacket); //删包
  39. }
  40. else
  41. printf("WARN: MQTT_PacketConnect Failed\r\n");
  42. return status;
  43. }

第三步用于将收集的温湿度数据,初始按钮命令等打包存于数组text[32]中,此处需要修改

  1. u8 key_LD = 0; //开关路灯
  2. u8 key_FS = 0; //开关空调
  3. u8 key_XYJ = 0; //远程开关洗衣机
  4. extern u8 humidityH; //湿度整数部分
  5. extern u8 humidityL; //湿度小数部分
  6. extern u8 temperatureH; //温度整数部分
  7. extern u8 temperatureL; //温度小数部分
  8. unsigned char OneNet_FillBuf(char *buf)
  9. {
  10. char text[32];
  11. memset(text, 0, sizeof(text));
  12. strcpy(buf, ",;");
  13. memset(text, 0, sizeof(text));
  14. sprintf(text, "key_LD,%d;", key_LD);
  15. strcat(buf, text);
  16. memset(text, 0, sizeof(text));
  17. sprintf(text, "key_FS,%d;", key_FS);
  18. strcat(buf, text);
  19. memset(text, 0, sizeof(text));
  20. sprintf(text, "key_XYJ,%d;", key_XYJ);
  21. strcat(buf, text);
  22. memset(text, 0, sizeof(text));
  23. sprintf(text, "Tempreture,%d.%d;",temperatureH,temperatureL);
  24. strcat(buf, text);
  25. memset(text, 0, sizeof(text));
  26. sprintf(text, "Humidity,%d.%d;",humidityH,humidityL);
  27. strcat(buf, text);
  28. return strlen(buf);
  29. }

第四步 用于上传数据到平台,此处无需修改

  1. //==========================================================
  2. // 函数名称: OneNet_SendData
  3. //
  4. // 函数功能: 上传数据到平台
  5. //
  6. // 入口参数: type:发送数据的格式
  7. //
  8. // 返回参数: 无
  9. //
  10. // 说明:
  11. //==========================================================
  12. void OneNet_SendData(void)
  13. {
  14. MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包
  15. char buf[128];
  16. short body_len = 0, i = 0;
  17. // printf("Tips: OneNet_SendData-MQTT\r\n");
  18. memset(buf, 0, sizeof(buf));
  19. body_len = OneNet_FillBuf(buf); //获取当前需要发送的数据流的总长度
  20. if(body_len)
  21. {
  22. if(MQTT_PacketSaveData(DEVID, body_len, NULL, 5, &mqttPacket) == 0) //封包
  23. {
  24. for(; i < body_len; i++)
  25. mqttPacket._data[mqttPacket._len++] = buf[i];
  26. ESP8266_SendData(mqttPacket._data, mqttPacket._len); //上传数据到平台
  27. // printf("Send %d Bytes\r\n", mqttPacket._len);
  28. MQTT_DeleteBuffer(&mqttPacket); //删包
  29. }
  30. else
  31. printf("WARN: EDP_NewBuffer Failed\r\n");
  32. }
  33. }

 第五步 用于平台返回数据检测,此处需要修改,具体修改处已标记

  1. //==========================================================
  2. // 函数名称: OneNet_RevPro
  3. //
  4. // 函数功能: 平台返回数据检测
  5. //
  6. // 入口参数: dataPtr:平台返回的数据
  7. //
  8. // 返回参数: 无
  9. //
  10. // 说明:
  11. //==========================================================
  12. void OneNet_RevPro(unsigned char *cmd)
  13. {
  14. MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; //协议包
  15. char *req_payload = NULL;
  16. char *cmdid_topic = NULL;
  17. unsigned short req_len = 0;
  18. unsigned char type = 0;
  19. short result = 0;
  20. char *dataPtr = NULL;
  21. char numBuf[10];
  22. int num = 0;
  23. type = MQTT_UnPacketRecv(cmd);//MQTT数据接收类型判断
  24. switch(type)
  25. {
  26. case MQTT_PKT_CMD: //命令下发
  27. //参数1收到的
  28. result = MQTT_UnPacketCmd(cmd, &cmdid_topic, &req_payload, &req_len); //解出topic和消息体
  29. if(result == 0)
  30. {
  31. //打印收到的信息,参数2数据,参数3数据长度
  32. printf( "cmdid: %s, req: %s, req_len: %d\r\n", cmdid_topic, req_payload, req_len);
  33. if(MQTT_PacketCmdResp(cmdid_topic, req_payload, &mqttPacket) == 0) //命令回复组包
  34. {
  35. printf( "Tips: Send CmdResp\r\n");
  36. ESP8266_SendData(mqttPacket._data, mqttPacket._len); //回复命令
  37. MQTT_DeleteBuffer(&mqttPacket); //删包
  38. }
  39. }
  40. break;
  41. case MQTT_PKT_PUBACK: //发送Publish消息,平台回复的Ack
  42. if(MQTT_UnPacketPublishAck(cmd) == 0)
  43. printf( "Tips: MQTT Publish Send OK\r\n");
  44. break;
  45. default:
  46. result = -1;
  47. break;
  48. }
  49. ESP8266_Clear(); //清空缓存
  50. if(result == -1)
  51. return;
  52. dataPtr = strchr(req_payload, ':'); //搜索':'
  53. if(dataPtr != NULL && result != -1) //如果找到了
  54. {
  55. dataPtr++;
  56. while(*dataPtr >= '0' && *dataPtr <= '9') //判断是否是下发的命令控制数据
  57. {
  58. numBuf[num++] = *dataPtr++;
  59. }
  60. numBuf[num] = 0;
  61. num = atoi((const char *)numBuf); //转为数值形式
  62. // /*************************主要修改此处***************************/
  63. if(strstr((char *)req_payload, "key_LD")) //搜索"key_LD"
  64. {
  65. if(num == 1) //控制数据如果为1,代表开
  66. {
  67. LED=1;
  68. }
  69. else if(num == 0) //控制数据如果为0,代表关
  70. {
  71. LED=0;
  72. }
  73. key_LD = num; //更新数据到云平台
  74. }
  75. if(strstr((char *)req_payload, "key_FS")) //搜索"key_FS"
  76. {
  77. if(num == 1) //控制数据如果为0,代表开
  78. {
  79. JDQ_FS = 0;
  80. }
  81. else if(num == 0) //控制数据如果为1,代表关
  82. {
  83. JDQ_FS = 1;
  84. }
  85. key_FS = num; //更新数据到云平台
  86. }
  87. if(strstr((char *)req_payload, "key_XYJ")) //搜索"key_FS"
  88. {
  89. if(num == 1) //控制数据如果为0,代表开
  90. {
  91. JDQ_XYJ = 0;
  92. }
  93. else if(num == 0) //控制数据如果为1,代表关
  94. {
  95. JDQ_XYJ = 1;
  96. }
  97. key_XYJ = num; //更新数据到云平台
  98. }
  99. }
  100. if(type == MQTT_PKT_CMD || type == MQTT_PKT_PUBLISH)
  101. {
  102. MQTT_FreeBuffer(cmdid_topic);
  103. MQTT_FreeBuffer(req_payload);
  104. }
  105. }

ESP8266.c

第一步需要修改的:连接自己家的WI-FI

第二步初始化 ESP8266

  1. //==========================================================
  2. // 函数名称: ESP8266_Init
  3. //
  4. // 函数功能: 初始化ESP8266
  5. //
  6. // 入口参数: 无
  7. //
  8. // 返回参数: 无
  9. //
  10. // 说明:
  11. //==========================================================
  12. void ESP8266_Init(void)
  13. {
  14. GPIO_InitTypeDef GPIO_Initure;
  15. RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOB, ENABLE);
  16. //ESP8266复位引脚
  17. GPIO_Initure.GPIO_Mode = GPIO_Mode_Out_PP;
  18. GPIO_Initure.GPIO_Pin = GPIO_Pin_1; //GPIOB1-复位
  19. GPIO_Initure.GPIO_Speed = GPIO_Speed_50MHz;
  20. GPIO_Init(GPIOB, &GPIO_Initure);
  21. GPIO_WriteBit(GPIOB, GPIO_Pin_1, Bit_RESET);
  22. delay_ms(250);
  23. GPIO_WriteBit(GPIOB, GPIO_Pin_1, Bit_SET);
  24. delay_ms(500);
  25. ESP8266_Clear();
  26. printf("AT\r\n");
  27. while(ESP8266_SendCmd("AT\r\n\r", "OK", 200))
  28. delay_ms(500);
  29. printf("CWMODE\r\n");
  30. while(ESP8266_SendCmd("AT+CWMODE=1\r\n", "OK", 200))
  31. delay_ms(500);
  32. printf("AT+CWDHCP\r\n");
  33. while(ESP8266_SendCmd("AT+CWDHCP=1,1\r\n", "OK", 200))
  34. delay_ms(500);
  35. printf("CWJAP\r\n");
  36. while(ESP8266_SendCmd(ESP8266_WIFI_INFO, "GOT IP", 200))
  37. delay_ms(500);
  38. printf("CIPSTART\r\n");
  39. while(ESP8266_SendCmd(ESP8266_ONENET_INFO, "CONNECT", 200))
  40. delay_ms(500);
  41. printf("ESP8266 Init OK\r\n");
  42. }

 第三步初始化c8t6串口二用于启动esp8266(A2、A3)

  1. /*
  2. ************************************************************
  3. * 函数名称: Usart2_Init
  4. *
  5. * 函数功能: 串口2初始化
  6. *
  7. * 入口参数: baud:设定的波特率
  8. *
  9. * 返回参数: 无
  10. *
  11. * 说明: TX-PA2 RX-PA3
  12. ************************************************************
  13. */
  14. void Usart2_Init(unsigned int baud)
  15. {
  16. GPIO_InitTypeDef gpio_initstruct;
  17. USART_InitTypeDef usart_initstruct;
  18. NVIC_InitTypeDef nvic_initstruct;
  19. RCC_APB2PeriphClockCmd(RCC_APB2Periph_GPIOA, ENABLE);
  20. RCC_APB1PeriphClockCmd(RCC_APB1Periph_USART2, ENABLE);
  21. //PA2 TXD
  22. gpio_initstruct.GPIO_Mode = GPIO_Mode_AF_PP;
  23. gpio_initstruct.GPIO_Pin = GPIO_Pin_2;
  24. gpio_initstruct.GPIO_Speed = GPIO_Speed_50MHz;
  25. GPIO_Init(GPIOA, &gpio_initstruct);
  26. //PA3 RXD
  27. gpio_initstruct.GPIO_Mode = GPIO_Mode_IN_FLOATING;
  28. gpio_initstruct.GPIO_Pin = GPIO_Pin_3;
  29. gpio_initstruct.GPIO_Speed = GPIO_Speed_50MHz;
  30. GPIO_Init(GPIOA, &gpio_initstruct);
  31. usart_initstruct.USART_BaudRate = baud;
  32. usart_initstruct.USART_HardwareFlowControl = USART_HardwareFlowControl_None; //无硬件流控
  33. usart_initstruct.USART_Mode = USART_Mode_Rx | USART_Mode_Tx; //接收和发送
  34. usart_initstruct.USART_Parity = USART_Parity_No; //无校验
  35. usart_initstruct.USART_StopBits = USART_StopBits_1; //1位停止位
  36. usart_initstruct.USART_WordLength = USART_WordLength_8b; //8位数据位
  37. USART_Init(USART2, &usart_initstruct);
  38. USART_Cmd(USART2, ENABLE); //使能串口
  39. USART_ITConfig(USART2, USART_IT_RXNE, ENABLE); //使能接收中断
  40. nvic_initstruct.NVIC_IRQChannel = USART2_IRQn;
  41. nvic_initstruct.NVIC_IRQChannelCmd = ENABLE;
  42. nvic_initstruct.NVIC_IRQChannelPreemptionPriority = 0;
  43. nvic_initstruct.NVIC_IRQChannelSubPriority = 0;
  44. NVIC_Init(&nvic_initstruct);
  45. }
  46. //==========================================================
  47. // 函数名称: USART2_IRQHandler
  48. //
  49. // 函数功能: 串口2收发中断
  50. //
  51. // 入口参数: 无
  52. //
  53. // 返回参数: 无
  54. //
  55. // 说明:
  56. //==========================================================
  57. void USART2_IRQHandler(void)
  58. {
  59. if(USART_GetITStatus(USART2, USART_IT_RXNE) != RESET) //接收中断
  60. {
  61. if(esp8266_cnt >= sizeof(esp8266_buf)) esp8266_cnt = 0; //防止串口被刷爆
  62. esp8266_buf[esp8266_cnt++] = USART2->DR;
  63. USART_ClearFlag(USART2, USART_FLAG_RXNE);
  64. }
  65. }
  66. /*
  67. ************************************************************
  68. * 函数名称: Usart_SendString
  69. *
  70. * 函数功能: 串口数据发送
  71. *
  72. * 入口参数: USARTx:串口组
  73. * str:要发送的数据
  74. * len:数据长度
  75. *
  76. * 返回参数: 无
  77. *
  78. * 说明:
  79. ************************************************************
  80. */
  81. void Usart2_SendString(unsigned char *str, unsigned short len)
  82. {
  83. unsigned short count = 0;
  84. for(; count < len; count++)
  85. {
  86. USART_SendData(USART2, *str++); //发送数据
  87. while(USART_GetFlagStatus(USART2, USART_FLAG_TC) == RESET); //等待发送完成
  88. }
  89. }

第四步ESP8266相关函数,无需修改

  1. //==========================================================
  2. // 函数名称: ESP8266_Clear
  3. //
  4. // 函数功能: 清空缓存
  5. //
  6. // 入口参数: 无
  7. //
  8. // 返回参数: 无
  9. //
  10. // 说明:
  11. //==========================================================
  12. void ESP8266_Clear(void)
  13. {
  14. memset(esp8266_buf, 0, sizeof(esp8266_buf));
  15. esp8266_cnt = 0;
  16. }
  17. //==========================================================
  18. // 函数名称: ESP8266_WaitRecive
  19. //
  20. // 函数功能: 等待接收完成
  21. //
  22. // 入口参数: 无
  23. //
  24. // 返回参数: REV_OK-接收完成 REV_WAIT-接收超时未完成
  25. //
  26. // 说明: 循环调用检测是否接收完成
  27. //==========================================================
  28. _Bool ESP8266_WaitRecive(void)
  29. {
  30. if(esp8266_cnt == 0) //如果接收计数为0 则说明没有处于接收数据中,所以直接跳出,结束函数
  31. return REV_WAIT;
  32. if(esp8266_cnt == esp8266_cntPre) //如果上一次的值和这次相同,则说明接收完毕
  33. {
  34. esp8266_cnt = 0; //清0接收计数
  35. return REV_OK; //返回接收完成标志
  36. }
  37. esp8266_cntPre = esp8266_cnt; //置为相同
  38. return REV_WAIT; //返回接收未完成标志
  39. }
  40. //==========================================================
  41. // 函数名称: ESP8266_SendCmd
  42. //
  43. // 函数功能: 发送命令
  44. //
  45. // 入口参数: cmd:命令
  46. // res:需要检查的返回指令
  47. //
  48. // 返回参数: 0-成功 1-失败
  49. //
  50. // 说明:
  51. //==========================================================
  52. _Bool ESP8266_SendCmd(char *cmd, char *res, u16 time)
  53. {
  54. Usart2_SendString((unsigned char *)cmd, strlen((const char *)cmd));
  55. while(time--)
  56. {
  57. if(ESP8266_WaitRecive() == REV_OK) //如果收到数据
  58. {
  59. if(strstr((const char *)esp8266_buf, res) != NULL) //如果检索到关键词
  60. {
  61. ESP8266_Clear(); //清空缓存
  62. return 0;
  63. }
  64. }
  65. delay_ms(10);
  66. }
  67. return 1;
  68. }
  69. //==========================================================
  70. // 函数名称: ESP8266_SendData
  71. //
  72. // 函数功能: 发送数据
  73. //
  74. // 入口参数: data:数据
  75. // len:长度
  76. //
  77. // 返回参数: 无
  78. //
  79. // 说明:
  80. //==========================================================
  81. void ESP8266_SendData(unsigned char *data, unsigned short len)
  82. {
  83. char cmdBuf[32];
  84. ESP8266_Clear(); //清空接收缓存
  85. sprintf(cmdBuf, "AT+CIPSEND=%d\r\n", len); //发送命令
  86. if(!ESP8266_SendCmd(cmdBuf, ">", 200)) //收到‘>’时可以发送数据
  87. {
  88. Usart2_SendString(data, len); //发送设备连接请求数据
  89. }
  90. }
  91. //==========================================================
  92. // 函数名称: ESP8266_GetIPD
  93. //
  94. // 函数功能: 获取平台返回的数据
  95. //
  96. // 入口参数: 等待的时间(乘以10ms)
  97. //
  98. // 返回参数: 平台返回的原始数据
  99. //
  100. // 说明: 不同网络设备返回的格式不同,需要去调试
  101. // 如ESP8266的返回格式为 "+IPD,x:yyy" x代表数据长度,yyy是数据内容
  102. //==========================================================
  103. unsigned char *ESP8266_GetIPD(unsigned short timeOut)
  104. {
  105. char *ptrIPD = NULL;
  106. do
  107. {
  108. if(ESP8266_WaitRecive() == REV_OK) //如果接收完成
  109. {
  110. ptrIPD = strstr((char *)esp8266_buf, "IPD,"); //搜索“IPD”头
  111. if(ptrIPD == NULL) //如果没找到,可能是IPD头的延迟,还是需要等待一会,但不会超过设定的时间
  112. {
  113. //printf("\"IPD\" not found\r\n");
  114. }
  115. else
  116. {
  117. ptrIPD = strchr(ptrIPD, ':'); //找到':'
  118. if(ptrIPD != NULL)
  119. {
  120. ptrIPD++;
  121. return (unsigned char *)(ptrIPD);
  122. }
  123. else
  124. return NULL;
  125. }
  126. }
  127. delay_ms(5); //延时等待
  128. } while(timeOut--);
  129. return NULL; //超时还未找到,返回空指针
  130. }

二、关于oneNET平台最新的可视化View的具体使用方法

1、创建oneNet账号,这个自己解决啦

点击链接控制台首页,进入后注册账号

2、在菜单找到如图按键,点击多协议接入

 

3、进入多协议接入后,初始界面应该是MQTT(旧版)【反正我的界面是这个】点击添加产品

 

蓝色框里自己填红色的可以按照我的来勾选主要还是看自己的需求

 

 4、点击你创建的设备

 5、进入后的界面,会出现下面的图,点击添加设备

此处的鉴权信息自己填一串就好,但是切记,我们在代码onenet.c需要修改的,不要忘记!!

 

  6、创建好设备后,出现如下界面,记住所框数据

7、点击设备列表,打开刚刚创建的设备,并进行配置,并通过MQTT协议下发命令,打开路灯

 

 

 注意发送格式!!!!!!!!!!为什么会出现这个格式呢?下文会有解释

 

 

 8、点开应用管理,CSDN论坛好多大佬都有写在应用管理处创建一个应用就可以,结果更新后,啥都没了,我咧个去,坑爹啊!!要用新版的可视化view,难顶,下面是操作过程:需要注意的是,想要实现按钮下发指令,需要专业版可视化,他有七天免费试用,期间建立的工程皆可保留,切记不要超过时间啦!

 

 

 9、具体控件所在位置说明

按钮(我的会员过期了,所以用不了)

仪表盘(免费)

 

文字:

 

10、数据流说明:(重点!!!!)

1、 数据流处理如下,点击一个仪表盘,完成所有的的配置,如下图所示,一共有五个数据:

 

蓝色的按照我的填就好,红色的是你的Master-APIkey具体位置如图:

 

 

 2、还有就是按钮的设置啦,需要注意的点如下图:(下面以路灯为例,其他的一致)

 

 3、最后说明一下:下发的命令格式(key_XX:{V})私有过滤器是个是个什么玩意!

 下发的命令格式,是因为我们在源码处给了一个奇葩造型(如下图),且需要先搜索是否有 ‘ :’故而需要加上冒号,而冒号后边的{V}则是我们所需数据,这个数据由按钮控制下发。

 找冒号:

 而私有过滤器(个人理解,要不官方感觉很抽象):就是保证页面初始化值,同时保证该按钮的传递值属于这个按钮的本身数据

以上,再次鸣谢永栀哇

本文内容由网友自发贡献,转载请注明出处:【wpsshop博客】
推荐阅读
相关标签
  

闽ICP备14008679号