Accès simultané du flux réseau sur la même machine

Question

De this answer et Docs, il est indiqué que pour l'accès au flux concurrent, la lecture et l'écriture peuvent être effectuées sans problème s'il y a UN thread unique pour la lecture et UN thread unique pour l'écriture.

Je vais avoir la configuration suivante, également montré dans l'image ci-dessous:

J'ai 2 services distincts Tester Service et My Service. Chacun d'eux a un Server et un Client. Chacun des serveurs et clients a 2 tâches WriterTask et ReaderTask.

Le problème auquel je suis confronté est qu'après un certain temps, le client donne IOException 10060. En fait, le serveur de l'autre côté fonctionne bien.

Maintenant, la documentation indique un thread unique pour l'opération de lecture/écriture, y a-t-il un problème si c'est sur la même machine?

Quelqu'un d'autre faisait face à une situation similaire auparavant?

Reader serveur:

private void ReaderTask(NetworkStream stream) 
    { 
     while (true) 
     { 
      // Some code 
      try 
      { 
       if (stream.CanRead) 
       { 
        var readTask = Task.Run(() => 
        { 
         MyObj message = null; 
         try 
         { 
          message = Deserialize<MyObj>(stream); 
          Console.WriteLine("ReaderTask: Read"); 
          // Some code 
         } 
         catch (IOException e) 
         { 
          Console.WriteLine("ReaderTask: " + e.Message); 
         } 
         return message; 
        }); 
        while(!readTask.Wait(1000)) 
        { 
         Console.WriteLine("ReaderTask: Wait 1000"); 
        } 
        if (readTask.Result != null) 
        { 
         Console.WriteLine("ReaderTask: Message received" + readTask.Result.toString()); 
        } 
       } 
      } 
      catch (IOException e) 
      { 
       Console.WriteLine("ReaderTask: " + e.Message); 
      } 
     } 
    } 

client Writer:

private void WriterTask(NetworkStream stream) 
    { 
     while (true) 
     { 
      // Some code 
      try 
      { 
       if (stream.CanWrite) 
       { 
        // message = getMessage(); 
        Serialize(stream, message); 
        Console.WriteLine("WriterTask: Write"); 
        // Some code 
       } 
      } 
      catch (IOException e) 
      { 
       Console.WriteLine("WriterTask: " + e.Message); 
      } 
      Thread.Sleep(1000); 
     } 
    } 

Answer 1

je me suis dit ce que le problème.

Je ne recevais pas de données de mon serveur car, je n'ai pas défini un délai d'attente de réception sur le client comme ceci client.ReceiveTimeout = 2000. Pour cette raison, le serveur aurait ReaderTask bloqué sur l'appel en lecture.

Je ne suis pas sûr à 100% de savoir pourquoi lorsque le WriterTask du client écrirait dans le flux, le ReaderTask du serveur ne lirait rien et resterait bloqué. Mais une fois que j'ai mis un délai sur l'objet client dans le serveur, tout a commencé à fonctionner normalement.

Donc, y a-t-il un problème si les applications avec ReaderTask et WriterTask uniques sont sur la même machine? Lorsque vous utilisez un délai d'attente de réception, aucun problème. Sans délai de réception, cela n'a pas fonctionné normalement (du moins dans mon cas).