From 7d59697663e18a992ad09053318d0dc8b7f7910f Mon Sep 17 00:00:00 2001 From: james <1943357252@qq.com> Date: Tue, 30 Jul 2024 07:58:11 +0800 Subject: [PATCH] =?UTF-8?q?md=20=E8=A1=A5=E5=85=85=E6=88=91=E7=9A=84?= =?UTF-8?q?=E5=AE=9E=E8=B7=B5=E7=9A=84=E4=BB=8B=E7=BB=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- Day5/README.md | 208 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 208 insertions(+) diff --git a/Day5/README.md b/Day5/README.md index b9ae3cd..d5c2698 100644 --- a/Day5/README.md +++ b/Day5/README.md @@ -240,6 +240,214 @@ W25Q64→注册为spi20设备，挂载到spi2总线上（**SPI设备**）→*通 ![DFS结合FAL配置W25Q64](image-1.png) +## 我的实践 +### 读取传感器数据，上传到阿里云 +（合并头两个代码），拼接字符串时我用了`sprintf`，其实应该也可以样例原有的`HAL_Snprintf`的 +``` c +#include "rtthread.h" +#include "dev_sign_api.h" +#include "mqtt_api.h" +#include +#include +#include +#include +#include "aht10.h" +char DEMO_PRODUCT_KEY[IOTX_PRODUCT_KEY_LEN + 1] = {0}; +char DEMO_DEVICE_NAME[IOTX_DEVICE_NAME_LEN + 1] = {0}; +char DEMO_DEVICE_SECRET[IOTX_DEVICE_SECRET_LEN + 1] = {0}; + +void *HAL_Malloc(uint32_t size); +void HAL_Free(void *ptr); +void HAL_Printf(const char *fmt, ...); +int HAL_GetProductKey(char product_key[IOTX_PRODUCT_KEY_LEN + 1]); +int HAL_GetDeviceName(char device_name[IOTX_DEVICE_NAME_LEN + 1]); +int HAL_GetDeviceSecret(char device_secret[IOTX_DEVICE_SECRET_LEN]); +uint64_t HAL_UptimeMs(void); +int HAL_Snprintf(char *str, const int len, const char *fmt, ...); + +// AHT挂载的总线名字 +#define AHT10_I2C_BUS "i2c3" + + // AHT设备指针 + aht10_device_t Dev = RT_NULL; + + // Humi:湿度值,Temp:温度值 + float Humi, Temp; + + +#define EXAMPLE_TRACE(fmt, ...) \ + do { \ + HAL_Printf("%s|%03d :: ", __func__, __LINE__); \ + HAL_Printf(fmt, ##__VA_ARGS__); \ + HAL_Printf("%s", "\r\n"); \ + } while(0) + +static void example_message_arrive(void *pcontext, void *pclient, iotx_mqtt_event_msg_pt msg) +{ + iotx_mqtt_topic_info_t *topic_info = (iotx_mqtt_topic_info_pt) msg->msg; + + switch (msg->event_type) { + case IOTX_MQTT_EVENT_PUBLISH_RECEIVED: + /* print topic name and topic message */ + EXAMPLE_TRACE("Message Arrived:"); + EXAMPLE_TRACE("Topic : %.*s", topic_info->topic_len, topic_info->ptopic); + EXAMPLE_TRACE("Payload: %.*s", topic_info->payload_len, topic_info->payload); + EXAMPLE_TRACE("\n"); + break; + default: + break; + } +} + +static int example_subscribe(void *handle) +{ + int res = 0; + const char *fmt = "/%s/%s/user/get"; + char *topic = NULL; + int topic_len = 0; + + topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1; + topic = HAL_Malloc(topic_len); + if (topic == NULL) { + EXAMPLE_TRACE("memory not enough"); + return -1; + } + memset(topic, 0, topic_len); + HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME); + + res = IOT_MQTT_Subscribe(handle, topic, IOTX_MQTT_QOS0, example_message_arrive, NULL); + if (res < 0) { + EXAMPLE_TRACE("subscribe failed"); + HAL_Free(topic); + return -1; + } + + HAL_Free(topic); + return 0; +} + + char tmp[256]; +void tmp_payload(void) +{ + // 读取温湿度值 + Humi = aht10_read_humidity(Dev); + Temp = aht10_read_temperature(Dev); + sprintf(tmp, "{\"params\":{\"temperature\":%.2f,\"humidity\":%.2f}}", Temp, Humi); + rt_kprintf("\n%f %f tmp:%s\n",Humi,Temp,tmp); + return; +} +static int example_publish(void *handle) +{ + + + tmp_payload(); + int res = 0; + const char *fmt = "/sys/%s/%s/thing/event/property/post"; + // /k1lyriw1yGj/${deviceName}/user/get + char *topic = NULL; + int topic_len = 0; + char *payload = tmp; + // strcpy(payload,tmp_payload()); + rt_kprintf("payload:%s\n",payload); + topic_len = strlen(fmt) + strlen(DEMO_PRODUCT_KEY) + strlen(DEMO_DEVICE_NAME) + 1; + topic = HAL_Malloc(topic_len); + if (topic == NULL) { + EXAMPLE_TRACE("memory not enough"); + return -1; + } + memset(topic, 0, topic_len); + HAL_Snprintf(topic, topic_len, fmt, DEMO_PRODUCT_KEY, DEMO_DEVICE_NAME); + + res = IOT_MQTT_Publish_Simple(0, topic, IOTX_MQTT_QOS0, payload, strlen(payload)); + if (res < 0) { + EXAMPLE_TRACE("publish failed, res = %d", res); + HAL_Free(topic); + return -1; + } + + HAL_Free(topic); + return 0; +} + +static void example_event_handle(void *pcontext, void *pclient, iotx_mqtt_event_msg_pt msg) +{ + EXAMPLE_TRACE("msg->event_type : %d", msg->event_type); +} + +static void mqtt_example_main(void *parameter) +{ + void *pclient = NULL; + int res = 0; + int loop_cnt = 0; + iotx_mqtt_param_t mqtt_params; + + HAL_GetProductKey(DEMO_PRODUCT_KEY); + HAL_GetDeviceName(DEMO_DEVICE_NAME); + HAL_GetDeviceSecret(DEMO_DEVICE_SECRET); + + EXAMPLE_TRACE("mqtt example"); + + memset(&mqtt_params, 0x0, sizeof(mqtt_params)); + + mqtt_params.handle_event.h_fp = example_event_handle; + + pclient = IOT_MQTT_Construct(&mqtt_params); + if (NULL == pclient) { + EXAMPLE_TRACE("MQTT construct failed"); + return ; + } + + res = example_subscribe(pclient); + if (res < 0) { + IOT_MQTT_Destroy(&pclient); + return ; + } + + while (1) { + if (0 == loop_cnt % 20) { + example_publish(pclient); + } + + IOT_MQTT_Yield(pclient, 200); + + loop_cnt += 1; + } + + return ; +} + + +#define THREAD_PRIORITY 25 +#define THREAD_STACK_SIZE 4096 +#define THREAD_TIMESLICE 5 + +rt_thread_t MQTT_Thread = RT_NULL; + +void MQTT_Creat_Thread(void) +{ + + // 初始化设备 + Dev = aht10_init(AHT10_I2C_BUS); + if (Dev == RT_NULL) + { + rt_kprintf("AHT10_init Fail"); + return; + } + + MQTT_Thread = rt_thread_create("MTQQ_Thread", mqtt_example_main, RT_NULL, THREAD_STACK_SIZE, THREAD_PRIORITY, THREAD_TIMESLICE); + + if (MQTT_Thread != RT_NULL) + { + rt_thread_startup(MQTT_Thread); + } + else + { + rt_kprintf("MQTT Thread Create Failed!\n"); + } + +} +MSH_CMD_EXPORT(MQTT_Creat_Thread, create a MQTT_Thread); +``` [更多参考官方文档链接](https://www.rt-thread.org/document/site/#/rt-thread-version/rt-thread-standard/programming-manual/filesystem/filesystem?id=%e6%96%87%e4%bb%b6%e7%ae%a1%e7%90%86)