Dans UWP StreamSocket, puis-je lire les données avec timeout et laisser la connexion ouverte si le délai expire

Question

Comme je ne pouvais pas trouver un moyen de jeter un coup d'oeil pour les données (lire les données sans consommer le tampon) comme demandé au How to peek StreamSocket for data in UWP apps J'essaie maintenant faire mon "coup d'oeil" mais toujours pas de chance.

Je ne vois pas comment je peux lire les données de StreamSocket de la manière qui me permettra d'utiliser des délais d'attente et de laisser la connexion utilisable dans le cas où le délai expire.

En fin de compte, le problème est le suivant. Dans mon client IMAP, j'obtiens une réponse d'un serveur et si cette réponse est négative, je dois attendre un peu pour voir si le serveur envoie immédiatement une autre réponse (parfois, le serveur peut le faire, avec des détails supplémentaires) sur l'erreur ou même un paquet zéro pour fermer la connexion). Si le serveur n'a pas envoyé une autre réponse, je vais bien, laissant simplement la méthode et revenant à l'appelant. L'appelant peut alors envoyer plus de données au flux, recevoir plus de réponses, etc.

Donc, après avoir envoyé une requête et obtenu une réponse initiale, j'ai besoin dans certains cas de lire à nouveau le socket avec un très petit intervalle de temps et si non les données arrivent, ne font rien.

Answer 1

Vous pouvez utiliser un CancelationTokenSource pour générer un délai et arrêter une opération asynchrone. Le DataReader consomme les données du flux d'entrée du StreamSocket. Sa méthode LoadAsync() retournera lorsqu'il y aura au moins un octet de données. Ici, nous ajoutons une source d'annulation qui annulera la tâche asynchrone après 1 seconde pour arrêter DataReader.LoadAsync() si aucune donnée n'a été consommée.

var stream  = new StreamSocket(); 

var inputStream = stream.InputStream; 

var reader  = new DataReader(inputStream); 
reader.InputStreamOptions = InputStreamOptions.Partial; 

while(true) 
{ 
    try 
    { 
     var timeoutSource = new CancellationTokenSource(TimeSpan.FromSeconds(1)); 
     var data = await reader.LoadAsync(1).AsTask(timeoutSource.Token); 

     while(reader.UnconsumedBufferLength > 0) 
     { 
      var read = reader.ReadUInt32(); 
     } 
    } 
    catch(TaskCanceledException) 
    { 
     // timeout 
    } 
} 

N'oubliez pas que la suppression de DataReader ferme le flux et la connexion.