NIO2 AsynchronousSocketChannel чтение/запись полностью с использованием CompletionHandler

Question

Я использую java 7's nio2 AsynchronousSocketChannel для выполнения операций чтения и записи с использованием CompletionHandlers. Во-первых, я хотел бы знать, гарантирована ли операция записи, полностью или нет, ByteBuffer. Если это частичная запись, использование CompletionHandler's - это способ полностью выписать ByteBuffer. Может быть, использование рекурсии?

То же самое касается чтения. Я гарантированно полностью прочитаю все сообщение из AsynchronousSocketchannel или может быть частично прочитанным. Если это так, снова используя CompletionHandlers, как я могу написать обработчик, который будет выполнять полную операцию чтения.

Благодарим Вас заранее Фрэнсис

Answer 1

Ни один из read и write операций не гарантируется писать или читать полное содержание буфера. Они просто читают или записывают все, что доступно в базовом сокете для операции чтения, или сколько операционная система может помещать в буфер для операции записи.

Для полного чтения/записи надежно вам нужно повторить операцию read/write до тех пор, пока существует некоторое оставшееся пространство/байт в буфере:

ByteBuffer buffer = ByteBuffer.allocate(full_size_I_do_expect); 
channel.read(buffer, null, 
    new CompletionHandler() { 
     @Override 
     public void completed(Integer result, Object attachment) { 
      if (result < 0) { 
       // handle unexpected connection close 
      } 
      else if (buffer.remaining() > 0) { 
       // repeat the call with the same CompletionHandler 
       channel.read(buffer, null, this); 
      } 
      else { 
       // got all data, process the buffer 
      } 
     } 
     @Override 
     public void failed(Throwable e, Object attachment) { 
      // handle the failure 
     } 
});