首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >Java客户端到C#服务器TCP

Java客户端到C#服务器TCP
EN

Stack Overflow用户
提问于 2018-09-22 14:08:26
回答 1查看 167关注 0票数 -1

问题是,当我发送到40KB时,一切都是正常的当我发送更多数据时,有时收到一半的数据没有任何问题,是否存在networkstream.Read限制,即使我错误地处理了数据,我也不能确定问题是来自网络流还是来自输出流的java或c#

C#服务器

代码语言:javascript
复制
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 //我在没有将数据分成较小的步长的情况下对此进行了测试,收到的数据中有一半并不是全部

代码语言:javascript
复制
        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;
    }

有什么想法吗?

EN

回答 1

Stack Overflow用户

发布于 2018-09-22 15:52:47

来自这篇文章的解决方案NetworkStream is reading data that should not be there

代码语言:javascript
复制
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开始,它需要读取已设置给它的量,以将读取重新设置到新的缓冲区位置。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/52453992

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档