qq_40634961 2019-02-25 21:09 采纳率: 0%
浏览 859

NIO中的SocketChannel多次write之后 用read如何做到区分多次的数据

例如socketChannel.write(ByteBuffer) buteBuffer的长度可能随时变更,但是接收的时候read方法是以一个固定的长度接收的

发送方

byte[] outData = new byte[2048];
ByteBuffer outByteBuffer = ByteBuffer.wrap(outData);
toWriteNrBytes = 获取数据返回一个长度;
outByteBuffer.limit(toWriteNrBytes);
socketChannel.write(outByteBuffer);

接收方

byte[] inData = new byte[2048];
ByteBuffer inByteBuffer = ByteBuffer.wrap(inData);
readNrBytes = socketChannel.read(inByteBuffer);

可是这个readNrBytes并不能实时的到每次写入的长度,请问怎么解决

  • 写回答

1条回答 默认 最新

  • Java_Light_696 2021-09-07 19:03
    关注

    这不是很简单?Buffer满了你把他清掉不就能继续用了?

                int allReadyRead;
                while ((allReadyRead = socketChannel.read(byteBuffer)) != -1) {
                    if (allReadyRead == 0) {
                        if (byteBuffer.limit() == byteBuffer.position()) {
                            byteBuffer.clear();
                            continue;
                        }
                    }
                    System.out.println("我是客户端,服务器返回信息:" + new String(byteBuffer.array(), byteBuffer.arrayOffset(), byteBuffer.arrayOffset() + byteBuffer.position(), "UTF-8"));
                }
    
    
    评论

报告相同问题?

悬赏问题

  • ¥15 如何在scanpy上做差异基因和通路富集?
  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?
  • ¥15 c++头文件不能识别CDialog