在一个简单的自制p2p程序中使用select()与udp交换“音乐数据”时出现的问题

Question

嘿嘿，

我正在尝试做一个简单的p2p程序，应该能够让至少3个对等交换音乐数据(作者/标题)，这是通过端口50001-50010每个对等存储在一个文件中。坦率地说，这是家庭作业，我们从来没有真正讨论过p2p，我也没有发现任何有用的简单的p2p示例，没有特殊的库，等等，通过beej的网络编程指南和其他一些来源，我得到了一个已经中途工作的程序，但我有一个大问题：

我的select调用只针对第一个客户端/对等体的整个循环，对于所有其他客户端/对等体，每次都是1，因此它们永远不会接收任何数据。

我的p2p代码：

case 6:
{
    if(!filename.empty())
    {
        time_t start, now;
        time(&start);
        double elapsedtime = 0;
        char *recvbuf;
        char *sendbuf;
        recvbuf = new char[1024];
        sendbuf = new char[1024];
        int recvfd, sendfd,err, port;
        int errormarker = 0;
        if((recvfd = socket(AF_INET,SOCK_DGRAM,0)) == -1)
        {
            std::cout << "Error setting socket\n";
            errormarker =1;
        }
        if(errormarker ==1)
            break;
        struct sockaddr_in server_address;
        server_address.sin_family = AF_INET;
        server_address.sin_addr.s_addr = INADDR_ANY;
        server_address.sin_port = htons(50001);
        for (int i =0; i<=9;i++)
        {
            port = 50001+i;
            errormarker = bind(recvfd,(sockaddr*) &server_address, sizeof   (server_address));
            if(errormarker ==-1)
                server_address.sin_port = htons(server_address.sin_port+1);
            else
                break;
        }
        if(errormarker == -1)
        {
            std::cout << "all ports are used, please wait a minute and try again\n";
            break;
        }
        std::cout << "Searching for other musicdata owners\n";
        fd_set readset;
        while (elapsedtime < 15)
        {
            if(errormarker != 0)
                break;
            memset(recvbuf, 0, sizeof(recvbuf));
            memset(sendbuf, 0, sizeof(sendbuf));
            struct timeval tv;
            tv.tv_sec =0;
            tv.tv_usec = rnd(10000,50000);
            FD_ZERO(&readset);
            FD_SET(recvfd, &readset);
            int result = select(recvfd + 1, &readset, NULL, NULL, &tv);
            std::cout << result << "\n";
            if (result >0)
            {
                result = recvfrom(recvfd, recvbuf, 1024, NULL,NULL,NULL);
                if (result != -1)
                {
                    buftofile(recvbuf,filename);
                    addnewdata(filename);
                }
                else
                    std::cout << "error receiving data \n";
            }
            filetobuf(sendbuf,filename);
            for(int i = 50001; i<=50010;i++)
            {
                struct addrinfo hints, *servinfo, *p;
                memset(&hints, 0, sizeof hints);
                hints.ai_family = AF_UNSPEC;
                hints.ai_socktype =SOCK_DGRAM;
                std::string s_port = to_string(i);
                err = getaddrinfo(NULL,s_port.c_str(),&hints,&servinfo);
                for(p=servinfo;p!=NULL;p=p->ai_next)                                
                {
                    if(i == port)
                    {
                        err = sendto(recvfd, sendbuf,strlen(sendbuf), 0, p->ai_addr,p->ai_addrlen);
                        continue;
                    }
                    if((sendfd = socket(p->ai_family, p->ai_socktype,p->ai_protocol)) == -1)
                    {
                        continue;
                    }
                    else
                    {
                        err=sendto(sendfd,sendbuf,strlen(sendbuf), 0, p->ai_addr,p->ai_addrlen);
                        close(sendfd);                              
                    }
                }
                freeaddrinfo(servinfo);
            }
            time(&now);
            elapsedtime=difftime(now,start);
        }
        close(recvfd);

    }
    else
        std::cout << "Error, please choose a file to save your data first!" << std::endl;
}
break;

这些函数都经过了测试，可以正常工作。

(在一个sitenote上，我得到了一个小小的不规则性，这让我有点吃惊:当我运行所有3个客户端时，第一个客户端每次都会得到他得到的所有数据-每次都是-我从一台pc上运行程序，但我不能完全理解为什么每次都会发生这种情况(我想我应该加上一个开始-和一个结束符号来消除这个问题，但事实上，每次都有相同的行出现让我着迷)。对这种现象有什么解释吗？)

提前感谢你的帮助。

Answer 1

您可以直接对recvfd描述符调用recvfrom，而不是检查读取集中的哪个套接字接收了数据。你需要在一个循环中检查所有它们。

这是我可以在快速回顾中收集到的信息。

但是here是我很久以前写的一个基于tcp的例子。您的是udp，但是您应该能够很容易地找到问题的根源。

附言:有人指出并在帖子的评论中修复了代码中的一个错误。