C# - StreamReader.ReadLine ne fonctionne pas correctement!

Question

Simplement j'ai essayé d'implémenter ce que BufferedStreamReader fait en Java. J'ai un flux de socket ouvert et je veux juste le lire de façon linéaire - ligne par ligne.

J'ai le code serveur suivant.

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()); 
      } 
     } 

Et le client-code suivant:

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(); 
     } 

Le serveur ne lit que la première ligne (login>user,pass) puis ReadLine retourne NULL!

Quelle est la manière la plus simple de réaliser ce lecteur orienté ligne comme dans Java BufferedStreamReader? : s

Answer 1

Une ligne lecteur typique est quelque chose comme:

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

(notez le using pour nous assurer Dispose() même si nous obtenons une erreur, et la boucle)

Si vous voulez, vous pourriez abstraite cette (séparation des préoccupations) avec un bloc itérateur:

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; 
     } 
    } 
} 

(noter que nous avons déplacé cela en fonction et a retiré le « faire quelque chose », vidange dan ng avec « retour de rendement », ce qui crée un iterator (un paresseusement itéré, machine d'état non-tampon)

Nous pourrions alors consommer ce aussi simple que:

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

Maintenant, notre code de traitement ne pas besoin de s'inquiéter comment pour lire les lignes - simplement donné une séquence de lignes, faire quelque chose avec eux. Notez que le using (Dispose()) s'applique également à TcpClient; vous devriez prendre l'habitude de vérifier IDisposable; par exemple (y compris encore votre diagraphie d'erreur):

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

Le temps de votre code serveur est configuré pour lire uniquement une ligne par connexion. Vous aurez besoin d'un autre moment pour essayer de lire toutes les lignes envoyées. Je pense qu'une fois que ce flux est configuré du côté client, il va envoyer toutes les données. Ensuite, du côté serveur, votre flux ne lit en réalité qu'une seule ligne de ce flux particulier.

Answer 3

essayé et obtenu

Le type ou le nom namespace Stream 'n'a pas pu être trouvé (vous manque une directive à l'aide ou une référence d'assemblage? Le type ou le nom d'espace de noms 'StreamReader' est introuvable (une directive using ou une référence d'assembly est-elle manquante?) Le nom de type ou d'espace de noms 'StreamReader' est introuvable (une directive using ou un assembly référence?) 'System.Net.Sockets.Socket' ne contient pas de définition pour '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 est une socket. pour certains rezoner la classe TcpClient ne fonctionne plus sur mon PC, mais la classe Socket fonctionne très bien.

UTF-8 est le StreamReader/Writer brin d'encodage