sendto()在缓冲区已满时阻塞，如何解决？

Question

我想用UDP给四个人做一个聊天室。代码如下：

<code>
#include<stdio.h>
#include<sys/socket.h>
#include<sys/types.h>
#include<arpa/inet.h>
#include<unistd.h>
#define PORT 9999
#define SIZE 1024
int c;
int i=0;
int k=0;
char name[4][20];
char ip[4][16];
FILE * txt;
struct sockaddr_in seraddr,cliaddr[3],getcliaddr[3];

void gettxt()
{
    txt=fopen("ip.txt","r");
    for(k=0;k<4;k++)
    {
        c=fgetc(txt);
        while(c!=' ')
        {
            name[k][i]=(char)c;
            i++;
            c=fgetc(txt);
        }
        name[k][i]='\0';
        i=0;
        c=fgetc(txt);
        while(c<'1'||c>'3')
            c=fgetc(txt);
        while(c!='\n')
        {
            ip[k][i]=c;
            c=fgetc(txt);
            i++;
        }
        ip[k][i]='\0';
        i=0;
    }
    for(k=0;k<4;k++)
        printf("<%s>%s\n",name[k],ip[k]);
}

int compare(struct sockaddr_in whichcli)
{
    int w=1;
    for(w=1;w<4;w++)
    {
        if(whichcli.sin_addr.s_addr==cliaddr[w].sin_addr.s_addr)
            break;
    }
    return w;
}

int main()
{
    int com;//compare return value (just the "k")
    int qq;
    int ret;
    int ser;
    int maxsock;
    char bufrecv[SIZE];
    char bufsend[SIZE];
    socklen_t clilen=sizeof(cliaddr[1]);//the same wa ~~I guess

    gettxt();

    fd_set readfds;

    seraddr.sin_family=AF_INET;
    seraddr.sin_addr.s_addr=inet_addr(ip[0]);
    seraddr.sin_port=htons(PORT);

    for(qq=1;qq<4;qq++)
    {
        cliaddr[qq].sin_family=AF_INET;
        cliaddr[qq].sin_addr.s_addr=inet_addr(ip[qq]);
        cliaddr[qq].sin_port=htons(PORT);
    }
    ser=socket(AF_INET,SOCK_DGRAM,0);
    bind(ser,(struct sockaddr*)&seraddr,sizeof(seraddr));

    if(STDIN_FILENO>ser)
        maxsock=STDIN_FILENO;
    else 
        maxsock=ser;

    while(1)
    {
        FD_ZERO(&readfds);  
        FD_SET(STDIN_FILENO,&readfds);
        FD_SET(ser,&readfds);
        ret=select(maxsock+1,&readfds,NULL,NULL,0); 
        if(ret>0)
        {
            if(FD_ISSET(STDIN_FILENO,&readfds))
            {
                fgets(bufsend,SIZE,stdin);
                for(qq=1;qq<4;qq++)
                    sendto(ser,bufsend,SIZE,0,(struct sockaddr*)&cliaddr[qq],clilen);
            }
            if(FD_ISSET(ser,&readfds))
            {
                for(qq=1;qq<4;qq++)
                {
                    recvfrom(ser,bufrecv,SIZE,0,(struct sockaddr*)&getcliaddr[qq],&clilen);
                    com=compare(getcliaddr[qq]);//
                    printf("<%s>%s\n",name[com],bufrecv);
                }
            }
        }
    }
    return 0;
}
</code>

文件"ip.txt“就是name-IP文件，如下所示：

<txt>
I 192.168.1.2
Sun 192.168.1.4
Jerry 192.168.1.5
Peter 192.168.1.6
</txt>

第一个是我自己的信息，下面三个是别人的，但是当我只有一个人运行程序时，首先，我们可以用非阻塞的方式互相聊天。几句话之后，它并没有很好地工作。我写的程序是为4个人写的，但是我只有一个人在运行它，另外两个人不能从它恢复(我猜仍然是" recvfrom“中的缓冲区，对吗？)因此"sendto“缓冲区已满并被阻塞。这就是我的想法，我说的对吗？如果这是真的，该如何解决呢？我的意思是如何定期清理"sendto“缓冲区？还是有其他的方法？非常感谢~~;-)

Answer 1

我认为问题出在您的逻辑中，当客户端向您发送消息时，您将遍历所有客户端并调用recvfrom，每次select返回时，您应该只调用一次recvfrom。

if(FD_ISSET(ser,&readfds))
{    
    struct sockaddr_in src_addr;
    socklen_t addrlen = sizeof(src_addr);
    recvfrom(ser, bufrecv, SIZE, 0, (struct sockaddr*)&src_addr, &addrlen);
    com=compare(src_addr);//
    printf("<%s>%s\n",name[com],bufrecv);    
}

编辑：似乎你使用recvfrom中的getcliaddr作为src_addr，这意味着每次你从一个客户端接收消息时，你会覆盖另一个客户端的地址，这对一个客户端来说不是问题，但对于多个客户端，你可以用发送者的地址覆盖第一个客户端，如果你再次调用recvfrom，它会阻塞，因为你认为它正在等待第一个客户端，而实际上它正在等待第二个客户端。

Answer 2

您误解了recvfrom(2)的src_addr参数的含义：

ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
                 struct sockaddr *src_addr, socklen_t *addrlen);

src_addr是此函数的输出，而不是输入。它应该指向一个空的struct sockaddr，它将用接收到的数据包的源地址填充该was。这意味着您不能选择一个特定的客户机来接收数据包(而且您并不是真的想要这样做，因为您不知道下一个输入的是谁)。相反，您只需接收一个数据包，然后找出它来自谁。