Код в конце страницы, есть принятие файла, попытался написать передачу но что-то не выходит.
if (key.isWritable()){
ByteBuffer buffer = ByteBuffer.allocate(256);
SocketChannel channelRead = (SocketChannel) key.channel();
Storage storage = (Storage) key.attachment();
int fileSize = (int) storage.fileChannel.size();
storage.fileChannel.read(buffer,0);
int position = 0;
if (fileSize != -1){
buffer.flip();
storage.read(buffer, channelRead);
}
}
public void read (ByteBuffer buffer, SocketChannel socketChannel) {
try {
if (readOperation != null)
positionRead += readOperation.get(5, TimeUnit.SECONDS);
fileChannel.read(buffer,positionRead);
socketChannel.write(buffer);
} catch (InterruptedException | ExecutionException | TimeoutException | IOException e) {
close();
System.out.println("Read timeout");
}
}
Проблема в строке socketChannel.write(buffer);
Я не могу передать файл частями. Есть несколько варинтов передачи, в 2х из 3х вариантов нужно передавать массив байт. Как в этом примере можно передавать файл частями?
fileChannel
асинхронный, а значитsocketChannel.write(buffer)
будет вызван до того, как закончится выполнениеfileChannel.read(buffer,positionRead)
.SocketChannel
верно, нужен массив байт илиByteBuffer
, но в вашем коде в момент вызоваwrite
вbuffer
ещё ничего нет, так какread
свою работу не закончил.socketChannel.register(selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE, new Storage());
SocketChannel.write()
вместоread
иAsynchronousFileChannel.read()
вместоwrite
.