c# - 命名管道意外结果

Question

有一个简单的命名管道服务器:

        static void Main(string[] args)
    {
        StartServer();
        Console.Read();
    }

    static void StartServer()
    {
        Task.Factory.StartNew(() =>
        {
            var server = new NamedPipeServerStream("TestPipes");

            server.WaitForConnection();
            StreamReader reader = new StreamReader(server);
           StreamWriter writer = new StreamWriter(server);

            while (true)
            {

                var line = reader.ReadLine();
            if (line == "Y")
            {

                for (int i = 0; i < 5; i++)
                    writer.WriteLine(i.ToString());
                writer.Flush();

            }

            if (line=="N")
            {
                for (int i = 10; i < 15; i++)
                    writer.WriteLine(i.ToString());
                writer.Flush();
            }   


            }
        });
    }

和非常简单的客户端:

static void Main(string[] args)
    {

        //Client
        var client = new NamedPipeClientStream(Environment.MachineName, "TestPipes");

        client.Connect();
        Console.WriteLine($"Connection esteblished at {DateTime.Now}, you may continue");
        StreamReader reader = new StreamReader(client);
        StreamWriter writer = new StreamWriter(client);

        while (true)
        {

            string input = Console.ReadLine();
            if (String.IsNullOrEmpty(input)) continue;
            writer.WriteLine(input);
              writer.Flush();

            string serverString;
            while (reader.Peek() >= 0)
            {
                serverString = reader.ReadLine();
                Console.WriteLine(serverString);

            } 


        }
    }

但出于某种原因，只有第一个命令正在完成。 例如，如果我输入“Y”得到输出“Y”，然后当输入“N”时，服务器什么也没有。 需要让它连续工作。 谢谢。

Answer 1

那是因为在您的客户端中，您在 while 循环之外定义了 StreamReader reader = new StreamReader(client);，所以在第一次迭代时，当读取器点击最后一行时，底层流永远不会被重置，所以 reader.Peek() >= 0 为后续调用产生 false。

将客户端读取器对象的声明移到 while 循环中:

var client = new NamedPipeClientStream(Environment.MachineName, "TestPipes");
client.Connect();
Console.WriteLine($"Connection esteblished at {DateTime.Now}, you may continue");

StreamWriter writer = new StreamWriter(client);
while (true)
{
    StreamReader reader = new StreamReader(client);
    string input = Console.ReadLine();
    if (String.IsNullOrEmpty(input)) continue;
    writer.WriteLine(input);
    writer.Flush();

    string serverString;
    while (reader.Peek() >= 0)
    {
        serverString = reader.ReadLine();
        Console.WriteLine(serverString);
    }
}