我托管一个服务器,它接收来自远程TCP客户端的数据(我也控制它)。下面是处理传入数据的方法:
private static async Task ReceiveDataFromRemoteSocket(
Socket socket,
int numBytesExpectedToReceive)
{
int numBytesLeftToReceive = numBytesExpectedToReceive;
using (MemoryStream memoryStream = new MemoryStream(numBytesExpectedToReceive))
{
byte[] dataBuffer = new byte[1024];
ArraySegment<byte> dataBufferSegment = new ArraySegment<byte>(dataBuffer);
int totalBytesReceived = 0;
while (numBytesLeftToReceive > 0)
{
Array.Clear(dataBuffer, 0, dataBuffer.Length);
int numBytesReceived = await socket.ReceiveAsync(dataBufferSegment, SocketFlags.Partial);
Console.WriteLine($"Received {numBytesReceived} bytes of data at {DateTime.UtcNow.ToShortTimeString()}.");
totalBytesReceived += numBytesReceived;
memoryStream.Write(
dataBuffer,
0,
numBytesLeftToReceive < dataBuffer.Length ? numBytesLeftToReceive : dataBuffer.Length);
numBytesLeftToReceive -= numBytesReceived;
}
Console.WriteLine($"Total number of bytes received, according to tally: {totalBytesReceived}.");
Console.WriteLine($"Memory stream: Contains {memoryStream.Length} bytes' worth of data.");
}
}numBytesExpectedToReceive是从标头检索的信息。
下面是我的控制台上的输出:
接受XX.XX.XXX.XXX:56767在2019年4月30日10:39:11的连接请求 期望从XX.XX.XXX.XXX:56767接收41898字节的数据。 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 416字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到96字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 在上午10:39接收1024字节的数据AM.Received 1024字节 在上午10:39收到1024字节的数据 接收到512个字节的数据在10:39 AM.Total接收到的字节数,据统计: 41984。 内存流:包含43434字节的数据。
正如您所看到的,内存流包含43434字节的数据,尽管我希望它只包含41984字节。
这导致了许多问题,例如,如果我通过编写ZipArchive创建一个新的new ZipArchive(memoryStream);实例,那么我将得到一个InvalidDataException,尽管我知道远程TCP客户端已经发送了一个有效的zip文件。
ZipArchive构造函数中?发布于 2019-04-30 11:08:44
问题是在这里您需要编写数据:
memoryStream.Write(
dataBuffer,
0,
numBytesLeftToReceive < dataBuffer.Length ? numBytesLeftToReceive : dataBuffer.Length);您完全忽略了收到的数量,相反,您只需检查要接收的数据是否比自助餐大小还要多,以及是否需要编写整个缓冲区。
您可以在输出中看到,有时没有接收到完整的缓冲区。然而,您仍然可以编写整个缓冲区。
一定要根据收到的金额来写。不要根据数据的长度做任何奇怪的比较:
memoryStream.Write(
dataBuffer,
0,
numBytesReceived);https://stackoverflow.com/questions/55919470
复制相似问题