21ic电子技术开发论坛 › 单片机与嵌入式系统 › GigaDevice GD32 MCU › GD32VW553-IoT V2 获取温湿度数据并 MQTT 上报 ...
返回列表 发新帖我要提问

GD32VW553-IoT V2 获取温湿度数据并 MQTT 上报

[复制链接]
224|0
iCEasy商城-小易 发表于 2025-11-3 14:51 | 显示全部楼层 |阅读模式
温湿度, GD32, IOT, QT, 获取, V2
本文转载自iCEasy商城口碑评测作者：Mr_Fang
欢迎大家戳链接GD32VW553-IoT V2 获取温湿度数据并 MQTT 上报_口碑测评-iCEasy商城，与原贴作者互动交流哦~

视频链接



https://www.bilibili.com/opus/1126807841456259072

概要



本项目将使用 DHT11 获取环境温湿度数据并显示在 OLED 屏幕上，连接 WIFI 后可使用 MQTT 上报数据
开源口碑分享内容



搭建 MQTT 服务器
此部分参考此文章：GD32VW55x MQTT 控制 GPIO 输出
OLED 驱动移植使用 DHT11 读取温湿度数据
DHT11 数字温湿度传感器是一款含有已校准数字信号输出的温湿度复合传感器，内部由一个 8 位单片机控制一个电阻式感湿元件和一个 NTC 测温元件。DHT11 虽然也是采用单总线协议，但是该协议与 DS18B20 的单总线协议稍微有些不同之处。相比于 DS18B20 只能测量温度，DHT11 既能检测温度又能检测湿度，不过 DHT11 的精度和测量范围都要低于 DS18B20，其温度测量范围为 090%RH，误差在±5%RH
dht11.c
复制
  1. #include "dht11.h"
    


  2. 

  3. // DHT11 IO
    

  4. #define GPIO_DATA GPIO_PIN_3
    


  5. 

  6. // 复位DHT11
    

  7. void DHT11_Rst(void)
    

  8. {
    

  9. DHT11_IO_OUT(); //SET OUTPUT
    

  10. gpio_bit_reset(GPIOA, GPIO_DATA); //拉低DQ
    

  11. sys_us_delay(20000); //拉低至少18ms
    

  12. gpio_bit_set(GPIOA, GPIO_DATA); //DQ=1
    

  13. sys_us_delay(30); //主机拉高20~40us
    

  14. }
    


  15. 

  16. // 等待DHT11的回应
    

  17. // 返回1: 未检测到DHT11的存在
    

  18. // 返回0: 存在
    

  19. uint8_t DHT11_Check(void)
    

  20. {
    

  21. uint8_t retry=0;
    

  22. DHT11_IO_IN();//SET INPUT
    

  23. while (gpio_input_bit_get(GPIOA, GPIO_DATA)&&retry<100)//DHT11会拉低40~80us
    

  24. {
    

  25. retry++;
    

  26. sys_us_delay(1);
    

  27. };
    

  28. if(retry>=100)return 1;
    

  29. else retry=0;
    

  30. while (!gpio_input_bit_get(GPIOA, GPIO_DATA)&&retry<100)//DHT11拉低后会再次拉高40~80us
    

  31. {
    

  32. retry++;
    

  33. sys_us_delay(1);
    

  34. };
    

  35. if(retry>=100)return 1;
    

  36. return 0;
    

  37. }
    


  38. 

  39. // 从DHT11读取一个位
    

  40. uint8_t DHT11_Read_Bit(void)
    

  41. {
    

  42. uint8_t retry=0;
    

  43. while(gpio_input_bit_get(GPIOA, GPIO_DATA)&&retry<100)//等待变为低电平
    

  44. {
    

  45. retry++;
    

  46. sys_us_delay(1);
    

  47. }
    

  48. retry=0;
    

  49. while(!gpio_input_bit_get(GPIOA, GPIO_DATA)&&retry<100)//等待变高电平
    

  50. {
    

  51. retry++;
    

  52. sys_us_delay(1);
    

  53. }
    

  54. sys_us_delay(40);//等待40us
    

  55. if(gpio_input_bit_get(GPIOA, GPIO_DATA))return 1;
    

  56. else return 0;
    

  57. }
    


  58. 

  59. // 从DHT11读取一个字节
    

  60. uint8_t DHT11_Read_Byte(void)
    

  61. {
    

  62. uint8_t i,dat;
    

  63. dat=0;
    

  64. for (i=0;i<8;i++)
    

  65. {
    

  66. dat<<=1;
    

  67. dat|=DHT11_Read_Bit();
    

  68. }
    

  69. return dat;
    

  70. }
    


  71. 

  72. // 从DHT11读取一次数据
    

  73. // temp: 温度值(范围:0~50°)
    

  74. // humi: 湿度值(范围:20%~90%)
    

  75. // 返回: 0, 正常; 1, 读取失败
    

  76. uint8_t DHT11_Read_Data(uint8_t *temp,uint8_t *humi)
    

  77. {
    

  78. uint8_t buf[5];
    

  79. uint8_t i;
    

  80. DHT11_Rst();
    

  81. if(DHT11_Check()==0)
    

  82. {
    

  83. for(i=0;i<5;i++)//读取40位数据
    

  84. {
    

  85. buf[i]=DHT11_Read_Byte();
    

  86. }
    

  87. if((buf[0]+buf[1]+buf[2]+buf[3])==buf[4])
    

  88. {
    

  89. *humi=buf[0];
    

  90. *temp=buf[2];
    

  91. }
    

  92. }
    

  93. else return 1;
    

  94. return 0;
    

  95. }
    


  96. 

  97. // 初始化DHT11, 同时检测DHT11的存在
    

  98. // 返回1: 不存在
    

  99. // 返回0: 存在
    

  100. uint8_t DHT11_Init(void)
    

  101. {
    

  102. rcu_periph_clock_enable(RCU_GPIOA);
    

  103. gpio_mode_set(GPIOA, GPIO_MODE_OUTPUT, GPIO_PUPD_NONE, GPIO_PIN_3);
    


  104. 

  105. DHT11_Rst(); //复位DHT11
    

  106. return DHT11_Check();//等待DHT11的回应
    

  107. }
