TCPクライアントとサーバ間でパケットロスが発生しないようにする

Question

データのチャンクをCサーバに送信するJava TCPクライアントを作成しています。クライアント/サーバーは開発PC上で非常にうまく機能しました。このコードは、ハードウェアボードに展開するとパケット損失を示しました。私はログを持っているだけで、サーバーがすべてのパケットを受け取っていないことがわかっています。 テストするハードウェアがありません。したがって、最初のレベルでは、クライアントコードが必要なすべてのデータを送信していることを確認したいと思います。

ここに私のコード（Javaのクライアント部分）です。これが確実に行われるようにするにはどうすればよいですか？タイミングなどのある再送コマンドがありますか？ここで

 Socket mySocket = new Socket("10.0.0.2",2800); 
     OutputStream os = mySocket.getOutputStream();   

     System.out.println(" Sending 8 byte Header Msg with length of following data to Server"); 
     os.write(hdr, 0, 8); 
     os.flush(); 

     System.out.println(" Sending Data "); 
     start = 0; 
     for(int index=0; index < ((rbuffer.length/chucksize)+1); index++){    
      if(start + chucksize > rbuffer.length) { 
       System.arraycopy(rbuffer, start, val, 0, rbuffer.length - start); 
      } else { 
       System.arraycopy(rbuffer, start, val, 0, chucksize); 
      } 
      start += chucksize ; 

      os.write(val,0,chucksize); 
      os.flush(); 
     } 

は、このデータを受け取り、Cの抜粋です：すべての

while ((bytes_received = recv(connected, rMsg, sizeof(rMsg),0)) > 0){ 

if (bytes_received > 0)  // zero indicates end of transmission */ 
    { 
    /* get length of message (2 bytes) */ 
    tmpVal = 0; 
    tmpVal |= rMsg[idx++]; 
    tmpVal = tmpVal << 8; 
    tmpVal |= rMsg[idx++]; 
    msg_len = tmpVal; 

    len = msg_len; 
    //printf("msg_len = %d\n", len); 
    printf("length of following message from header message : %d\n", len); 
    char echoBuffer[RCVBUFSIZE] ;   
    memset(echoBuffer, 0, RCVBUFSIZE); 
    int recvMsgsize = 0; 

    plain=(char *)malloc(len+1); 
    if (!plain) 
    { 
    fprintf(stderr, "Memory error!"); 
    } 
    for(i = RCVBUFSIZE; i < (len+RCVBUFSIZE); i=i+RCVBUFSIZE){ 
    if(i>=len){ 
     recvMsgSize = recv(connected, echoBuffer, (len - (i-RCVBUFSIZE)), 0); 
     memcpy(&plain[k], echoBuffer, recvMsgSize); 
     k = k+recvMsgSize; 
    } 
    else{ 
     recvMsgSize = recv(connected, echoBuffer, RCVBUFSIZE, 0); 
     memcpy(&plain[k], echoBuffer, recvMsgSize); 
     k = k+recvMsgSize; 
     } 
    } 
}//closing if 
}//closing while 

Answer 1

まずTCP/IPでのパケット損失のようなものはありません。このプロトコルは、正しい順序でバイトストリームを確実に送信するように設計されています。したがって、問題はアプリケーションまたは他の側で発生している必要があります。

私はこの全体のarraycopy()狂気（C誰を？）分析する気分では本当にないのですが、なぜあなただ​​けBufferedOutputStreamて一度に全体rbufferを送信していませんか？

、その後：

os.write(rbuffer); 

は私を信じて、BufferedOutputStreamは（チャンクにバイトを収集し、一度にそれらを送信する）まったく同じことをやっています。それとも、私は何かを逃していますか？

Answer 2

私は次のようにC側のプログラムを変更し、それが動作するようになりました：

    printf("length of following message from header message : %d\n", len); 

        plain=(char *)malloc(len+1); 
        if (!plain) 
        { 
         fprintf(stderr, "Memory error!"); 

        } 
        memset(plain, 0, len+1); 
        int remain = len; 
        k= 0; 
        while (remain){ 
         int toGet = remain > RCVBUFSIZE ? RCVBUFSIZE : remain; 
         remain -= toGet; 
         int recvd = 0; 
         while(recvd < toGet) { 
          if((recvMsgSize = recv(connected, echoBuffer, toGet-recvd, 0)) < 0){ 
           printf("error receiving data\n"); 
          } 
          memcpy(&plain[k], echoBuffer, recvMsgSize); 
          k += recvMsgSize; 
          printf("Total data accumulated after recv input %d\n", k); 
          recvd += recvMsgSize; 
         } 
        }