udp 广播

UDP接收广播地址发来的数据接收问题

发布于 2024-07-22 14:32:16 浏览：526 订阅该版

1 个回答

三世执戟 2024-07-22

这家伙很懒，什么也没写！

aeniac 2024-07-25

这家伙很懒，什么也没写！

aeniac 2024-07-25

这家伙很懒，什么也没写！

```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\n");
        return;
    }
    /* 创建一个socket，类型是SOCK_DGRAM，UDP类型 */
    if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1)
    {
        rt_kprintf("Socket error\n");

/* 释放接收用的数据缓冲 */
        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\n");
        /* 释放接收用的数据缓冲 */
        rt_free(recv_data);
        return;
    }
    addr_len = sizeof(struct sockaddr);
    rt_kprintf("UDP Server Waiting for client on port 48899...\n");
    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("\n(%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;
}
```