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

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими условиями использования и подтверждаете, что прочитали и поняли наши политику конфиденциальности и нормы поведения.

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