【STM32F407+CUBEMX+FreeRTOS+lwIP之UDP记录】

本文主要是介绍【STM32F407+CUBEMX+FreeRTOS+lwIP之UDP记录】，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

基本信息

正点原子F407探索者开发板
cubemx v6.10.0
STM32Cube FM_f4 v1.28.0
8720A

cubemx配置

GPIO

NVIC

RCC

SYS

ETH

FREERTOS

这个按需配置

lwIP

这个按需配置

8720A可以选下图中这个，其他为适配的可以生成代码后自己修改

UDP（SOCKET）

本地端口是本地对外开放的端口
远程端口目标IP的端口

一些定义

#include <lwip/sockets.h>
#include "lwip/opt.h"
#include "lwip/sys.h"
#include "lwip/api.h"
#include "lwip/udp.h"
#include "queue.h"osThreadId_t led_TaskHandle;
const osThreadAttr_t led_Task_attributes = {.name = "led_Task",.stack_size = 128 * 4,.priority = (osPriority_t) (osPriorityNormal-10),
};
void Start_led_Task(void *argument);#ifdef lwip_socket_udp_base
osThreadId_t socket_udp_TaskHandle;
const osThreadAttr_t socket_udp_Task_attributes = {.name = "socket_udp_Task",.stack_size = 128 * 8,.priority = (osPriority_t) (osPriorityNormal-9),
};
void Start_socket_udp_Task(void *argument);
#define LWIP_DEMO_PORT 8081
#define LWIP_DEMO_RX_BUFSIZE         200    /* 最大接收数据长度 */
//#define IP_ADDR   "192.168.123.92"		/* 单播 一对一*/
socklen_t sock_fd;                     /* 定义一个Socket接口 */
struct sockaddr_in local_info;         /* 定义Socket地址信息结构体 */
/* 接收数据缓冲区 */
uint8_t g_lwip_demo_recvbuf[LWIP_DEMO_RX_BUFSIZE];osThreadId_t lwip_recv_TaskHandle;
const osThreadAttr_t lwip_recv_Task_attributes = {.name = "lwip_recv_Task",.stack_size = 128 * 4,.priority = (osPriority_t) (osPriorityNormal-9),
};
/* 显示消息队列的数量 */
#define DISPLAYMSG_Q_NUM    20              /* 显示消息队列的数量 */
QueueHandle_t g_display_queue;              /* 显示消息队列句柄 */

创建led任务

led_TaskHandle = osThreadNew(Start_led_Task, NULL, &led_Task_attributes);

lwIP初始化后UDP、接收、队列

