我正在尝试制作一个简单的 p2p 程序,该程序应该能够让至少 3 个对等点通过端口 50001-50010 交换存储在每个对等点 1 个文件中的音乐数据(作者/标题)。坦率地说,这是家庭作业,我们从未真正讨论过 p2p,也没有找到任何有用且简单的 p2p 示例,无需特殊库等。通过 Beej 的网络编程指南和其他一些来源,我得到了一个已经在一半工作的程序,但我有 1 个大的程序问题:
我的 select 调用针对整个循环,仅针对第一个客户端/对等点,每次 1 对于所有其他客户端/对等点,它只是 0,因此它们永远不会收到任何数据
我的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;
所有功能都经过测试并且可以正常工作。
(在现场笔记中,我发现了一些不规则之处,这让我有点吃惊: 当我运行所有 3 个客户端并且第一个客户端获取所有数据时,他每次同一行都缺少 3 个字符 --- 每次都 --- 我从一台电脑运行该程序,但无法完全理解为什么会这样每次都会发生(我想我应该添加一个开始和一个结束符号来消除问题,但事实上,每次都会出现同一条线,这让我着迷)。这种现象有解释吗?)
您不是检查读取集中的哪个套接字接收到数据,而是直接在recvfd描述符上调用recvfrom。您需要循环检查所有这些。
这是我可以通过快速回顾收集到的内容。
但是这里是我很久以前写的一个基于tcp的例子。你的是udp,但你应该能够轻松找到问题的根源。
附注代码中有一个错误,有人在帖子的评论中指出并修复了。