0 
/* SEND FUNC. */
int mysend(unsigned char *buffer, int len) {

int     sock,ret;
int     status,flags;
struct sockaddr_in6 servaddr;
int opt = 1;
char *addr = "1101::1";

sock = socket(AF_INET6,SOCK_DGRAM,0);
if (sock < 0)
    return -1;
if( setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof(opt)) < 0 ) 
    return -1;
flags = fcntl(sock, F_GETFL, 0);
fcntl(sock, F_SETFL, flags|O_NONBLOCK);

servaddr.sin6_family = AF_INET6;
servaddr.sin6_port = htons(61616);

status = inet_pton(AF_INET6, addr, &servaddr.sin6_addr);
if (status <= 0) {
    perror("inet_pton");
    return -1;
}
/* send message to server */
status = sendto(sock, buffer, len, 0, (struct sockaddr *)&servaddr, sizeof(servaddr));
if (status < 0) {
    perror("sendto");
    return -1;
}
close(sock);
printf("MESSAGE SENT SUCCESSFULLY\n");
return 0;
}

/* RECEIVE FUNC. */
int myrcv() {


int     sock,ret;
int     status,len,rx_bytes;
int timeout,nfds =1;
struct sockaddr_in6 servaddr;
struct timeval wait;
unsigned char rxbuff[1024];
char *rcv;
char *addr = "1101::1";
fd_set rd;
struct pollfd *fds;


sock = socket(AF_INET6,SOCK_DGRAM,0);
if (sock < 0) 
    return -1;

servaddr.sin6_family = AF_INET6;
servaddr.sin6_port = htons(61616);

status = inet_pton(AF_INET6, addr, &servaddr.sin6_addr);
if (status <= 0) 
    return -1;
bind(sock,(struct sockaddr *)&servaddr,sizeof(servaddr));
timeout = (1* 1000);

wait.tv_sec = 10;
wait.tv_usec = 0;

len = sizeof(servaddr);
fds->fd = sock;
fds->events = POLLIN;

for(;;) {
  //FD_ZERO(&rd);
  //FD_SET(sock,&rd);

    printf("Waiting for data....\n");
    ret = poll(fds,nfds,timeout);

  //ret = select(1,&rd,NULL,NULL,&wait);
    if(ret < 0)
        break;
    if(fds->revents == 0)
      printf("revents 0 %d\n",ret);

    if(ret == 0)
       continue;

    memset(rxbuff,0,1024);
   //if(FD_ISSET(sock,&rd)) {
        printf("receiving message\n");
        rx_bytes = recvfrom(sock,rxbuff,1024,0,(struct sockaddr *)&servaddr,&len);
        memcpy(rcv,rxbuff,rx_bytes);
  //}      
}
close(sock);
return 0;
}

int main()
{
/* call mysend() periodically using sigaction() */
/* create a thread that continuously monitors(calls myrcv()) for incoming data */
    return 0;
}

サーバーからパケットを受信できませんが、tcpdump 出力でパケットを確認できました。上記はサンプル クライアント コード スニペットで、サーバーとの間でデータの送受信を試みます。シナリオは次のとおりです。クライアントはサーバーに定期的にデータを送信する必要があり、サーバーからデータを受信できる必要もあります。poll メソッドと select メソッドの両方を使用してみましたが、受信できませんでした。何か不足している場合はお知らせください。ご協力ありがとうございました。

4

2 に答える 2

1

bind受信に関する問題は、受信ソケットをローカル ポートに接続する必要があることです。

また、送信と受信の両方に単一のソケットを作成し、送信ソケットで使用するなど、改善できる点もありSO_REUSEADDRます (書き込み専用ソケットでは必要ありません)。

あなたがすべきことは次のとおりです。

  1. ソケットの作成
  2. ソケット オプションの設定
  3. ローカル アドレスにバインド (IN6ADDR_ANY_INITすべてのインターフェイスにバインドするために使用)
  4. サーバーへの書き込み
  5. 返信のための投票
于 2012-09-26T08:42:59.107 に答える
0

いくつかのこと：

  1. 受信関数（myrcv）は、bind（）呼び出しを介してリッスンポートを指定していません。それが最も可能性の高い問題です。ポートはランダムに選択されますが、送信機能についても同様です。

  2. myrcv（）関数では、poll（）を呼び出す前に実際にfdsまたはnfsdを初期化した場所がわかりません。

  3. mysend（）を呼び出すたびにソケットを再度開いたり閉じたりすると、問題が発生するように見えます。サーバーがメッセージを受信したのと同じポートで同じクライアントに送り返すことを期待している場合は、すでにソケットを閉じている可能性が高くなります。送信と受信の両方で1つのソケットを開くだけです。送信スレッドと受信スレッドの間で同じソケットを共有できます。

于 2012-09-26T08:44:24.880 に答える