使用 TcpClient 和 StreamReader 无法接收多于一条消息

Question

我需要接收来自服务器应用程序的第二个回复。当我第一次连接到服务器应用程序时，我得到了回复。但是当我尝试发送另一条消息时，我收不到它。

我已尝试寻找解决方案，但找不到任何东西。我相信问题是我的读者的指针仍然在最后。这就是为什么我无法阅读下一个回复的原因。这是我的代码：

public static void XConn()
{
    TcpClient client = new TcpClient();
    client.Connect("xxx.xxx.xxx.xxx",xx); // i cant show the IP sorry
    Stream s = client.GetStream();
    StreamReader sr = new StreamReader(s);
    StreamWriter sw = new StreamWriter(s);

    String r = "";
    sw.AutoFlush = true;      

    sw.WriteLine("CONNECT\nlogin:xxxxxxx \npasscode:xxxxxxx \n\n" + Convert.ToChar(0)); // cant show also

    while(sr.Peek() >= 0)
    {
        r = sr.ReadLine();
        Console.WriteLine(r);
        Debug.WriteLine(r);
        if (r.ToString() == "")
            break;
    }

    sr.DiscardBufferedData();

    //get data needed, sendMsg is a string containing the message i want to send
    GetmsgType("1");
    sw.WriteLine(sendMsg);

    // here i try to receive again the 2nd message but it fails =(
    while(sr.Peek() >= 0)
    {
        r = sr.ReadLine();
        Console.WriteLine(r);
        Debug.WriteLine(r);
        if (r.ToString() == "")
            break;
    }

    s.Close();

    Console.WriteLine("ok");
}

Answer 1

TcpClient.GetStream() 返回一个NetworkStream，它不支持查找，因此您无法更改阅读器指针，并且只要连接打开，它也永远不会真正结束。这意味着当服务器在响应之间存在延迟时，StreamReader.Peek() 方法可能会返回误导性的 -1。

获得响应的一种可靠方法是设置读取超时并一直循环直到抛出异常，您可以捕获并继续执行。该流仍可用于发送另一条消息。

       s.ReadTimeout = 1000;

       try
       {
          sw.WriteLine(sendMsg);

          while(true)
          {
            r = sr.ReadLine();
            Console.WriteLine(r);
          } 

         sr.DiscardBufferedData(); 
       }
      catch(IOException)
       {
         //Timed out—probably no more to read
       }

---

更新：以下也可能有效，在这种情况下，您不必担心设置超时或捕获异常：

         while(true)
         {
           r = sr.ReadLine();
           Console.WriteLine(r);
           if (sr.Peek() < 0) break;
         }