单片机IWIP MQTT实验

单片机 STM32F407开发板DMF407电机开发板平台keil V5.31HSE 为8MHZHSI为16MHZ一、Aliyun主函数int main(void) { HAL_Init(); /* 初始化HAL库 */ sys_stm32_clock_init(336, 8, 2, 7); /* 设置时钟,168Mhz */ delay_init(168); /* 延时初始化 */ usart_init(115200); /* 串口初始化为115200 */ usmart_dev.init(84); /* 初始化USMART */ led_init(); /* 初始化LED */ lcd_init(); /* 初始化LCD */ key_init(); /* 初始化按键 */ my_mem_init(SRAMIN); /* 初始化内部SRAM内存池 */ my_mem_init(SRAMCCM); /* 初始化内部SRAMCCM内存池 */ freertos_demo(); /* 创建lwIP的任务函数 */ }void freertos_demo(void) { /* start_task任务 */ xTaskCreate((TaskFunction_t )start_task, (const char * )start_task, (uint16_t )START_STK_SIZE, (void * )NULL, (UBaseType_t )START_TASK_PRIO, (TaskHandle_t * )StartTask_Handler); vTaskStartScheduler(); /* 开启任务调度 */ }void start_task(void *pvParameters) { pvParameters pvParameters; g_lwipdev.lwip_display_fn lwip_test_ui; lwip_test_ui(1); /* 加载后前部分UI */ while (lwip_comm_init() ! 0) { lcd_show_string(30, 110, 200, 16, 16, lwIP Init failed!!, RED); delay_ms(500); lcd_fill(30, 50, 200 30, 50 16, WHITE); lcd_show_string(30, 110, 200, 16, 16, Retrying... , RED); delay_ms(500); LED1_TOGGLE(); } while (!ethernet_read_phy(PHY_SR)) /* 检查MCU与PHY芯片是否通信成功 */ { printf(MCU与PHY芯片通信失败请检查电路或者源码\r\n); } while ((g_lwipdev.dhcpstatus ! 2) (g_lwipdev.dhcpstatus ! 0XFF)) /* 等待DHCP获取成功/超时溢出 */ { vTaskDelay(5); } taskENTER_CRITICAL(); /* 进入临界区 */ /* 创建lwIP任务 */ xTaskCreate((TaskFunction_t )lwip_demo_task, (const char* )lwip_demo_task, (uint16_t )LWIP_DMEO_STK_SIZE, (void* )NULL, (UBaseType_t )LWIP_DMEO_TASK_PRIO, (TaskHandle_t* )LWIP_Task_Handler); /* LED测试任务 */ xTaskCreate((TaskFunction_t )led_task, (const char* )led_task, (uint16_t )LED_STK_SIZE, (void* )NULL, (UBaseType_t )LED_TASK_PRIO, (TaskHandle_t* )LEDTask_Handler); vTaskDelete(StartTask_Handler); /* 删除开始任务 */ taskEXIT_CRITICAL(); /* 退出临界区 */ }void lwip_demo_task(void *pvParameters) { pvParameters pvParameters; lwip_demo(); while (1) { vTaskDelay(5); } }void lwip_demo(void) { struct hostent *server; static struct mqtt_connect_client_info_t mqtt_client_info; server gethostbyname((char *)HOST_NAME); /* 对oneNET服务器地址解析 */ memcpy(g_mqtt_ip,server-h_addr,server-h_length); /* 把解析好的地址存放在mqtt_ip变量当中 */ char *PASSWORD; PASSWORD mymalloc(SRAMIN, 300); /* 为密码申请内存 */ lwip_ali_get_password(DEVICE_SECRET, CONTENT, PASSWORD); /* 通过hmac_sha1算法得到password */ /* 设置一个空的客户端信息结构 */ memset(mqtt_client_info, 0, sizeof(mqtt_client_info)); /* 设置客户端的信息量 */ mqtt_client_info.client_id (char *)CLIENT_ID; /* 设备名称 */ mqtt_client_info.client_user (char *)USER_NAME; /* 产品ID */ mqtt_client_info.client_pass (char *)PASSWORD; /* 计算出来的密码 */ mqtt_client_info.keep_alive 100; /* 保活时间 */ mqtt_client_info.will_msg NULL; mqtt_client_info.will_qos NULL; mqtt_client_info.will_retain 0; mqtt_client_info.will_topic 0; myfree(SRAMIN, PASSWORD); /* 释放内存 */ /* 创建MQTT客户端控制块 */ g_mqtt_client mqtt_client_new(); /* 连接服务器 */ mqtt_client_connect(g_mqtt_client, /* 服务器控制块 */ g_mqtt_ip, MQTT_PORT,/* 服务器IP与端口号 */ mqtt_connection_cb, LWIP_CONST_CAST(void*, mqtt_client_info),/* 设置服务器连接回调函数 */ mqtt_client_info); /* MQTT连接信息 */ while(1) { if (g_publish_flag 1) { g_temp 30 rand() % 10 1; /* 温度的数据 */ g_humid 54.8 rand() % 10 1;/* 湿度的数据 */ sprintf((char *)g_payload_out, {\params\:{\CurrentTemperature\:%0.1f,\RelativeHumidity\:%0.1f},\method\:\thing.event.property.post\}, g_temp, g_humid); g_payload_out_len strlen((char *)g_payload_out); mqtt_publish(g_mqtt_client,DEVICE_PUBLISH,g_payload_out,g_payload_out_len,1,0,mqtt_publish_request_cb,NULL); } vTaskDelay(1000); } }实验结果二、Onenet主函数int main(void) { HAL_Init(); /* 初始化HAL库 */ sys_stm32_clock_init(336, 8, 2, 7); /* 设置时钟,168Mhz */ delay_init(168); /* 延时初始化 */ usart_init(115200); /* 串口初始化为115200 */ usmart_dev.init(84); /* 初始化USMART */ led_init(); /* 初始化LED */ lcd_init(); /* 初始化LCD */ key_init(); /* 初始化按键 */ my_mem_init(SRAMIN); /* 初始化内部SRAM内存池 */ my_mem_init(SRAMCCM); /* 初始化内部SRAMCCM内存池 */ freertos_demo(); /* 创建lwIP的任务函数 */ }void freertos_demo(void) { /* start_task任务 */ xTaskCreate((TaskFunction_t )start_task, (const char * )start_task, (uint16_t )START_STK_SIZE, (void * )NULL, (UBaseType_t )START_TASK_PRIO, (TaskHandle_t * )StartTask_Handler); vTaskStartScheduler(); /* 开启任务调度 */ }void start_task(void *pvParameters) { pvParameters pvParameters; g_lwipdev.lwip_display_fn lwip_test_ui; lwip_test_ui(1); /* 加载后前部分UI */ while (lwip_comm_init() ! 0) { lcd_show_string(30, 110, 200, 16, 16, lwIP Init failed!!, RED); delay_ms(500); lcd_fill(30, 50, 200 30, 50 16, WHITE); lcd_show_string(30, 110, 200, 16, 16, Retrying... , RED); delay_ms(500); LED1_TOGGLE(); } while (!ethernet_read_phy(PHY_SR)) /* 检查MCU与PHY芯片是否通信成功 */ { printf(MCU与PHY芯片通信失败请检查电路或者源码\r\n); } while ((g_lwipdev.dhcpstatus ! 2)(g_lwipdev.dhcpstatus ! 0XFF)) /* 等待DHCP获取成功/超时溢出 */ vTaskDelay(5); taskENTER_CRITICAL(); /* 进入临界区 */ /* 创建lwIP任务 */ xTaskCreate((TaskFunction_t )lwip_demo_task, (const char* )lwip_demo_task, (uint16_t )LWIP_DMEO_STK_SIZE, (void* )NULL, (UBaseType_t )LWIP_DMEO_TASK_PRIO, (TaskHandle_t* )LWIP_Task_Handler); /* LED测试任务 */ xTaskCreate((TaskFunction_t )led_task, (const char* )led_task, (uint16_t )LED_STK_SIZE, (void* )NULL, (UBaseType_t )LED_TASK_PRIO, (TaskHandle_t* )LEDTask_Handler); vTaskDelete(StartTask_Handler); /* 删除开始任务 */ taskEXIT_CRITICAL(); /* 退出临界区 */ }void lwip_demo_task(void *pvParameters) { pvParameters pvParameters; lwip_demo(); while (1) { vTaskDelay(5); } }void lwip_demo(void) { char pro_id[] USER_PRODUCT_ID; /* 产品ID */ char access_key[] USER_ACCESS_KEY; /* 产品密钥 */ char dev_name[] USER_DEVICE_NAME; /* 设备名称 */ char dev_id[] USER_DEVICE_ID; /* 产品设备ID */ char key[] USER_KEY; /* 设备密钥 */ struct hostent *server; static struct mqtt_connect_client_info_t mqtt_client_info; char version[] 2018-10-31; unsigned int expiration_time 1956499200; char authorization_buf[160] {0}; server gethostbyname((char *)HOST_NAME); /* 对oneNET服务器地址解析 */ memcpy(g_mqtt_ip,server-h_addr,server-h_length); /* 把解析好的地址存放在mqtt_ip变量当中 */ /* 把各个参数保存在g_onenet_info结构体的成员变量中 */ memset(g_onenet_info.pro_id, 0, sizeof(g_onenet_info.pro_id)); strcpy(g_onenet_info.pro_id, pro_id); memset(g_onenet_info.access_key, 0, sizeof(g_onenet_info.access_key)); strcpy(g_onenet_info.access_key, access_key); memset(g_onenet_info.dev_name, 0, sizeof(g_onenet_info.dev_name)); strcpy(g_onenet_info.dev_name, dev_name); memset(g_onenet_info.dev_id, 0, sizeof(g_onenet_info.dev_id)); strcpy(g_onenet_info.dev_id, dev_id); memset(g_onenet_info.key, 0, sizeof(g_onenet_info.key)); strcpy(g_onenet_info.key, key); /* 根据这些参数进行解码当然这个密码可以在token软件下解码 */ onenet_authorization(version, (char *)g_onenet_info.pro_id, expiration_time, (char *)g_onenet_info.key, (char *)g_onenet_info.dev_name, authorization_buf, sizeof(authorization_buf), 0); /* 设置一个空的客户端信息结构 */ memset(mqtt_client_info, 0, sizeof(mqtt_client_info)); /* 设置客户端的信息量 */ mqtt_client_info.client_id (char *)g_onenet_info.dev_name; /* 设备名称 */ mqtt_client_info.client_user (char *)g_onenet_info.pro_id; /* 产品ID */ mqtt_client_info.client_pass (char *)authorization_buf; /* 计算出来的密码 */ mqtt_client_info.keep_alive 100; /* 保活时间 */ mqtt_client_info.will_msg NULL; mqtt_client_info.will_qos NULL; mqtt_client_info.will_retain 0; mqtt_client_info.will_topic 0; /* 创建MQTT客户端控制块 */ g_mqtt_client mqtt_client_new(); /* 连接服务器 */ mqtt_client_connect(g_mqtt_client, /* 服务器控制块 */ g_mqtt_ip, MQTT_PORT,/* 服务器IP与端口号 */ mqtt_connection_cb, LWIP_CONST_CAST(void*, mqtt_client_info),/* 设置服务器连接回调函数 */ mqtt_client_info); /* MQTT连接信息 */ while(1) { if (g_publish_flag 1) { g_temp 30 rand() % 10 1; /* 温度的数据 */ g_humid 54.8 rand() % 10 1;/* 湿度的数据 */ sprintf((char *)g_payload_out, {\id\: 123,\dp\: { \temperatrue\: [{\v\: %0.1f,}],\power\: [{\v\: %0.1f,}]}}, g_temp, g_humid); g_payload_out_len strlen((char *)g_payload_out); mqtt_publish(g_mqtt_client,DEVICE_PUBLISH,g_payload_out,g_payload_out_len,1,0,mqtt_publish_request_cb,NULL); } vTaskDelay(1000); } }实验结果