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

Question

我想用 UDP 为 4 个人创建一个聊天室。这是代码:

<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”文件就是名称-IP文件，如下所示:

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

第一个是我自己的，后面三个是别人的。但是当我只和一个人一起运行这个程序时，首先，我们可以用非阻塞的方式互相聊天。说了几句，也不灵。我运行了 gcc，我猜想当“sendto”缓冲区已满时，它会阻止等待另一个“recvfrom”buf。我编写的程序是为 4 个人编写的，但我只与一个人一起运行它，其他两个人无法从中接收(我猜仍然是“recvfrom”中的缓冲区，对吗？)。所以“sendto”缓冲区已满并被阻塞。 我是这么想的，对吗？ 如果是真的，如何解决？我的意思是如何定期清理“sendto”缓冲区？或者还有其他方法吗？ 非常感谢~~;-)

Answer 1

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

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 它会阻塞，因为您认为它在等待第一个客户端，而实际上它在等待第二个客户端。