同一台机器上同时访问网络流

Question

来自this answer和Docs，它说对于并发流访问，如果有一个唯一的读取线程和一个唯一的写入线程，则可以毫无问题地执行读取和写入。

我有以下设置，如下图所示：

我有 2 个独立的服务 Tester Service 和 My Service。他们每个人都有一个Server 和一个Client。每个服务器和客户端都有 2 个任务 WriterTask 和 ReaderTask。

我面临的问题是，经过一段时间后，客户给出了IOException 10060。事实上，另一边的服务器运行良好。

现在，文档说有一个用于读/写操作的唯一线程，如果它在同一台机器上会不会有问题？

以前有没有人遇到过类似的情况？

服务器阅读器：

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

客户作家：

    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

我发现了问题所在。

我没有从我的服务器接收任何数据，因为我没有像 client.ReceiveTimeout = 2000 这样在客户端上设置接收超时。因此，服务器会在读取调用时阻止它的 ReaderTask。

我不能 100% 确定为什么当客户端的 WriterTask 写入流时，服务器的 ReaderTask 什么也不读取并保持阻塞状态。但是一旦我对服务器中的客户端对象设置了超时，一切都开始正常运行了。

那么，如果具有唯一ReaderTask 和WriterTask 的应用程序在同一台机器上，会不会有问题？当您使用接收超时时，完全没有问题。如果没有接收超时，它就无法正常工作（至少在我的情况下）。