Trung tâm cá nhân
sách gpt4 ăn đã đi

c - 在 udp 服务器中接收最新数据包 - C

In lại 作者：太空狗 更新时间：2023-10-29 15:40:10 25 4
mua khóa gpt4 giày nike

UDP 服务器正在使用 lựa chọn 系统调用接收数据包。我想从每个 UDP 客户端接收最新的数据包。 (我也想听多个 UDP 客户端数据包)。

我的简单 UDP 服务器的代码:

int main(void) {
    int fd;
    int port = 5678;
    char buffer[1024];
    fd_set readfs;
    socklen_t client_length;
    struct timeval timeout_interval;
    struct sockaddr_in6 server_addr;
    struct sockaddr_in6 client_addr;
    int result;
    int recv;
    char client_addr_ipv6[100];

    fd = socket(PF_INET6, SOCK_DGRAM, 0);
    printf(" \e[1m \e[34m ---------------------------------------- \n-------------------- UDP SERVER --------------------\n \e[39m \e[0m \n");
    printf("Process: \e[34m %d \e[49m Port ..\n", port);

    if (fd < 0) {
        printf("ERR: fd < 0");
    } khác {
        memset(&server_addr, 0, sizeof(server_addr));
        server_addr.sin6_family = AF_INET6;
        server_addr.sin6_addr = in6addr_any;
        server_addr.sin6_port = htons(port);
        memset(&client_addr, 0, sizeof(client_addr));
        client_addr.sin6_family = AF_INET6;
        client_addr.sin6_addr = in6addr_any;
        client_addr.sin6_port = htons(port);

        if (bind(fd, (struct sockaddr *) &server_addr, sizeof(server_addr))
                >= 0) {
            printf("\e[1m INFO: \e[0m \e[34m Bind success.. \e[39m\n");

        } khác {
            printf("Bind.");
            trả về -1;
        }
        for (;;) {
            FD_ZERO(&readfs);
            FD_SET(fd, &readfs);
            int max_fd = MAX(0, fd);
            timeout_interval.tv_sec = 3;
            timeout_interval.tv_usec = 50000000;

            result = select(max_fd + 1, &readfs, NULL, NULL, &timeout_interval);
            //printf("\n %d \t %d \n", result, fd);
            if (result < 0) {
                printf("ERR\n");
            } else if (result == 0) {
                printf("\nTimeout\n");
            } khác {
                if (FD_ISSET(fd, &readfs)) {
                    client_length = sizeof(client_addr);
                    if ((recv = recvfrom(fd, buffer, sizeof(buffer), 0,
                                    (struct sockaddr *) &client_addr, &client_length))
                            < 0) {
                        printf("Recv-ERR!");
                        phá vỡ;
                    }
                    inet_ntop(AF_INET6, &(client_addr.sin6_addr), client_addr_ipv6, 100);
                    //printf("Client IP/Port : %s ",client_addr_ipv6);

                    printf("\n ------------------------------------------ \n");
                    printf("\e[1m Data: \e[0m \e[32m %.*s \n Client IP/Port : \e[34m %s / %d \n\e[39m", recv, buffer,client_addr_ipv6,ntohs(client_addr.sin6_port));
                }
            }
        }
    }
}

câu trả lời hay nhất

处理此问题的最佳方法是让发送方在每个数据包中放置一个序列号。每发出一个数据包，序号加1。

在接收方，您会跟踪收到的最后一个数据包的计数器。如果下一个进来的数据包有一个更大的计数器，它就是最新的。如果它不是更大，则它是一个较旧的数据包，您可以根据您的应用程序以适当的方式处理它。

此外，您应该将 recv 变量重命名为类似 recv_len 的名称。 recv 是将被此变量定义屏蔽的套接字函数的名称。

关于c - 在 udp 服务器中接收最新数据包 - C，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/39206009/

25 4 0
Đề xuất bài viết: c - 我如何告诉 gcc 我的内联汇编破坏了堆栈的一部分？
Đề xuất bài viết: java - Activity 占用 140mb 内存
Đề xuất bài viết: c - 确定文件是否是 zip 存档内的目录
Đề xuất bài viết: android - 与 firebase 11.8.0 和 google-services 插件 3.1.2 冲突
太空狗
Hồ sơ

Tôi là một lập trình viên xuất sắc, rất giỏi!

Nhận phiếu giảm giá taxi Didi miễn phí
Phiếu giảm giá taxi Didi
Các bài viết phổ biến trên toàn bộ trang web
Chứng chỉ ICP Bắc Kinh số 000000
Hợp tác quảng cáo: 1813099741@qq.com 6ren.com
Xem sitemap của VNExpress