【发布时间】:2013-04-15 05:56:38
【问题描述】:
目前我正在开发单个服务器、单个客户端 udp 聊天应用程序。最初我使用阻塞套接字,这是默认条件。现在我想将套接字转换为非阻塞,以便客户端和服务器之间的通信可以在没有转弯障碍的情况下完成...... 我现在已经在服务器端实现了选择功能,但是当它启动时客户端会发送一条消息,该消息显示在服务器端,之后客户端和服务器都没有响应,所以现在我展示了如何有我在服务器端实现了 select() 函数:
//Declaring a non-blocking structure
fd_set readfds,writefds;
// clear the set ahead of time
FD_ZERO(&readfds);
FD_ZERO(&writefds);
// add our descriptor to the set
FD_SET(sd, &readfds);
FD_SET(sd, &writefds);
/value of sd+1
int n=sd+1;
由于我想同时接收和发送数据,所以我在循环中实现了select函数:
int client_length = (int)sizeof(struct sockaddr_in);
int rv = select(n, &readfds, NULL, NULL, NULL);
if(rv==-1)
{
printf("Error in Select!!!\n");
exit(0);
}
else if(rv==0)
{
printf("Timeout occurred\n");
}
else
if (FD_ISSET(sd, &readfds))
{
int bytes_received = recvfrom(sd, buffer,SIZE, 0, (struct sockaddr *)&client, &client_length);
if (bytes_received < 0)
{
fprintf(stderr, "Could not receive datagram.\n");
closesocket(sd);
WSACleanup();
exit(0);
}
}
进一步发送数据:
fgets(buffer,SIZE,stdin);
int rv1 = select(n, &writefds, NULL, NULL, NULL);
if(rv1==-1)
{
printf("Error in Select!!!\n");
exit(0);
}
else if(rv1==0)
{
printf("Timeout occurred\n");
}
else
if(FD_ISSET(sd,&writefds))
{
if(sendto(sd, buffer,strlen(buffer), 0, (struct sockaddr *) &client,client_length)<0)
{
printf("Error sending the file! \n");
exit(1);
}
}
}
所以如果有人让我知道我是否做对了,我真的很感激,如果这没问题,那么客户端的相同实现会解决我的问题吗?
【问题讨论】:
-
请记住
select()会覆盖其输入,因此您必须在每次调用该函数(或复制它们)时重新创建fd_sets。我不确定这是否是您的问题,但这是select()代码的常见问题。 -
@Jonathan Leffler:那么我应该在循环中初始化“readfds”和“writefds”吗?
-
是的 - 你需要在循环中初始化
readfds和writefds因为select()在你调用它时会修改它们。 -
好的,我在客户端也实现了同样的东西,但它仍然作为一个阻塞应用程序工作:(
-
请让我知道我要去哪里或者它是否是正确的方法......我看到了 select() 的例子,它基本上处理了两个套接字来检查他们是否输入数据或不是……