C# - StreamReader.ReadLine non funziona correttamente!

Question

Semplicemente ho cercato di implementare ciò che BufferedStreamReader fa in Java. Ho un flusso di socket aperto e voglio solo leggerlo in modo orientato alla linea - riga per riga.

Ho il seguente codice server.

while (continueProcess) 
     { 
      try 
      { 
       StreamReader reader = new StreamReader(Socket.GetStream(), Encoding.UTF8); 
       string command = reader.ReadLine(); 
       if (command == null) 
        break; 

       OnClientExecute(command); 
      } 
      catch (Exception e) 
      { 
       Console.WriteLine(e.ToString()); 
      } 
     } 

E il seguente client-code:

TcpClient tcpClient = new TcpClient(); 
     try 
     { 
      tcpClient.Connect("localhost", serverPort); 
      StreamWriter writer = new StreamWriter(tcpClient.GetStream(), Encoding.UTF8); 
      writer.AutoFlush = true; 
      writer.WriteLine("login>user,pass"); 
      writer.WriteLine("print>param1,param2,param3"); 
     } 
     catch (Exception e) 
     { 
      Console.WriteLine(e.ToString()); 
     } 
     finally 
     { 
      tcpClient.Close(); 
     } 

Il server legge solo la prima riga (login>user,pass) e poi ReadLine restituisce null!

Qual è il modo più semplice per ottenere questo lettore orientato alla linea come in Java BufferedStreamReader? : s

Answer 1

Una tipica linea-reader è qualcosa di simile:

using(StreamReader reader = new StreamReader(Socket.GetStream(), Encoding.UTF8)) { 
    string line; 
    while((line = reader.ReadLine()) != null) { 
     // do something with line 
    } 
} 

(notare che il using per assicurarci di Dispose() anche se otteniamo un errore, e il ciclo)

Se si vuole, si potrebbe abstract questo (separazione degli interessi), con un blocco iteratore:

static IEnumerable<string> ReadLines(Stream source, Encoding encoding) { 
    using(StreamReader reader = new StreamReader(source, encoding)) { 
     string line; 
     while((line = reader.ReadLine()) != null) { 
      yield return line; 
     } 
    } 
} 

(di notare che ho trasferito questo in una funzione e ha rimosso il "fare qualcosa", sosti ng con "ritorno rendimento", che crea un iteratore (un pigramente iterato, non-buffering macchina a stati)

Ci sarebbe poi consumare questo nel modo più semplice:

foreach(string line in ReadLines(Socket.GetStream(), Encoding.UTF8)) { 
    // do something with line 
} 

Ora il nostro codice di elaborazione non lo fa è necessario preoccuparsi di come leggere righe - semplicemente dato una sequenza di linee, fare qualcosa con loro.

Si noti che lo using (Dispose()) si applica anche a TcpClient; dovresti prendere l'abitudine di controllare per IDisposable; per esempio (ancora compreso il vostro errore-registrazione):

using(TcpClient tcpClient = new TcpClient()) { 
    try { 
     tcpClient.Connect("localhost", serverPort); 
     StreamWriter writer = new StreamWriter(tcpClient.GetStream(), Encoding.UTF8); 
     writer.AutoFlush = true; 
     writer.WriteLine("login>user,pass"); 
     writer.WriteLine("print>param1,param2,param3"); 
    } catch (Exception ex) { 
     Console.Error.WriteLine(ex.ToString()); 
    } 
} 

Answer 2

Il tempo nel codice del server è impostato per leggere solo una riga per connessione. Ne avrai bisogno un altro mentre cerchi di leggere tutte le linee inviate. Penso che una volta che lo stream è configurato dal lato client, invierà tutti i dati. Quindi sul lato server, il tuo stream sta effettivamente leggendo solo una riga da quel particolare stream.

Answer 3

provato questo e ha ottenuto

Il tipo o dello spazio dei nomi il nome 'flusso' non è stato trovato (le manca un un riferimento all'assembly direttiva using o? Impossibile trovare il nome dello spazio dei nomi 'StreamReader' (manca una direttiva using o un riferimento all'assembly?) Impossibile trovare il nome dello spazio dei nomi 'StreamReader' (manca una direttiva using o un assembly riferimento?) 'System.Net.Sockets.Socket' non contiene una definizione per 'GetStream'

Answer 4

public string READS() 
    { 
     byte[] buf = new byte[CLI.Available];//set buffer 
     CLI.Receive(buf);//read bytes from stream 
     string line = UTF8Encoding.UTF8.GetString(buf);//get string from bytes 
     return line;//return string from bytes 
    } 
    public void WRITES(string text) 
    { 
     byte[] buf = UTF8Encoding.UTF8.GetBytes(text);//get bytes of text 
     CLI.Send(buf);//send bytes 
    } 

CLI è una presa. per alcuni rezona la classe TcpClient non funziona più sul mio pc, ma la classe Socket funziona perfettamente.

UTF-8 è il filamento di codifica StreamReader/Writer