1

我想在 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”缓冲区？还是有其他方法？非常感谢~~;-)

4

2 回答 2

1

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

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);    
}

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

于 2012-10-30T16:53:36.307 回答
1

您误解了 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，它将用接收到的数据包的源地址填充。这意味着你不能选择一个特定的客户端来接收一个数据包（你也不想这样做，因为你不知道接下来谁会打字）。相反，您只需收到一个数据包，然后找出它来自谁。

于 2012-10-30T17:09:34.683 回答