dht11.h
复制
  1. #ifndef DHT11_H
    

  2. #define DHT11_H
    


  3. 

  4. #include "gd32vw55x.h"
    

  5. #include "sys.h"
    


  6. 

  7. // DHT11 IO
    

  8. #define GPIO_DATA GPIO_PIN_3
    


  9. 

  10. #define DHT11_IO_IN() {gpio_mode_set(GPIOA, GPIO_MODE_INPUT, GPIO_PUPD_NONE, GPIO_DATA);}
    

  11. #define DHT11_IO_OUT() {gpio_mode_set(GPIOA, GPIO_MODE_OUTPUT, GPIO_PUPD_NONE, GPIO_DATA);}
    


  12. 

  13. uint8_t DHT11_Init(void);
    

  14. uint8_t DHT11_Read_Data(uint8_t *temp,uint8_t *humi);
    

  15. uint8_t DHT11_Read_Byte(void);
    

  16. uint8_t DHT11_Read_Bit(void);
    

  17. uint8_t DHT11_Check(void);
    

  18. void DHT11_Rst(void);
    


  19. 

  20. #endif
使用 MQTT 上报数据
打开 MDK MQTT Demo 的 /main/mqtt_client_main.c，可以直接在这里编写代码（可以直接删除内容）
引入头文件和定义常量、全局变量
复制
  1. #include <stdint.h>
    

  2. #include <stdio.h>
    

  3. #include "app_cfg.h"
    

  4. #include "gd32vw55x_platform.h"
    

  5. #include "wifi_management.h"
    

  6. #include "wifi_init.h"
    


  7. 

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

  9. #include "lwip/apps/mqtt5.h"
    

  10. #include "lwip/apps/mqtt_priv.h"
    


  11. 

  12. #include "mqtt5_client_config.c"
    


  13. 

  14. #include "oled.h"
    

  15. #include "dht11.h"
    


  16. 

  17. #define SSID "SSID"
    

  18. #define PASSWORD "PASSWORD"
    


  19. 

  20. #define SERVER_PORT 1883
    

  21. ip_addr_t sever_ip_addr = IPADDR4_INIT_BYTES(192,168,0,2);
    


  22. 

  23. static char client_id[] = {'G', 'i', 'g', 'a', 'D', 'e', 'v', 'i', 'c', 'e', 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0};
    

  24. struct mqtt_connect_client_info_t client_info = {
    

  25. .client_id = client_id,
    

  26. .client_user = NULL,
    

  27. .client_pass = NULL,
    

  28. .keep_alive = 120,
    

  29. .will_topic = NULL,
    

  30. .will_topic = NULL,
    

  31. .will_qos = 0,
    

  32. .will_retain = 0
    

  33. };
    


  34. 

  35. char* topic_pub = "dht11/topic";
    


  36. 

  37. static mqtt_client_t *mqtt_client = NULL;
    

  38. int16_t connect_fail_reason = -1;
    


  39. 

  40. uint8_t temp;
    

  41. uint8_t humi;
