TCP 패킷 전송 오류

Question

작은 이미지를 보내고받는 웹캠 앱을 만들고 있습니다. 나는 그것을 보내고받을 수있게 만들었고, 127.0.0.1에서 테스트를 해 보았지만 정상적으로 작동했다. 그러나 이제는 내 자신의 외부 IP 주소를 사용하고 있는데, 하나의 이미지를 보내고 수신 한 다음 엉망진창처럼 보인다. 이미지 크기의 거대한 정수 값, 충돌로 이어지는 마이너스 값, 아마도 수신 및 전송이 자체적으로 실행되고 있으며 어떻게 든 동기화되지 않을 것이라고 생각합니다. 나는 각 이미지를 보내기 전에 1000ms의 지연 시간을 두었고 느린 것이지만 작동하면서 지연을 제거하자마자 망가져 버렸다.

// This sends. 
    private void NewFrameReceived(object sender, NewFrameEventArgs e) 
    { 
     Bitmap img = (Bitmap)e.Frame.Clone(); 

     byte[] imgBytes = EncodeToJpeg(img, 25).ToArray(); 
     if (_tcpOut.Connected) 
     { 
      NetworkStream ns = _tcpOut.GetStream(); 
      if (ns.CanWrite) 
      { 
       System.Threading.Thread.Sleep(500); 
       ns.Write(BitConverter.GetBytes(imgBytes.Length), 0, 4); 
       ns.Write(imgBytes, 0, imgBytes.Length); 
      } 
     } 
    } 

    // This receives. 
    private void listeningThread_DoWork(object sender, System.ComponentModel.DoWorkEventArgs e) 
    { 
     // start listening for connections 
     _tcpIn = new TcpListener(IPAddress.Any, 54321); 
     _tcpIn.Start(); 

     TcpClient _inClient = _tcpIn.AcceptTcpClient(); 
     while (true) 
     { 
      NetworkStream ns = _inClient.GetStream(); 
      if (ns.CanRead && ns.DataAvailable) 
      { 
       Byte[] imgSizeBytes = new Byte[4]; 
       ns.Read(imgSizeBytes, 0, 4); 
       int imgSize = BitConverter.ToInt32(imgSizeBytes, 0); 

       Byte[] imgBytes = new Byte[imgSize]; <-- ERROR, GET CRAZY LARGE VALUE 
       ns.Read(imgBytes, 0, imgSize); 

       MemoryStream ms = new MemoryStream(imgBytes); 
       Image img = Image.FromStream(ms); 

       picVideo.Image = img; 
      } 
     } 
    } 

Answer 1

Read 당신이 요구하는만큼 많은 바이트를 읽을 필요는 없습니다. 현재 많은 사람들이 이용할 수있는 것처럼 - 실제 반환 값을 확인하여 읽은 바이트 수를 확인해야합니다. documentation을 사용하면 더 나은 이해를 얻을 수 있습니다.

모든 이미지 바이트가 읽힐 때까지 읽기를 유지하려면 논리를 추가해야합니다. 의사 코드 예제 :

total_bytes_read = 0; 
while (total_bytes_read != total_bytes_needed) 
{ 
    bytes_left_to_read = total_bytes_needed - total_bytes_read; 
    total_bytes_read += read(buffer, total_bytes_read, bytes_left_to_read); 
} 

Answer 2

당신이 조금 ..... 데이터가 다른 패킷에 도착할 수있는 일을 재고 할 필요가 : 여기

는 코드입니다. 읽기 기능은 사용 가능한 것을 읽습니다. 이렇게하면 시스템이 동기화되지 않게됩니다. 시작과 이미지의 끝이 내 데이터 스트림에있는 위치를 항상 알 수 있도록

나는 이미지에 대한 약간의 프로토콜을 구축 할 것입니다.

당신이 할 필요는 없지만, 쉽게 인생을 만드는, 당신은 얼마나 그것을 가지고 이미지를 수신을 통해 알고있는 간단한 상태 머신에 의해 순수하게 그것을 할 수 있습니다. 그러나 이미지 (예 : 스트림의 1 여분의 바이트)를 전송할 때 준수하지 않을 경우 영원히 동기를 벗어날 수 있습니다.