0

我正在开发客户端/服务器应用程序。
服务器有时会向所有连接的客户端发送一个字符串。

为此，我定义了一个数据包：
byte <- packet id
int <- 字符串的长度 byte[] <- 包含字符串的字节数组

现在我如何发送这个数据包：

byte[] buf = { ID };
buf = buf.Concat(BitConverter.GetBytes(StringData.Length)).ToArray();
buf = buf.Concat(Encoding.UTF8.GetBytes(StringData)).ToArray();

stream.Write(buf, 0, buf.Length);

有时字符串很小（大约 200 字节），但有时会稍大一些（>20k 字节）。通常较小的数据包在客户端读取它们时不会出现问题，但较大的数据包仅被客户端部分接收。
客户端的典型场景：

packet id -> 0x01
length -> 20000
string -> "this is an example stri"

我知道“这是一个示例字符串”不是 20000 字节长，但这只是一个示例。
在我的例子中，字符串是一个序列化的 JObject (Json.Net)。

在客户端，我像这样读取数据包：

byte[] buf = new byte[1];
stream.Read(buf, 0, buf.Length);

// Some packet id evaluation

buf = new byte[4];
stream.Read(buf, 0, buf.Length);
int length = BitConverter.ToInt32(buf, 0);

buf = new byte[length];
stream.Read(buf, 0, length);
string jsonString = Encoding.UTF8.GetString(buf, 0, length);

我真的不知道我做错了什么。
有什么建议可以在哪里查找错误或我在发送数据时做错了什么？

提前致谢！

4

2 回答 2

2

代码有两个问题：

首先，您使用的是字符串的长度，而不是数据包中编码数据的长度。先转换字符串，这样就可以使用数据包中的长度了：

byte[] data = Encoding.UTF8.GetBytes(StringData);
byte[] buf = { ID };
buf = buf.Concat(BitConverter.GetBytes(data.Length)).ToArray();
buf = buf.Concat(data).ToArray();

其次，该Read方法不保证它返回请求的字节数。它可能会在缓冲区中放入更少的字节，并返回实际放入缓冲区中的字节数。

使用Read调用的返回值检查是否需要多次调用才能获取数据。例子：

buf = new byte[4];
int offset = 0;
while (offset < buf.length) {
  int len = stream.Read(buf, offset, buf.Length - offset);
  offset += len;
}

注意：此实现不处理流过早结束的情况。然后该Read方法将返回零，并且代码进入一个永恒循环。您可能希望创建一种用于从流中读取的方法，您可以在其中处理所有可能的错误。

于 2013-10-24T18:21:11.800 回答
0

我不能保证这会奏效，但请试一试阅读您的数据：

var ms = new System.IO.MemoryStream();

byte[] buffer = new byte[4096];
int bytesRead = 0;

do
{
    bytesRead = stream.Read(buffer, 0, buffer.Length);

    ms.Write(buffer, 0, bytesRead);
}
while (stream.DataAvailable);

string jsonString = System.Text.Encoding.UTF8.GetString(ms.ToArray());

根据您的需要进行调整。让我知道它是如何工作的。

于 2013-10-24T18:13:15.347 回答