void StartDefaultTask(void *argument)
{/* init code for LWIP */MX_LWIP_Init();/* USER CODE BEGIN StartDefaultTask */taskENTER_CRITICAL();           /* 进入临界区 */socket_udp_TaskHandle = osThreadNew(Start_socket_udp_Task, NULL, &socket_udp_Task_attributes);lwip_recv_TaskHandle = osThreadNew(lwip_recv_Task, NULL, &lwip_recv_Task_attributes);g_display_queue = xQueueCreate(DISPLAYMSG_Q_NUM,200);/* 创建消息Message_Queue,队列项长度是200长度 */taskEXIT_CRITICAL();            /* 退出临界区 *//* Infinite loop */for(;;){osDelay(1);	//ticks}/* USER CODE END StartDefaultTask */
}

udp配置

void Start_socket_udp_Task(void *argument){/* 发送数据内容 */char g_lwip_demo_sendbuf[] = "ALIENTEK DATA \r\n";memset(&local_info, 0, sizeof(struct sockaddr_in)); /* 将服务器地址清空 */local_info.sin_len = sizeof(local_info);local_info.sin_family = AF_INET;                    /* IPv4地址 */local_info.sin_port = htons(LWIP_DEMO_PORT);        /* 设置端口号 */local_info.sin_addr.s_addr = htons(INADDR_ANY);     /* 设置本地IP地址 */sock_fd = socket(AF_INET,SOCK_DGRAM,0);/* 建立一个新的socket连接 */if (sock_fd < 0){printf("socket failed!\n");}int ret = bind(sock_fd,(struct sockaddr *)&local_info, sizeof(struct sockaddr_in));/* 建立绑定 */if (ret < 0){printf(" bind error!\n ");}while(1){local_info.sin_addr.s_addr = inet_addr(IP_ADDR);                /* 需要发送的远程IP地址 */sendto(sock_fd,                                         /* scoket */(char *)g_lwip_demo_sendbuf,                        /* 发送的数据 */sizeof(g_lwip_demo_sendbuf), 0,                     /* 发送的数据大小 */(struct sockaddr *)&local_info,                   /* 接收端地址信息 */ sizeof(local_info));                              /* 接收端地址信息大小 */vTaskDelay(400);LL_GPIO_TogglePin(LED1_GPIO_Port,LED1_Pin);}
}

将从队列收到的消息打印出来

void Start_led_Task(void *argument){uint8_t buffer[200];while(1){LL_GPIO_TogglePin(LED0_GPIO_Port,LED0_Pin);vTaskDelay(500);if (xQueueReceive(g_display_queue,&buffer,portMAX_DELAY)){printf("%s\n",buffer);memset(buffer,0,200);       /* 清除缓冲区 */}}
}

void lwip_recv_Task(void *argument){BaseType_t lwip_err;struct sockaddr_in sender;/*存放发送方信息*/int sender_len = sizeof(sender);/*发送方信息长度*/while(1){memset(g_lwip_demo_recvbuf, 0, sizeof(g_lwip_demo_recvbuf));
//		recv(sock_fd, (void *)g_lwip_demo_recvbuf, sizeof(g_lwip_demo_recvbuf), 0);/*这个只有通信数据*/recvfrom(sock_fd, (void *)g_lwip_demo_recvbuf, sizeof(g_lwip_demo_recvbuf), 0,(struct sockaddr*)&sender,(socklen_t *)&sender_len);/*这个只有通信数据、还有发送方信息*/lwip_err = xQueueSend(g_display_queue,&g_lwip_demo_recvbuf,0);if (lwip_err == errQUEUE_FULL){printf("队列Key_Queue已满，数据发送失败!\r\n");}else{/*IP*/printf("%s %d \n", inet_ntoa(sender.sin_addr), ntohs(sender.sin_port));/*打印发送放IP和端口*/}vTaskDelay(10);}
}

效果

UDP广播（SOCKET）

#define IP_ADDR   "192.168.123.255"		/* 广播所有设备255.255.255.255 通常只在本地网络中使用*/

效果

UDP组播（SOCKET）

添加一些定义

/* 组播D类IP：224.0.0.0至239.255.255.255 */
/* 多播/组播 IP 地址 */
#define GROUP_IP "224.0.1.0"
/* 多播信息 */
struct ip_mreq_t
{struct ip_mreq mreq;            /* 多播信息控制块 */socklen_t mreq_len;             /* 多播信息长度 */
};
struct ip_mreq_t mreq_info;

bind后加这个

/*组播 LWIP_IGMP为1*/mreq_info.mreq.imr_multiaddr.s_addr = inet_addr(GROUP_IP);     /* 多播组 IP 地址设置 */mreq_info.mreq.imr_interface.s_addr = htonl(INADDR_ANY);       /* 待加入多播组的 IP 地址 */mreq_info.mreq_len = sizeof(struct ip_mreq);/* 添加多播组成员（该语句之前，socket 只与 某单播IP地址相关联 执行该语句后 将与多播地址相关联） */ret = setsockopt(sock_fd,IPPROTO_IP,IP_ADD_MEMBERSHIP,&mreq_info.mreq,mreq_info.mreq_len);if (ret < 0){printf("setsockopt failed !");}else{printf("setsockopt success\n");}

切到组播IP，发送数据

local_info.sin_addr.s_addr = inet_addr(GROUP_IP); /* 组播ip */
sendto(sock_fd,                                         /* scoket */(char *)g_lwip_demo_sendbuf,                        /* 发送的数据 */sizeof(g_lwip_demo_sendbuf), 0,                     /* 发送的数据大小 */(struct sockaddr *)&local_info,                   /* 接收端地址信息 */ sizeof(local_info));                              /* 接收端地址信息大小 */vTaskDelay(400);LL_GPIO_TogglePin(LED1_GPIO_Port,LED1_Pin);

cubemx注意以下

ethernetif.c

netif初始化前添加

netif->flags |=NETIF_FLAG_IGMP;/*组播*/

PHY初始化前添加

HAL_ETH_GetMACFilterConfig(&heth,&g_eth_macfilterconfig_handler);g_eth_macfilterconfig_handler.ReceiveAllMode = ENABLE;g_eth_macfilterconfig_handler.PassAllMulticast =ENABLE;HAL_ETH_SetMACFilterConfig(&heth,&g_eth_macfilterconfig_handler);

这个定义到外面

	ETH_MACFilterConfigTypeDef g_eth_macfilterconfig_handler;

效果

可参考正点原子和野火的手册

这篇关于【STM32F407+CUBEMX+FreeRTOS+lwIP之UDP记录】的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---