udp广播接收和发送（udp广播接收和发送 stm32）

科技前沿 • 2025-06-03 07:35 • 阅读 33

大家好，我是讯享网，很高兴认识大家。

“`c #include “at_udp_server.h” #define BUFSZ 128 At_Date_Struct at_date; void at_udp_server(void *parameter) {

int sock; int bytes_read; char *recv_data; socklen_t addr_len; struct sockaddr_in server_addr, client_addr; /* 分配接收用的数据缓冲 */ recv_data = rt_malloc(BUFSZ); if (recv_data == RT_NULL) { /* 分配内存失败，返回 */ rt_kprintf("No memory

”);

 return; } /* 创建一个socket，类型是SOCK_DGRAM，UDP类型 */ if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) { rt_kprintf("Socket error

”);

 /* 释放接收用的数据缓冲 */ rt_free(recv_data); return; } int set = 1; setsockopt(sock, SOL_SOCKET, SO_BROADCAST, &set, sizeof(set)); /* 初始化服务端地址 */ server_addr.sin_family = AF_INET; server_addr.sin_port = htons(48899); server_addr.sin_addr.s_addr = inet_addr(basics_ip_use.ip_addr); rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero)); /* 绑定socket到服务端地址 */ if (bind(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) == -1) { /* 绑定地址失败 */ rt_kprintf("Bind error

”);

讯享网

 /* 释放接收用的数据缓冲 */ rt_free(recv_data); return; } addr_len = sizeof(struct sockaddr); rt_kprintf("UDP Server Waiting for client on port 48899...

”);

while (1) { /* 从sock中收取最大BUFSZ - 1字节数据 */ bytes_read = recvfrom(sock, recv_data, BUFSZ - 1, 0, (struct sockaddr *)&client_addr, &addr_len); /* UDP不同于TCP，它基本不会出现收取的数据失败的情况，除非设置了超时等待 */ if(bytes_read != 0) { recv_data[bytes_read] = '0'; /* 把末端清零 */ /* 输出接收的数据 */ rt_kprintf("

(%s , %d) said : “, inet_ntoa(client_addr.sin_addr),

 ntohs(client_addr.sin_port)); rt_kprintf("%s", recv_data); at_date.recv_at_buffer = recv_data; at_date.recv_len = bytes_read; at_date.sock = sock; at_date.client_addr = (struct sockaddr *)&client_addr; at_date.at_for = UDP; at_date_dis(&at_date); } bytes_read = 0; rt_thread_mdelay(10); } return;

} “`

udp广播接收和发送（udp广播接收和发送 stm32）

相关推荐