TCP를 통해 여러 메시지 보내기

Question

이전에 비슷한 질문을했지만 그 방법을 찾지 못했습니다. 일부 데이터가 손실 될 수 있고 마지막 메시지의 일부로 일부 데이터가 올 수 있으므로 TCP를 통해 데이터를 전송할 때 문제가 있음을 이해합니다. 목록에서 일련의 명령을 보내는 중 수정하려고합니다.

여기에 보내는 내 클라이언트의 코드입니다 :

private void sendBtn_Click(object sender, EventArgs e) 
     { 
      try 
      { 
       for (int i = 0; i < listORequestedCommands.Items.Count; i++) 
       { 
        clientSock.Send(Encoding.Default.GetBytes(listORequestedCommands.Items[i].ToString()), listORequestedCommands.Items[i].ToString().Length, SocketFlags.None); 
       } 
       removeAll_Click(sender, e); 
       sendBtn.Enabled = false; 
      } 
      catch (Exception ex) 
      { 
       MessageBox.Show(ex.Message, "Error!"); 
       this.Close(); 
      } 

     } 

여기 수신 내 서버 코드입니다 : 내가 크기 접두사 및 직렬화 뭔가를 지시했다

private void clientReceived(Client sender, byte[] data) 
     { 
      try 
      { 
       Invoke((MethodInvoker)delegate 
       { 
        for (int i = 0; i < lstClients.Items.Count; i++) 
        { 
         Client client = lstClients.Items[i].Tag as Client; 

         if (client.ID == sender.ID) 
         { 
          string incommingCommand = Encoding.Default.GetString(data); 
          if (incommingCommand.CompareTo("") != 0) 
          { 
           lstClients.Items[i].SubItems[1].Text = incommingCommand; 
           string[] splittedIncommingCommand = incommingCommand.Split(' '); 

           int numRunProc = 0; 

           do 
           { 
            numRunProc = countProcesses(); 
           } 
           while ((numRunProc >= maxProcesses) || (numRunProc + Int32.Parse(splittedIncommingCommand[splittedIncommingCommand.Length - 1]) >= maxProcesses)); 

           Process processToRun = new Process(); 
           processToRun.StartInfo.FileName = splittedIncommingCommand[0]; 
           processToRun.StartInfo.WorkingDirectory = Path.GetDirectoryName(splittedIncommingCommand[0]); 
           processToRun.StartInfo.Arguments = ""; 

           for (int j = 1; j < splittedIncommingCommand.Length; j++) 
           { 
            processToRun.StartInfo.Arguments += " " + splittedIncommingCommand[j]; 
           } 

           processToRun.Start(); 
          } 
          break; 
         } 
        } 
       }); 
      } 
      catch (Exception ex) 
      { 
       MessageBox.Show(ex.Message, "Error!"); 
       this.Close(); 
      } 

     } 

, 하지만 문제가 생겨서 제대로 작동하지 않는 것 같습니다.

Answer 1

크기 접두사와 직렬화가 정확히 무엇을 의미하는지 모르겠지만 클라이언트가 얼마나 많은 바이트를 가져야하는지 또는 서버에 메시지의 끝을 "표시"해야한다는 것을 서버에 알리는 것이 좋습니다 즉, 두 개의 CRLF 또는 유사 태그/설명 (예 :)의 eom > 또는 <!과 같은 끝의 문자열. 첫 번째 옵션의 경우 일반적으로 이진 데이터를 사용해야합니다. 두 번째 샘플 코드를 쉽게 보인다.

Answer 2

요청한대로 network library networkcomms.net을 사용하여 해결책을 드릴 수 있습니다. 아래의 코드 예제는 단일 문자열을 전송합니다. 당신이 보내는 것을 쉽게 그것을

NetworkComms.AppendGlobalIncomingPacketHandler<string[]> 

또는

에 서버 섹션

NetworkComms.AppendGlobalIncomingPacketHandler<string> 

를 변경하여 string[], List<string> 등을 사용하여 수정할 수 있습니다

NetworkComms.AppendGlobalIncomingPacketHandler<List<string>> 

클라이언트 측 관계없이 그대로 유지 . 다음과 같이 서버의 코드는 다음과 같습니다

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 

using NetworkCommsDotNet; 

namespace TCPServer 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      NetworkComms.AppendGlobalIncomingPacketHandler<string>("Message", (packetHeader, connection, incomingString) => 
      { 
        Console.WriteLine("The server received a string - " + incomingString); 
        //Perform any other operations on the string you want to here. 
      }); 

      TCPConnection.StartListening(true); 

      Console.WriteLine("Server ready. Press any key to shutdown server."); 
      Console.ReadKey(true); 
      NetworkComms.Shutdown(); 
     } 
    } 
} 

을 그리고 클라이언트 : 당신이 그것을 추가 할 수 있도록

using System; 
using System.Collections.Generic; 
using System.Linq; 
using System.Text; 

using NetworkCommsDotNet; 

namespace TCPClient 
{ 
    class Program 
    { 
     static void Main(string[] args) 
     { 
      string messageToSend = "This is the message to send"; 
      TCPConnection.GetConnection(new ConnectionInfo("127.0.0.1", 10000)).SendObject("Message", messageToSend); 

      Console.WriteLine("Press any key to exit client."); 
      Console.ReadKey(true); 
      NetworkComms.Shutdown(); 
     } 
    } 
} 

당신은 분명히 웹 사이트에서 NetworkCommsDotNet DLL을 다운로드해야합니다 ' NetworkCommsDotNet을 사용하여 '참조. 클라이언트의 서버 IP 주소도 현재 "127.0.0.1"입니다. 동일한 컴퓨터에서 서버와 클라이언트를 모두 실행하는 경우이 옵션이 작동합니다. 자세한 내용은 getting started 또는 how to create a client server application 기사를 확인하십시오.