Longueur de l'octet de la variable d'écoute TCP/IP

Question

Je reçois un flux dont la longueur varie mais qui présente un caractère de début et de fin. Lorsque j'exécute ce code:

public TCPListener() 
{ 
     Int32 port = 31001; 
     IPAddress localAddr = IPAddress.Parse("192.168.0.78"); //Local 
     server = new TcpListener(localAddr, port); 
     server.Start(); 

     while (true) 
     { 
      // Console.Write("Waiting for a connection...-- "); 
      TcpClient client = server.AcceptTcpClient(); 

      // Console.WriteLine("new client connected"); 
      try 
      { 
       ThreadPool.QueueUserWorkItem(new WaitCallback(HandleClient), client); 
      } 
      catch (Exception ex) 
      { } 
     } 
    } 

    private void HandleClient(object tcpClient) 
    { 
     // string path = @"c:\Test.txt"; 
     TcpClient client = (TcpClient)tcpClient; 
     Byte[] bytes = new Byte[135]; 
     String data = null; 
     int i; 

     try 
     { 
      NetworkStream stream = client.GetStream(); 

      while ((i = stream.Read(bytes, 0, bytes.Length)) != 0) 
      { 
       data = System.Text.Encoding.ASCII.GetString(bytes, 0, i); 
       URLObject oU = new URLObject(); 
       oU = oDecode.TextFrameDecode(data); 
       Console.WriteLine(data); 
       Console.WriteLine(""); 
      } 
     } 
     catch (Exception ex) 
     { } 

     // Console.WriteLine(data); 
} 

Je reçois beaucoup de données chaque seconde; Je reçois les données, mais elles sont parfois fragmentées en morceaux qui ne sont pas analysables. Lorsque j'exécute ce code pour rechercher le délimiteur de fin, le flux n'obtient qu'une connexion toutes les deux minutes avec un seul enregistrement, donc je pense que les données sont tronquées, ce qui n'est pas correct.

static void Main(string[] args) 
{ 
     Int32 port = 31001; 
     IPAddress localAddr = IPAddress.Parse("192.168.0.78"); //Local 
     server = new TcpListener(localAddr, port); 
     server.Start(); 

     while (true) 
     { 
      Console.Write("Waiting for a connection...-- "); 
      TcpClient client = server.AcceptTcpClient(); 
      Console.WriteLine("new client connected"); 

      try 
      { 
       ThreadPool.QueueUserWorkItem(new WaitCallback(HandleClient), client); 
      } 
      catch (Exception ex) 
      { } 
     } 
} 

static void HandleClient(object tcpClient) 
{ 
     TcpClient client = (TcpClient)tcpClient; 
     Byte[] bytes = new Byte[135]; 
     String data = null; 
     int i; 

     try 
     { 
      using (NetworkStream stream = client.GetStream()) 
      using (StreamReader reader = new StreamReader(stream)) 
      { 
       string inputLine = reader.ReadLineSingleBreak(); 
       inputLine = inputLine + "#"; 
       Console.WriteLine(inputLine); 
       URLObject oU = new URLObject(); 
       oU = oDecode.TextFrameDecode(inputLine); 
      } 
     } 
     catch (Exception ex) 
     { } 
    } 
} 

public static class StreamReaderExtensions 
{ 
    public static string ReadLineSingleBreak(this StreamReader self) 
    { 
     StringBuilder currentLine = new StringBuilder(); 
     int i; 
     char c; 

     while ((i = self.Read()) >= 0) 
     { 
      c = (char)i; 

      if (c == '#') 
      { 
       break; 
      } 

      currentLine.Append(c); 
     } 

     return currentLine.ToString(); 
    } 
} 

J'ai besoin d'un mélange des deux ... obtenir toutes les données, mais ensuite analyser correctement.

Answer 1

j'ai fait réparer par des conseils Pieter Witvoet:

static private TcpListener server = null; 
    static private Decode oDecode = new Decode(); 
    static private string sLeftOver = string.Empty; 
    static void Main(string[] args) 
    { 
     Int32 port = 31001; 
     IPAddress localAddr = IPAddress.Parse("192.168.0.78"); //Local 
     server = new TcpListener(localAddr, port); 
     server.Start(); 
     while (true) 
     { 
      Console.Write("Waiting for a connection...-- "); 
      TcpClient client = server.AcceptTcpClient(); 
      Console.WriteLine("new client connected"); 
      try 
      { 
       ThreadPool.QueueUserWorkItem(new WaitCallback(HandleClient), client); 
      } 
      catch (Exception ex) 
      { } 
     } 
    } 
    static void HandleClient(object tcpClient) 
    { 
     TcpClient client = (TcpClient)tcpClient; 
     Byte[] bytes = new Byte[256]; 
     String data = null; 
     int i; 
     try 
     { 
      NetworkStream stream = client.GetStream(); 
      while ((i = stream.Read(bytes, 0, bytes.Length)) != 0) 
      { 
       data = System.Text.Encoding.ASCII.GetString(bytes, 0, i); 
       URLObject oU = new URLObject(); 

       Console.WriteLine(data); 
       Console.WriteLine(""); 
       //Split data here 
       string[] aData = Regex.Split(data, @"(?<=[#])"); 
       foreach (string s in aData) 
       { 
        string sData = s; 
        sData = sLeftOver + sData; 
        if (sData.EndsWith("#")) 
        { 
         sLeftOver = string.Empty; 
         Console.WriteLine(sData); 
         Console.WriteLine(""); 
         oU = oDecode.TextFrameDecode(sData); 
               } 
        else 
        { 
         sLeftOver = s; 
        } 
       } 
      } 
     } 
     catch (Exception ex) 
     { } 
    }