c# SslStream.Read循环问题

Question

我一直在通过创建一个应用程序来学习 C#，但我遇到了一个我一直在努力解决的障碍。

基本上我有下面的代码，这是我用来从我设置的网络流中读取的代码。它可以工作，但每次 sslstream.Read() 解锁时它只读取 1 个数据包。这导致消息大量积压。

我正在尝试做的是，如果流读取的部分包含多个数据包，则将它们全部读取。

我曾多次尝试解决这个问题，但最终却陷入了一堆混乱的代码中。

如果有人可以帮助我，我将不胜感激！

（每个数据包的前 4 个字节是数据包的大小。数据包范围在 8 字节到 28,000 字节之间）

        SslStream _sslStream = (SslStream)_sslconnection;
        int bytes = -1;
        int nextread = 0;
        int byteslefttoread = -1;
        byte[] tmpMessage;
        byte[] buffer = new byte[3000000];
        do
        {
            bytes = _sslStream.Read(buffer, nextread, 8192);
           int packetSize = BitConverter.ToInt32(buffer, 0);
            nextread += bytes;
            byteslefttoread = packetSize - nextread;

            if (byteslefttoread <= 0)
            {
                int leftover = Math.Abs(byteslefttoread);
                do
                {
                    tmpMessage = new byte[packetSize];
                    Buffer.BlockCopy(buffer, 0, tmpMessage, 0, packetSize);

                    PacketHolder tmpPacketHolder = new PacketHolder(tmpMessage, "in");
                    lock (StaticMessageBuffers.MsglockerIn)
                    {
                        //puts message into the message queue.. not very oop... :S
                        MessageInQueue.Enqueue(tmpPacketHolder);
                    }
                }
                while (leftover > 0);

                Buffer.BlockCopy(buffer, packetSize , buffer, 0, leftover);
                byteslefttoread = 0;
                nextread = leftover;

            }

        } while (bytes != 0);

Answer 1

如果您使用 .Net 3.5 或更高版本，我强烈建议您查看 Windows Communication Foundation (wcf ）。它会简单地处理您尝试通过网络执行的任何操作。

另一方面，如果您这样做纯粹是为了教育目的。
请查看此链接。最好的选择是以较小的增量从流中读取数据，并将该数据输入到另一个流中。一旦您确定了消息所需的数据长度，您就可以将第二个流切割成消息。您可以设置一个外部循环，在其中检查可用字节并等待其值 > 0 开始下一条消息。还应该注意的是，任何网络代码都应该在自己的线程上运行，以免阻塞 UI 线程。