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>

最初は自分の情報で、次の 3 つは他の人の情報でした。でも、一人だけでプログラムを走らせてみたら、まずノンブロッキングでチャットできるようになりました。いくつかの言葉の後、うまくいきませんでした。gcc を実行したところ、「sendto」バッファがいっぱいになると、他の「recvfrom」バッファの待機がブロックされたと推測しました。私が書いたプログラムは 4 人用ですが、1 人だけで実行しただけで、他の 2 人は recvfrom を実行できません (まだ "recvfrom" 内のバッファーだと思いますが、そうですか?)。そのため、「sendto」バッファがいっぱいになり、ブロックされました。それは私が思うことです、私は正しいですか？それが本当なら、それを解決する方法は？「sendto」バッファを定期的にクリーンアップする方法を意味しますか? それとも何か他の方法がありますか？どうもありがとう~~;-)

4

2 に答える 2

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 に答える
1

問題はあなたのロジックにあると思います。クライアントがメッセージを送信すると、すべてのクライアントをループして呼び出します。戻るたびに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);    
}

編集:クライアントからメッセージを受信するたびに、別のクライアントのアドレスを上書きgetcliaddrすることを意味するように in を使用しrecvfromているようです.送信者のアドレスとあなたがもう一度呼び出すと、実際には2番目のクライアントを待っているときに最初のクライアントを待っていると思うため、ブロックされます。src_addrrecvfrom

于 2012-10-30T16:53:36.307 に答える