MQTT 任务相关函数
复制
  1. struct mqtt_connect_client_info_t* get_client_param_data_get(void)
    

  2. {
    

  3. return &client_info;
    

  4. }
    


  5. 

  6. // 断开并释放MQTT连接
    

  7. void mqtt_connect_free(void)
    

  8. {
    

  9. connect_fail_reason = -1;
    

  10. if (mqtt_client == NULL)
    

  11. return;
    


  12. 

  13. mqtt5_disconnect(mqtt_client);
    

  14. mqtt5_param_delete(mqtt_client);
    

  15. mqtt_client_free(mqtt_client);
    

  16. mqtt_client = NULL;
    

  17. }
    


  18. 

  19. // 断开连接或连接异常回调函数
    

  20. void mqtt_connect_callback(mqtt_client_t *client, void *arg, mqtt_connection_status_t status)
    

  21. {
    

  22. char *prefix = NULL;
    

  23. char *reason = NULL;
    


  24. 

  25. if ((status == MQTT_CONNECT_ACCEPTED) ||
    

  26. (status == MQTT_CONNECT_REFUSED_PROTOCOL_VERSION)) {
    

  27. return;;
    

  28. }
    


  29. 

  30. prefix = "MQTT: client will be closed, reason is ";
    

  31. switch (status) {
    

  32. case MQTT_CONNECT_DISCONNECTED:
    

  33. reason = "remote has closed connection";
    

  34. break;
    

  35. case MQTT_CONNECT_TIMEOUT:
    

  36. reason = "connect attempt to server timed out";
    

  37. break;
    

  38. default:
    

  39. reason = "others";
    

  40. break;
    

  41. }
    


  42. 

  43. printf("%s%s, id is %d.\r\n", prefix, reason, status);
    

  44. }
    


  45. 

  46. // 解析错误码
    

  47. void mqtt_fail_reason_display(mqtt_connect_return_res_t fail_reason)
    

  48. {
    

  49. char *prefix = "MQTT mqtt_client: connection refused reason is ";
    

  50. char *reason = NULL;
    


  51. 

  52. switch(fail_reason) {
    

  53. case MQTT_CONNECTION_REFUSE_PROTOCOL:
    

  54. reason = "Bad protocol";
    

  55. break;
    

  56. case MQTT_CONNECTION_REFUSE_ID_REJECTED:
    

  57. reason = "ID rejected";
    

  58. break;
    

  59. case MQTT_CONNECTION_REFUSE_SERVER_UNAVAILABLE:
    

  60. reason = "Server unavailable";
    

  61. break;
    

  62. case MQTT_CONNECTION_REFUSE_BAD_USERNAME:
    

  63. reason = "Bad username or password";
    

  64. break;
    

  65. case MQTT_CONNECTION_REFUSE_NOT_AUTHORIZED:
    

  66. reason = "Not authorized";
    

  67. break;
    


  68. 

  69. default:
    

  70. reason = "Unknown reason";
    

  71. break;
    

  72. }
    

  73. printf("%s%s, id is %d.\r\n", prefix, reason, fail_reason);
    


  74. 

  75. return;
    

  76. }
    


  77. 

  78. // 与服务器建立连接
    

  79. static int client_connect(void)
    

  80. {
    

  81. err_t ret = ERR_OK;
    

  82. uint32_t connect_time = 0;
    


  83. 

  84. mqtt_client = mqtt_client_new();
    


  85. 

  86. printf("MQTT: start link server...\r\n");
    


  87. 

  88. if (mqtt5_param_cfg(mqtt_client)) {
    

  89. printf("MQTT: Configuration MQTT parameters failed, stop connection.\r\n");
    

  90. return -2;
    

  91. }
    


  92. 

  93. connect_time = sys_current_time_get();
    

  94. ret = mqtt5_client_connect(mqtt_client, &sever_ip_addr, SERVER_PORT, mqtt_connect_callback, NULL, &client_info,
    

  95. &(mqtt_client->mqtt5_config->connect_property_info),
    

  96. &(mqtt_client->mqtt5_config->will_property_info));
    

  97. if (ret != ERR_OK) {
    

  98. printf("MQTT mqtt_client: connect to server failed.\r\n");
    

  99. return ret;
    

  100. }
    


  101. 

  102. // 等待连接成功
    

  103. while (mqtt_client_is_connected(mqtt_client) == false) {
    

  104. // 超时
    

  105. if ((sys_current_time_get() - connect_time) > 5000) {
    

  106. printf("MQTT mqtt_client: connect to server timeout.\r\n");
    

  107. return -3;
    

  108. }
    

  109. // 异常
    

  110. if (connect_fail_reason == MQTT_CONNECTION_REFUSE_PROTOCOL) {
    

  111. mqtt5_disconnect(mqtt_client);
    

  112. mqtt5_param_delete(mqtt_client);
    

  113. printf("MQTT: The server does not support version 5.0, now switch to version 3.1.1.\r\n");
    

  114. connect_fail_reason = -1;
    

  115. break;
    

  116. } else if (connect_fail_reason > 0) {
    

  117. mqtt5_fail_reason_display((mqtt5_connect_return_res_t)connect_fail_reason);
    

  118. return connect_fail_reason;
    

  119. }
    

  120. sys_yield();
    

  121. }
    


  122. 

  123. printf("MQTT: Successfully connected to server.\r\n");
    


  124. 

  125. return 0;
    

  126. }
    


  127. 

  128. // 发布回调函数
    

  129. void mqtt_pub_cb(void *arg, err_t status)
    

  130. {
    

  131. switch (status) {
    

  132. case ERR_OK:
    

  133. printf("topic publish success.\r\n");
    

  134. break;
    

  135. case ERR_TIMEOUT:
    

  136. printf("topic publish time out.\r\n");
    

  137. break;
    

  138. default:
    

  139. printf("topic publish failed.\r\n");
    

  140. break;
    

  141. }
    


  142. 

  143. return;
    

  144. }
    


  145. 

  146. // 发布
    

  147. static int client_publish(char *topic, char *context, uint16_t length)
    

  148. {
    

  149. err_t ret = ERR_OK;
    


  150. 

  151. ret = mqtt5_msg_publish(mqtt_client, topic, context, length, 1, 1, mqtt_pub_cb, NULL, mqtt_client->mqtt5_config->publish_property_info,
    

  152. mqtt_client->mqtt5_config->server_resp_property_info.response_info);
    

  153. return ret;
    

  154. }
    


  155. 

  156. // MQTT主函数
    

  157. static void mqtt_client_demo(void)
    

  158. {
    

  159. if (client_connect() != 0) {
    

  160. printf("MQTT connect server failed.\r\n");
    

  161. goto exit;
    

  162. }
    


  163. 

  164. while(1) {
    

  165. sys_msleep(5000);
    

  166. char context[256] = {'\0'};
    


  167. 

  168. DHT11_Read_Data(&temp,&humi);
    


  169. 

  170. OLED_ShowNum(64, 6, temp, 2, 16, 1);
    

  171. OLED_ShowNum(64, 26, humi, 2, 16, 1);
    

  172. OLED_Refresh();
    


  173. 

  174. int len = snprintf(context, sizeof(context), "{"temp": %d, "humi": %d}", temp, humi);
    

  175. if(client_publish(topic_pub, context, len) == ERR_OK) {
    

  176. printf("topic: %s\r\npayload: %s\r\n", topic_pub, context);
    

  177. }
    

  178. }
    


  179. 

  180. exit:
    

  181. printf("MQTT: close mqtt connection.\r\n");
    

  182. mqtt_connect_free();
    


  183. 

  184. return;
    

  185. }
    


  186. 

  187. // 任务函数
    

  188. static void mqtt_client_task(void *param)
    

  189. {
    

  190. int status = 0;
    

  191. char *ssid = SSID;
    

  192. char *password = PASSWORD;
    

  193. struct mac_scan_result candidate;
    


  194. 

  195. if (ssid == NULL) {
    

  196. printf("ssid can not be NULL!\r\n");
    

  197. goto exit;
    

  198. }
    


  199. 

  200. /*
    

  201. * 1. Start Wi-Fi scan
    

  202. */
    

  203. printf("Start Wi-Fi scan.\r\n");
    

  204. status = wifi_management_scan(1, ssid);
    

  205. if (status != 0) {
    

  206. printf("Wi-Fi scan failed.\r\n");
    

  207. goto exit;
    

  208. }
    

  209. sys_memset(&candidate, 0, sizeof(struct mac_scan_result));
    

  210. status = wifi_netlink_candidate_ap_find(WIFI_VIF_INDEX_DEFAULT, NULL, ssid, &candidate);
    

  211. if (status != 0) {
    

  212. goto exit;
    

  213. }
    


  214. 

  215. /*
    

  216. * 2. Start Wi-Fi connection
    

  217. */
    

  218. printf("Start Wi-Fi connection.\r\n");
    

  219. if (wifi_management_connect(ssid, password, 1) != 0) {
    

  220. printf("Wi-Fi connection failed\r\n");
    

  221. goto exit;
    

  222. }
    


  223. 

  224. /*
    

  225. * 3. Start MQTT client
    

  226. */
    

  227. printf("Start MQTT client.\r\n");
    

  228. mqtt_client_demo();
    


  229. 

  230. /*
    

  231. * 4. Stop Wi-Fi connection
    

  232. */
    

  233. printf("Stop Wi-Fi connection.\r\n");
    

  234. wifi_management_disconnect();
    


  235. 

  236. exit:
    

  237. printf("The test has ended.\r\n");
    

  238. sys_task_delete(NULL);
    

  239. }
