Java客户端到C#服务器TCP
Java客户端到C#服务器TCP
提问于 2018-09-22 14:08:26
问题是，当我发送到40KB时，一切都是正常的当我发送更多数据时，有时收到一半的数据没有任何问题，是否存在networkstream.Read限制，即使我错误地处理了数据，我也不能确定问题是来自网络流还是来自输出流的java或c#
C#服务器
private void ReadData(){
if (networkStream.DataAvailable)
{
int size = GetBufferSize();
Thread.Sleep(340);
byte[] myReadBuffer = new byte[size];
int numberOfBytesRead = 0;
while (true)
{
numberOfBytesRead = networkStream.Read(myReadBuffer, 0, myReadBuffer.Length);
if (numberOfBytesRead >= myReadBuffer.Length)
{
break;
}
}
string str = Encoding.UTF8.GetString(myReadBuffer, 0, size);
dynamic Message = Newtonsoft.Json.JsonConvert.DeserializeObject<dynamic>(str);
// Android Message , JSON String
if (OnAndroidMessage != null)
{
OnAndroidMessage(Message);
}
}
}
private int GetBufferSize()
{
byte[] myReadBuffer = new byte[4];
int numberOfBytesRead = 0;
do
{
numberOfBytesRead = networkStream.Read(myReadBuffer, 0, myReadBuffer.Length);
} while (networkStream.DataAvailable && numberOfBytesRead < myReadBuffer.Length);
if (numberOfBytesRead > 0)
{
// reverse the byte array.
if (BitConverter.IsLittleEndian)
{
Array.Reverse(myReadBuffer);
}
return BitConverter.ToInt32(myReadBuffer, 0);
}
else
{
return 0;
}
}Java Client //我在没有将数据分成较小的步长的情况下对此进行了测试，收到的数据中有一半并不是全部
mBufferOut = socket.getOutputStream();
private void sendMessage(final String message) {
if (mBufferOut != null && message != null) {
try {
byte[] data = message.getBytes("UTF-8");
Log.d("_TAG", "Sending: " + message);
Log.d("_TAG", "Message length: " + Integer.toString(data.length));
mBufferOut.write(toByteArray(data.length));
mBufferOut.flush();
List<byte[]> divideArray = divideArray(data, 10000);
for (byte[] dataChunk : divideArray) {
Log.e("_TAG","CHUNK SIZE > " + Integer.toString(dataChunk.length));
mBufferOut.write(dataChunk, 0, dataChunk.length);
mBufferOut.flush();
}
} catch (Exception e1) {
e1.printStackTrace();
}
}
}
private List<byte[]> divideArray(byte[] source, int chunksize) {
List<byte[]> result = new ArrayList<byte[]>();
int start = 0;
while (start < source.length) {
int end = Math.min(source.length, start + chunksize);
result.add(Arrays.copyOfRange(source, start, end));
start += chunksize;
}
return result;
}有什么想法吗？
回答 1
Stack Overflow用户
发布于 2018-09-22 15:52:47
来自这篇文章的解决方案NetworkStream is reading data that should not be there
static void ReadExact(Stream stream, byte[] buffer, int offset, int count)
{
int read;
while(count > 0 && (read = stream.Read(buffer, offset, count)) > 0) {
offset += read;
count -= read;
}
if(count != 0) throw new EndOfStreamException();
}问题是读取它需要大小，你需要给它分块并检查每个块，而且读取不会从它停止的地方重新开始，直到它读取的数量被设置为读取。如果我设置为读取10，那么如果它没有找到10，那么它将读取它找到的内容，例如它读取6，它将返回6，当它再次循环读取其余的时候，它不是从6开始，它从0开始读取，直到4，所以你覆盖了你的数据，如果它从第一次尝试读取10，那么它设置读取完成，这样它就不会从0开始，它需要读取已设置给它的量，以将读取重新设置到新的缓冲区位置。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/52453992
复制相关文章
相似问题
腾讯云开发者
