Stream.Read是结合两种不同的读

Question

我有一个简单的文件服务器\客户端应用程序香港专业教育学院用C＃。但我通常遇到问题，我的流将两个不同的读取写入单个缓冲区。我有一个同步流，仍然没有帮助。有什么建议么？谢谢！

System.Threading.Thread.Sleep(25); 
receive_fspos = new byte[30]; 
int bytesread = stream_1.Read(receive_fspos, 0, receive_fspos.Length);//this is where it gets combined 
if (bytesread == 0) 
{ 
    finished = true; 
    System.Threading.Thread.Sleep(25); 
} 
string string_1 = utf.GetString(receive_fspos).TrimEnd(new char[] { (char)0 }); 
int fsposition = (int)Convert.ToInt64(string_1); 
bytestosend = fsposition; 
filestream.Position = fsposition; 
byte[] buffer_1 = new byte[bufsize]; 
int bytesreadfromfs = filestream.Read(buffer_1, 0, buffer_1.Length); 
stream_1.Write(buffer_1, 0, buffer_1.Length); 
Console.Write("\rSent " + fsposition + "/" + length + " bytes"); 
finished = true; 

Answer 1

得到它的工作，码> 30000个字符：\ 这是一个有点混乱，但嘿，它的功能。

服务器：https://www.dropbox.com/s/2wyccxpjbja10z3/Program.cs?m

客户端：https://www.dropbox.com/s/yp78nx4ubacsz6f/Program.cs?m

Answer 2

如果您不完全了解它，我不会建议编写自己的流方法。

您遇到的问题是，因为输入的数据是不给你知道在长度消息是多少字节的方式字节流。

在下面你的代码，说明你想读流的“receive_fspos.Length”字节。由于“receive_fspos.Length”是30，将被读取的字节的量将是在任何地方从0到30。

如果只有15已经由连接接收的字节。它会给你15个字节。如果消息长度为20个字节。然后，该消息现在分成不同的部分。

如果所述第一消息是4个字节，所述第二消息是12个字节。现在你在结尾处有2条消息和一组16个空白字节。更糟糕的是，这16个“空白”字节可能是第三条消息进入流的开始。

如果该消息是50个字节长。那么你只会收到一半的消息。现在您需要将读取的字节添加到单独的缓冲区中。再次从流中读取。然后重复此操作，直到确定您已阅读完成整个消息所需的确切字节数。然后将所有读取字节连接回单个字节[]。

 receive_fspos = new byte[30]; 
    int bytesread = stream_1.Read(receive_fspos, 0, receive_fspos.Length);//this is where it gets combined 

不是滚动您自己的循环请使用BCL方法。它听起来像你正在使用字符串，所以这将是首选的方法..我会建议如下。

using(NetworkStream networkStream = tcpClient.GetStream()) 
using(StreamReader streamReader = new StreamReader(networkStream)) 
using(StreamWriter streamWriter = new StreamWriter(networkStream)) 
{ 
    networkStream.ReadTimeout = timeout; //Set a timeout to stop the stream from reading indefinately   

    //To receive a string 
    string incomingString = stream.ReadLine(); 

    //To send a string 
    stream.WriteLine(messageToSend); 
    stream.Flush(); 
} 

您的答案阐明了您正在尝试发送文件。为此我建议发送一个字节数组[]。使用这种方法，你可以发送任何可以序列化的东西。这包括一个文件。请注意，文件的大小是有限的，因为它必须保存在内存中。为了写一个更大的文件，你会希望将数据保存块，因为它是被流

//Please note that if the file size is large enough. It may be preferred to use a stream instead of holding the entire file in memory. 
byte[] fileAsBytes = File.ReadAllBytes(fileName); 

using(NetworkStream networkStream = tcpClient.GetStream()) 
using(BinaryReader binaryReader = new BinaryReader(networkStream)) 
using(BinaryWriter binaryWriter = new BinaryWriter(networkStream)) 
{ 
    networkStream.ReadTimeout = timeout; //Set a timeout to stop the stream from reading indefinately   

    //To receive a byte array 
    int incomingBytesLength = BinaryReader.ReadInt32(); //The header is 4 bytes that lets us know how large the incoming byte[] is. 
    byte[] incomingBytes = BinaryReader.ReadBytes(incomingBytesLength); 

    //To send a byte array 
    BinaryWriter.Write(fileAsBytes.Length); //Send a header of 4 bytes that lets the listener know how large the incoming byte[] is. 
    BinaryWriter.Write(fileAsBytes); 
}