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