Java nio仅读取8192/433000字节

Question

为了更好地理解JavaNIO和网络编程，我正在进行一个项目。我正试图通过netcat将一个400000字节的文件发送到我的服务器，在那里可以找到并写入文件。

问题是：当文件小于10000字节时，或者当我放置一个线程时，程序可以完美地工作。选择（）之前的睡眠（超时）。该文件发送但只读取8192字节，然后取消循环并返回select（）以捕获其余数据。但是，该文件捕获了后面的内容。我需要完整的数据进一步扩大到该项目。

我尝试过的事情：我尝试将数据加载到另一个字节数组中，该数组显然有效，但跳过了8192个字节（因为再次调用了select（）。读取391000字节的其余部分。比较文件时，缺少前8192个字节。我尝试过很多其他的事情，但我在NIO中还不足以理解我把事情搞砸了。

我的代码

这正是我感觉代码混乱的地方（调试后）

private void startServer() {
   File temp = new File("Filepath");
   Selector selector = Selector.open();
   ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
   serverSocketChannel.configureBlocking(false);
   serverSocketChannel.socket().bind(listenAddress);
   serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

   log.info("Server Socket Channel Started");

   while(!stopRequested){
     selector.select();
     Set<SelectionKey> keys = selector.selectedKeys();

     for(SelectionKey key : keys){
       if(key.isAcceptable()){
         try {
           serverSocketChannel = (ServerSocketChannel) key.channel();
           SocketChannel socket = serverSocketChannel.accept();
           socket.configureBlocking(false);
           socket.register(selector, SelectionKey.OP_READ);
         }catch (IOException e) {
           log.error("IOException caught: ", e);
         }
       }
       if(key.isReadable(){ read(key); }
       keys.remove(key);
     }
   } 
  } catch (IOException e) {
    log.error("Error: ", e);
  }
}

private void read(SelectionKey key) {
  int count = 0;
  File tmp = new File("Path");

  try {
    SocketChannel channel = (SocketChannel) key.channel();
    byteBuffer.clear();
    while((count = channel.read(byteBuffer)) > 0) {
         byteBuffer.flip();
         //in bytearrayoutputstream to append to data byte array
         byteArrayOutputStream.write(byteBuffer.array(), byteBuffer.arrayOffset(), count);
         byteBuffer.compact();
      }
    }
    data = byteArrayOutputStream.toByteArray();
    FileUtils.writeByteArrayToFile(tmp, data);
  }
}

上面的代码就是我正在使用的代码。我在这门课上有更多的东西，但我相信主要有两个函数有问题，就是这两个。我不太确定我应该采取什么措施。我必须测试我的程序的文件包含许多TCP，大约400000字节。select（）收集最初的8192个字节，然后运行read（在捕获流中的所有数据之前不应该执行），然后返回并收集其余的字节。我已将byteBuffer分配为30720字节。

如果不清楚，我可以张贴代码的其余部分，让我知道你的建议是什么。

问题
为什么当分配的空间是30720时，这段代码只抓取8192字节？为什么它工作在调试模式或与Thread.sleep（）？

以前的人建议我把行李放在行李架上。clear（）在循环之外，即使这样做，问题仍然存在。

Answer 1

非阻塞API仅promise，如果存在超过0个字节，则会引发“可读”状态。它不能保证它会等到您感兴趣的所有字节都到达；甚至没有一种方式可以说“在至少有X个字节进入之前，不要将此频道标记为可读取”。没有办法直接解决这个问题；相反，您的代码必须能够处理半满的缓冲区。例如，通过读取这些数据，清除“isReadable”状态，直到更多字节到达。

使用原始的非阻塞API是火箭科学（例如，正确编写代码非常棘手，很容易让CPU内核旋转到100%，因为您对标志管理不当，并且很容易冻结所有线程由于意外调用阻塞方法，应用程序只能处理正常线程变体所能处理的一两个百分比。

我强烈建议您首先重新考虑是否需要非阻塞（它总是很慢，而且开发起来难度也很大。毕竟，你不能在任何处理程序代码的任何地方进行一次潜在的阻塞调用，否则你的应用程序在加载时都会非常慢，而且java在等待/产生东西方面也不是很好——唯一真正的好处是你可以更细粒度地控制缓冲区大小，这是不可改变的vant，除非您的RAM非常有限，并且可以为每个连接状态使用很小的缓冲区）。如果您认为这确实是唯一的方法，那么请使用使此API更易于使用的库，例如netty。