目前我正在开发单个服务器、单个客户端 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);
}
}
}
所以如果somoone让我知道我是否做对了,我真的很感激,如果这没问题,那么客户端的相同实施会解决我的问题吗?