0

Код в конце страницы, есть принятие файла, попытался написать передачу но что-то не выходит.

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х вариантов нужно передавать массив байт. Как в этом примере можно передавать файл частями?

11
  • 2
    У вас тут много странного. Во-первых, вы зачем-то пытаетесь считать 256 байт из начала файла каждый раз, когда сетевой канал становится доступным для записи. Во-вторых, на сколько я понимаю, fileChannel асинхронный, а значит socketChannel.write(buffer) будет вызван до того, как закончится выполнение fileChannel.read(buffer,positionRead). 25 апр 2018 в 6:15
  • 1
    Нет, асинхронная запись принципиально ничем не отличается от чтения. С запись в SocketChannel верно, нужен массив байт или ByteBuffer, но в вашем коде в момент вызова write в buffer ещё ничего нет, так как read свою работу не закончил. 25 апр 2018 в 10:28
  • 1
    Потому что события наступают не одновременно. Сначала клиент соединяется с сервером, канал становится acceptable. Если клиент вызывает read со своей стороны, на стороне сервера канал становится writable. Если клиент вызывает write, канал становится readable. 25 апр 2018 в 18:52
  • 1
    Вы можете "подписать" селектор на оба состояния канала: socketChannel.register(selector, SelectionKey.OP_READ | SelectionKey.OP_WRITE, new Storage()); 26 апр 2018 в 16:43
  • 1
    Как я уже писал, принципиальных различий у записи и чтения нет. Достаточно использовать метод SocketChannel.write() вместо read и AsynchronousFileChannel.read() вместо write. 26 апр 2018 в 17:42

0

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Посмотрите другие вопросы с метками или задайте свой вопрос.