主函数
复制
  1. int main(void)
    

  2. {
    

  3. platform_init();
    


  4. 

  5. // 初始化 OLED
    

  6. OLED_Init();
    

  7. OLED_ColorTurn(0);
    

  8. OLED_DisplayTurn(0);
    


  9. 

  10. OLED_ShowString(6, 6, (uint8_t *)"Temp:", 16, 1);
    

  11. OLED_ShowString(6, 26, (uint8_t *)"Humi:", 16, 1);
    

  12. OLED_Refresh();
    


  13. 

  14. if (wifi_init()) {
    

  15. printf("wifi init failed.\r\n");
    

  16. }
    


  17. 

  18. while(DHT11_Init())
    

  19. {
    

  20. printf("DHT11 Error \r\n");
    

  21. sys_us_delay(1000000);
    

  22. }
    


  23. 

  24. sys_task_create_dynamic((const uint8_t *)"MQTT Client", 4096, OS_TASK_PRIORITY(0), mqtt_client_task, NULL);
    


  25. 

  26. sys_os_start();
    


  27. 

  28. for ( ; ; );
    

  29. }
烧录程序
使用 Type-C 数据线将 GD32VW553-IoT V2 开发板连接到电脑，拨动拨码开关“1”到“ON”侧，按下按钮 K1 进入下载模式
打开 GD32 All In One Programmer 软件，按照下图配置后即可直接烧录
GD32 All In One Programmer 中勾选 Jump to run the App program 烧录程序后即可自动运行
使用 MQTT 客户端订阅消息获取数据
可以参考此文章：GD32VW55x MQTT 控制 GPIO 输出，使用 MQTT 客户端测试章节配置 MQTTBox 软件订阅 dht11/topic 消息




回复

收藏 举报

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

本版积分规则

iCEasy商城-小易

15

主题

18

帖子

0

粉丝
快速回复 在线客服 返回列表 返回顶部