Java NIO — Краткое руководство —

C: /test/temp.txt

Hello World!

import java.io.FileInputStream;import java.io.FileNotFoundException;import java.io.IOException;import java.nio.ByteBuffer;import java.nio.channels.ScatteringByteChannel;publicclassScatterExample{privatestaticString FILENAME ="C:/Test/temp.txt";publicstaticvoid main(String[] args){ByteBuffer bLen1 =ByteBuffer.allocate(1024);ByteBuffer bLen2 =ByteBuffer.allocate(1024);FileInputStreamin;try{in=newFileInputStream(FILENAME);ScatteringByteChannel scatter =in.getChannel(); scatter.read(newByteBuffer[]{bLen1, bLen2}); bLen1.position(0); bLen2.position(0);int len1 = bLen1.asIntBuffer().get();int len2 = bLen2.asIntBuffer().get();System.out.println("Scattering : Len1 = "  len1);System.out.println("Scattering : Len2 = "  len2);}catch(FileNotFoundException exObj){ exObj.printStackTrace();}catch(IOException ioObj){ ioObj.printStackTrace();}}}

Channeldemo.java

import java.io.IOException;import java.io.RandomAccessFile;import java.nio.ByteBuffer;import java.nio.channels.FileChannel;publicclassChannelDemo{publicstaticvoid main(String args[])throwsIOException{RandomAccessFile file =newRandomAccessFile("C:/Test/temp.txt","r");FileChannel fileChannel = file.getChannel();ByteBuffer byteBuffer =ByteBuffer.allocate(512);while(fileChannel.read(byteBuffer)>0){// flip the buffer to prepare for get operation byteBuffer.flip();while(byteBuffer.hasRemaining()){System.out.print((char) byteBuffer.get());}} file.close();}}

Filechanneldemo.java

import java.io.IOException;import java.io.RandomAccessFile;import java.nio.ByteBuffer;import java.nio.channels.FileChannel;import java.nio.charset.Charset;import java.nio.file.Path;import java.nio.file.Paths;import java.nio.file.StandardOpenOption;import java.util.HashSet;import java.util.Set;publicclassFileChannelDemo{publicstaticvoid main(String args[])throwsIOException{//append the content to existing file  writeFileChannel(ByteBuffer.wrap("Welcome to TutorialsPoint".getBytes()));//read the file readFileChannel();}publicstaticvoid readFileChannel()throwsIOException{RandomAccessFile randomAccessFile =newRandomAccessFile("C:/Test/temp.txt","rw");FileChannel fileChannel = randomAccessFile.getChannel();ByteBuffer byteBuffer =ByteBuffer.allocate(512);Charset charset =Charset.forName("US-ASCII");while(fileChannel.read(byteBuffer)>0){ byteBuffer.rewind();System.out.print(charset.decode(byteBuffer)); byteBuffer.flip();} fileChannel.close(); randomAccessFile.close();}publicstaticvoid writeFileChannel(ByteBuffer byteBuffer)throwsIOException{Set<StandardOpenOption> options =newHashSet<>(); options.add(StandardOpenOption.CREATE); options.add(StandardOpenOption.APPEND);Path path =Paths.get("C:/Test/temp.txt");FileChannel fileChannel =FileChannel.open(path, options); fileChannel.write(byteBuffer); fileChannel.close();}}

Gatheringbytechannel

запись в несколько каналов — в этом мы сделали запись данных из нескольких буферов в один канал. Для этого снова несколько буферов выделяются и добавляются в массив типа буфера. Затем этот массив передается в качестве параметра методу write ()

В следующем примере показано, как осуществляется сбор данных в Java NIO.

import java.io.FileNotFoundException;import java.io.FileOutputStream;import java.io.IOException;import java.nio.ByteBuffer;import java.nio.channels.GatheringByteChannel;publicclassGatherExample{privatestaticString FILENAME ="C:/Test/temp.txt";publicstaticvoid main(String[] args){String stream1 ="Gather data stream first";String stream2 ="Gather data stream second";ByteBuffer bLen1 =ByteBuffer.allocate(1024);ByteBuffer bLen2 =ByteBuffer.allocate(1024);// Next two buffer hold the data we want to writeByteBuffer bstream1 =ByteBuffer.wrap(stream1.getBytes());ByteBuffer bstream2 =ByteBuffer.wrap(stream2.getBytes());int len1 = stream1.length();int len2 = stream2.length();// Writing length(data) to the Buffer bLen1.asIntBuffer().put(len1); bLen2.asIntBuffer().put(len2);System.out.println("Gathering : Len1 = "  len1);System.out.println("Gathering : Len2 = "  len2);// Write data to the filetry{FileOutputStreamout=newFileOutputStream(FILENAME);GatheringByteChannel gather =out.getChannel(); gather.write(newByteBuffer[]{bLen1, bLen2, bstream1, bstream2});out.close(); gather.close();}catch(FileNotFoundException exObj){ exObj.printStackTrace();}catch(IOException ioObj){ ioObj.printStackTrace();}}}

Java nio — filelock

Как мы знаем, Java NIO поддерживает параллелизм и многопоточность, что позволяет ему работать с несколькими потоками, работающими с несколькими файлами одновременно. Но в некоторых случаях нам требуется, чтобы наш файл не получал общий доступ ни от одного потока и не был доступен.

Для такого требования NIO снова предоставляет API, известный как FileLock, который используется для обеспечения блокировки всего файла или его части, чтобы файл или его часть не были доступны для общего доступа.

чтобы обеспечить или применить такую ​​блокировку, мы должны использовать FileChannel или AsynchronousFileChannel, который предоставляет для этой цели два метода lock () и tryLock (). Предоставляемая блокировка может быть двух типов:

• Эксклюзивная блокировка — эксклюзивная блокировка не позволяет другим программам получать перекрывающуюся блокировку любого типа.

• Общая блокировка . Общая блокировка не позволяет другим одновременно работающим программам получать перекрывающуюся эксклюзивную блокировку, но позволяет им получать перекрывающиеся общие блокировки.

Эксклюзивная блокировка — эксклюзивная блокировка не позволяет другим программам получать перекрывающуюся блокировку любого типа.

Общая блокировка . Общая блокировка не позволяет другим одновременно работающим программам получать перекрывающуюся эксклюзивную блокировку, но позволяет им получать перекрывающиеся общие блокировки.

Методы, используемые для получения блокировки над файлом —

• lock () — этот метод FileChannel или AsynchronousFileChannel получает эксклюзивную блокировку для файла, связанного с данным каналом. Типом возврата этого метода является FileLock, который далее используется для мониторинга полученной блокировки.

• lock (long position, long size, boolean shared) — этот метод снова является перегруженным методом блокировки и используется для блокировки определенной части файла.

• tryLock () — этот метод возвращает FileLock или null, если блокировка не может быть получена, и он пытается получить явно исключительную блокировку для файла этого канала.

• tryLock (long position, long size, boolean shared) — этот метод пытается получить блокировку в заданной области файла этого канала, которая может быть эксклюзивной или общего типа.

lock () — этот метод FileChannel или AsynchronousFileChannel получает эксклюзивную блокировку для файла, связанного с данным каналом. Типом возврата этого метода является FileLock, который далее используется для мониторинга полученной блокировки.

lock (long position, long size, boolean shared) — этот метод снова является перегруженным методом блокировки и используется для блокировки определенной части файла.

tryLock () — этот метод возвращает FileLock или null, если блокировка не может быть получена, и он пытается получить явно исключительную блокировку для файла этого канала.

tryLock (long position, long size, boolean shared) — этот метод пытается получить блокировку в заданной области файла этого канала, которая может быть эксклюзивной или общего типа.

Java nio — селектор

Как мы знаем, Java NIO поддерживает множественные транзакции от и до каналов и буферов. Таким образом, чтобы изучить один или несколько каналов NIO и определить, какие каналы готовы к транзакции данных, т. Е. Чтение или запись, Java NIO обеспечивает Selector.

С помощью Selector мы можем создать поток, который будет знать, какой канал готов для записи и чтения данных и может обрабатывать этот конкретный канал.

Мы можем получить экземпляр селектора, вызвав его статический метод open (). После открытия селектора мы должны зарегистрировать канал неблокирующего режима, который возвращает экземпляр SelectionKey.

SelectionKey — это набор операций, которые можно выполнить с каналом, или мы можем сказать, что мы можем узнать состояние канала с помощью клавиши выбора.

Основные операции или состояние канала, представленные клавишей выбора:

• SelectionKey.OP_CONNECT — канал, который готов к подключению к серверу.

• SelectionKey.OP_ACCEPT — канал, который готов принимать входящие соединения.

• SelectionKey.OP_READ — канал, который готов к чтению данных.

• SelectionKey.OP_WRITE — канал, который готов к записи данных.

SelectionKey.OP_CONNECT — канал, который готов к подключению к серверу.

SelectionKey.OP_ACCEPT — канал, который готов принимать входящие соединения.

SelectionKey.OP_READ — канал, который готов к чтению данных.

SelectionKey.OP_WRITE — канал, который готов к записи данных.

Ключ выбора, полученный после регистрации, имеет несколько важных методов, как указано ниже —

• attach () — этот метод используется для прикрепления объекта с помощью ключа. Основная цель присоединения объекта к каналу — это распознавание того же канала.

• attachment () — этот метод используется для сохранения прикрепленного объекта из канала.

• channel () — Этот метод используется для получения канала, для которого создается конкретный ключ.

• selector () — этот метод используется для получения селектора, для которого создан определенный ключ.

• isValid () — Этот метод возвращает погоду, ключ действителен или нет.

• isReadable () — Этот метод заявляет, что канал ключа погоды готов для чтения или нет.

• isWritable () — этот метод утверждает, что канал ключа погоды готов к записи или нет.

• isAcceptable () — Этот метод сообщает, что канал ключа погоды готов к приему входящего соединения или нет.

• isConnectable () — Этот метод проверяет, завершил ли канал этого ключа свою операцию соединения через сокет.

• isAcceptable () — Этот метод проверяет, готов ли канал этого ключа принять новое соединение с сокетом.

• InterestOps () — Этот метод получает набор интересов этого ключа.

• readyOps () — этот метод извлекает готовый набор, представляющий собой набор операций, для которых канал готов.

attach () — этот метод используется для прикрепления объекта с помощью ключа. Основная цель присоединения объекта к каналу — это распознавание того же канала.

attachment () — этот метод используется для сохранения прикрепленного объекта из канала.

channel () — Этот метод используется для получения канала, для которого создается конкретный ключ.

selector () — этот метод используется для получения селектора, для которого создан определенный ключ.

isValid () — Этот метод возвращает погоду, ключ действителен или нет.

isReadable () — Этот метод заявляет, что канал ключа погоды готов для чтения или нет.

isWritable () — этот метод утверждает, что канал ключа погоды готов к записи или нет.

isAcceptable () — Этот метод сообщает, что канал ключа погоды готов к приему входящего соединения или нет.

isConnectable () — Этот метод проверяет, завершил ли канал этого ключа свою операцию соединения через сокет.

isAcceptable () — Этот метод проверяет, готов ли канал этого ключа принять новое соединение с сокетом.

InterestOps () — Этот метод получает набор интересов этого ключа.

readyOps () — этот метод извлекает готовый набор, представляющий собой набор операций, для которых канал готов.

Мы можем выбрать канал из селектора, вызвав его статический метод select (). Метод выбора селектора перегружен как —

• select () — этот метод блокирует текущий поток, пока хотя бы один канал не будет готов к событиям, для которых он зарегистрирован.

• select (long timeout) — Этот метод делает то же самое, что и select (), за исключением того, что он блокирует поток на максимальное время ожидания в миллисекундах (параметр).

• selectNow () — этот метод вообще не блокируется. Он сразу же возвращается, когда каналы готовы.

select () — этот метод блокирует текущий поток, пока хотя бы один канал не будет готов к событиям, для которых он зарегистрирован.

select (long timeout) — Этот метод делает то же самое, что и select (), за исключением того, что он блокирует поток на максимальное время ожидания в миллисекундах (параметр).

selectNow () — этот метод вообще не блокируется. Он сразу же возвращается, когда каналы готовы.

Также для того, чтобы оставить заблокированный поток, который вызывает метод select, из экземпляра селектора можно вызвать метод wakeup (), после чего поток, ожидающий внутри select (), немедленно вернется.

Наконец, мы можем закрыть селектор, вызвав метод close (), который также делает недействительными все экземпляры SelectionKey, зарегистрированные в этом селекторе, вместе с закрытием селектора.

Java nio против io

Как мы знаем, Java NIO введен для усовершенствования традиционного API Java IO. Основными усовершенствованиями, которые делают NIO более эффективным, чем IO, являются модель потока данных канала, используемая в NIO, и использование операционной системы для обычных задач ввода-вывода.

Разницу между Java NIO и Java IO можно объяснить следующим образом:

• Как упоминалось в предыдущем посте, в буфере NIO и канально-ориентированном потоке данных для операций ввода / вывода, которые обеспечивают более быстрое выполнение и лучшую производительность по сравнению с IO. Также NIO использует операционную систему для обычных задач ввода / вывода, что снова делает ее более эффективной.

• Другой аспект различия между NIO и IO состоит в том, что этот IO использует поток данных линии потока, то есть еще один байт за раз, и полагается на преобразование объектов данных в байты и наоборот, в то время как NIO работает с блоками данных, которые являются кусками байтов.

• В Java потоковые объекты ввода / вывода являются однонаправленными, в то время как в NIO каналы являются двунаправленными, то есть канал может использоваться как для чтения, так и для записи данных.

• Потоковый поток данных в IO не позволяет перемещаться вперед и назад в данных. В случае необходимости перемещаться вперед и назад в данных, считанных из потока, необходимо сначала кэшировать их в буфере. В случае NIO мы используем ориентированный на буфер что позволяет получать доступ к данным взад и вперед без необходимости кэширования.

• NIO API также поддерживает многопоточность, так что данные могут считываться и записываться асинхронно, таким образом, чтобы при выполнении операций ввода-вывода текущий поток не блокировался. Это снова делает его более эффективным, чем обычный API ввода-вывода Java.

• Концепция многопоточности вводится с введением селекторов в Java NIO, которые позволяют прослушивать несколько каналов для событий ввода-вывода асинхронным или неблокирующим способом.

• Многопоточность в NIO делает его неблокирующим, что означает, что поток запрашивается для чтения или записи только при наличии данных, в противном случае поток можно использовать в другой задаче на время. Но это невозможно в случае обычного ввода-вывода Java, так как нет многопоточности поддерживается в нем, что делает его как блокирующий.

• NIO позволяет управлять несколькими каналами, используя только один поток, но стоимость состоит в том, что синтаксический анализ данных может быть несколько более сложным, чем при чтении данных из блокирующего потока в случае Java-ввода-вывода. Так что в случае, если требуется меньше соединений с очень высокой пропускной способностью с отправкой большого количества данных за один раз, тогда в этом случае лучше всего подойдет java IO API.

Как упоминалось в предыдущем посте, в буфере NIO и канально-ориентированном потоке данных для операций ввода / вывода, которые обеспечивают более быстрое выполнение и лучшую производительность по сравнению с IO. Также NIO использует операционную систему для обычных задач ввода / вывода, что снова делает ее более эффективной.

Другой аспект различия между NIO и IO состоит в том, что этот IO использует поток данных линии потока, то есть еще один байт за раз, и полагается на преобразование объектов данных в байты и наоборот, в то время как NIO работает с блоками данных, которые являются кусками байтов.

В Java потоковые объекты ввода / вывода являются однонаправленными, в то время как в NIO каналы являются двунаправленными, то есть канал может использоваться как для чтения, так и для записи данных.

Потоковый поток данных в IO не позволяет перемещаться вперед и назад в данных. В случае необходимости перемещаться вперед и назад в данных, считанных из потока, необходимо сначала кэшировать их в буфере. В случае NIO мы используем ориентированный на буфер что позволяет получать доступ к данным взад и вперед без необходимости кэширования.

NIO API также поддерживает многопоточность, так что данные могут считываться и записываться асинхронно, таким образом, чтобы при выполнении операций ввода-вывода текущий поток не блокировался. Это снова делает его более эффективным, чем обычный API ввода-вывода Java.

Концепция многопоточности вводится с введением селекторов в Java NIO, которые позволяют прослушивать несколько каналов для событий ввода-вывода асинхронным или неблокирующим способом.

Многопоточность в NIO делает его неблокирующим, что означает, что поток запрашивается для чтения или записи только при наличии данных, в противном случае поток можно использовать в другой задаче на время. Но это невозможно в случае обычного ввода-вывода Java, так как нет многопоточности поддерживается в нем, что делает его как блокирующий.

NIO позволяет управлять несколькими каналами, используя только один поток, но стоимость состоит в том, что синтаксический анализ данных может быть несколько более сложным, чем при чтении данных из блокирующего потока в случае Java-ввода-вывода.

Акции nio взлетели в 12 раз за год. продолжит ли расти «tesla для бедных»

Важные методы буфера

Как уже упоминалось, что Buffer действует как объект памяти, который предоставляет набор методов, которые делают более удобным работу с блоком памяти. Ниже приведены важные методы Buffer —

• allocate (intacity) — Этот метод используется для выделения нового буфера с емкостью в качестве параметра. Метод Allocate выдает исключение IllegalArgumentException в случае, если переданная емкость является отрицательным целым числом.

• read () и put () — метод чтения канала используется для записи данных из канала в буфер, а put — метод буфера, который используется для записи данных в буфер.

• flip () — Метод flip переключает режим буфера с режима записи на режим чтения. Он также устанавливает позицию обратно в 0 и устанавливает предел, в котором позиция была во время записи.

• write () и get () — метод записи канала используется для записи данных из буфера в канал, в то время как get является методом буфера, который используется для чтения данных из буфера.

• rewind () — метод перемотки используется, когда требуется перечитывание, так как он устанавливает позицию в ноль и не изменяет значение лимита.

• clear () и compact () — clear и compact оба метода используются для перехода из режима чтения в режим записи. Метод clear () устанавливает позицию в ноль и ограничивает ее до емкости, в этом методе данные в буфере не очищаются, только маркеры инициализируются повторно.

  С другой стороны, метод compact () используется, когда осталось несколько непрочитанных данных, и все же мы используем режим записи буфера, в этом случае компактный метод копирует все непрочитанные данные в начало буфера и устанавливает положение сразу после последнего непрочитанного элемента. Свойство limit все еще установлено в емкость.

• mark () и reset () — Как следует из названия, метод mark используется для пометки какой-либо конкретной позиции в буфере, в то время как сброс делает положение обратно в отмеченную позицию.

allocate (intacity) — Этот метод используется для выделения нового буфера с емкостью в качестве параметра. Метод Allocate выдает исключение IllegalArgumentException в случае, если переданная емкость является отрицательным целым числом.

read () и put () — метод чтения канала используется для записи данных из канала в буфер, а put — метод буфера, который используется для записи данных в буфер.

flip () — Метод flip переключает режим буфера с режима записи на режим чтения. Он также устанавливает позицию обратно в 0 и устанавливает предел, в котором позиция была во время записи.

write () и get () — метод записи канала используется для записи данных из буфера в канал, в то время как get является методом буфера, который используется для чтения данных из буфера.

rewind () — метод перемотки используется, когда требуется перечитывание, так как он устанавливает позицию в ноль и не изменяет значение лимита.

clear () и compact () — clear и compact оба метода используются для перехода из режима чтения в режим записи. Метод clear () устанавливает позицию в ноль и ограничивает ее до емкости, в этом методе данные в буфере не очищаются, только маркеры инициализируются повторно.

С другой стороны, метод compact () используется, когда осталось несколько непрочитанных данных, и все же мы используем режим записи буфера, в этом случае компактный метод копирует все непрочитанные данные в начало буфера и устанавливает положение сразу после последнего непрочитанного элемента. Свойство limit все еще установлено в емкость.

mark () и reset () — Как следует из названия, метод mark используется для пометки какой-либо конкретной позиции в буфере, в то время как сброс делает положение обратно в отмеченную позицию.

Важные методы сокета канала

• bind (SocketAddress local) — этот метод используется для привязки канала сокета к локальному адресу, который предоставляется в качестве параметра для этого метода.

• accept () — этот метод используется для принятия соединения с сокетом этого канала.

• connect (SocketAddress remote) — этот метод используется для подключения сокета к удаленному адресу.

• finishConnect () — Этот метод используется для завершения процесса подключения канала сокета.

• getRemoteAddress () — Этот метод возвращает адрес удаленного местоположения, к которому подключен сокет канала.

• isConnected () — как уже упоминалось, этот метод возвращает статус подключения сокетного канала, т. е. подключен он или нет.

• open () — метод Open используется для открытия канала сокета без указанного адреса. Этот удобный метод работает так, как если бы он вызывал метод open (), вызывал метод connect для получающегося канала сокета сервера, передавал его удаленно, а затем возвращал канал.

• read (ByteBuffer dst) — этот метод используется для чтения данных из данного буфера через канал сокета.

• setOption (SocketOption <T> name, T value) — этот метод устанавливает значение параметра сокета.

• socket () — этот метод извлекает сокет сервера, связанный с этим каналом.

• validOps () — этот метод возвращает набор операций, идентифицирующий поддерживаемые операции этого канала. Каналы сервера сокетов поддерживают только принятие новых соединений, поэтому этот метод возвращает SelectionKey.OP_ACCEPT.

bind (SocketAddress local) — этот метод используется для привязки канала сокета к локальному адресу, который предоставляется в качестве параметра для этого метода.

accept () — этот метод используется для принятия соединения с сокетом этого канала.

connect (SocketAddress remote) — этот метод используется для подключения сокета к удаленному адресу.

finishConnect () — Этот метод используется для завершения процесса подключения канала сокета.

getRemoteAddress () — Этот метод возвращает адрес удаленного местоположения, к которому подключен сокет канала.

isConnected () — как уже упоминалось, этот метод возвращает статус подключения сокетного канала, т. е. подключен он или нет.

open () — метод Open используется для открытия канала сокета без указанного адреса. Этот удобный метод работает так, как если бы он вызывал метод open (), вызывал метод connect для получающегося канала сокета сервера, передавал его удаленно, а затем возвращал канал.

read (ByteBuffer dst) — этот метод используется для чтения данных из данного буфера через канал сокета.

setOption (SocketOption <T> name, T value) — этот метод устанавливает значение параметра сокета.

socket () — этот метод извлекает сокет сервера, связанный с этим каналом.

validOps () — этот метод возвращает набор операций, идентифицирующий поддерживаемые операции этого канала. Каналы сервера сокетов поддерживают только принятие новых соединений, поэтому этот метод возвращает SelectionKey.OP_ACCEPT.

Клиент: datagramchannelclient.java

import java.io.IOException;import java.net.InetSocketAddress;import java.net.SocketAddress;import java.nio.ByteBuffer;import java.nio.channels.DatagramChannel;publicclassDatagramChannelClient{publicstaticvoid main(String[] args)throwsIOException{DatagramChannel client =null; client =DatagramChannel.open(); client.bind(null);String msg ="Hello World!";ByteBuffer buffer =ByteBuffer.wrap(msg.getBytes());InetSocketAddress serverAddress =newInetSocketAddress("localhost",8989); client.send(buffer, serverAddress); buffer.clear(); client.receive(buffer); buffer.flip(); client.close();}}

Клиент: socketchannelclient.java

import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.channels.FileChannel;import java.nio.channels.ServerSocketChannel;import java.nio.channels.SocketChannel;import java.nio.file.Path;import java.nio.file.Paths;import java.nio.file.StandardOpenOption;import java.util.EnumSet;publicclassSocketChannelClient{publicstaticvoid main(String[] args)throwsIOException{ServerSocketChannel serverSocket =null;SocketChannel client =null; serverSocket =ServerSocketChannel.open(); serverSocket.socket().bind(newInetSocketAddress(9000)); client = serverSocket.accept();System.out.println("Connection Set: "  client.getRemoteAddress());Path path =Paths.get("C:/Test/temp1.txt");FileChannel fileChannel =FileChannel.open(path,EnumSet.of(StandardOpenOption.CREATE,StandardOpenOption.TRUNCATE_EXISTING,StandardOpenOption.WRITE));ByteBuffer buffer =ByteBuffer.allocate(1024);while(client.read(buffer)>0){ buffer.flip(); fileChannel.write(buffer); buffer.clear();} fileChannel.close();System.out.println("File Received"); client.close();}}

Методы класса filelock

• acquBy () — этот метод возвращает канал, для которого была получена блокировка файла.

• position () — этот метод возвращает позицию в файле первого байта заблокированной области. Блокированная область не должна содержаться внутри или даже перекрывать фактический базовый файл, поэтому значение, возвращаемое этим методом, может превышать текущий размер.

• size () — этот метод возвращает размер заблокированной области в байтах. Блокированная область не должна содержаться внутри или даже перекрывать фактический базовый файл, поэтому значение, возвращаемое этим методом, может превышать текущий размер файла.

• isShared () — Этот метод используется для определения того, является ли блокировка общей или нет.

• overlaps (длинная позиция, длинный размер) — этот метод сообщает, перекрывает ли эта блокировка заданный диапазон блокировки.

• isValid () — этот метод сообщает, действительна ли полученная блокировка. Объект блокировки остается действительным до тех пор, пока он не будет освобожден или соответствующий канал файла не будет закрыт, в зависимости от того, что произойдет раньше.

• release () — Освобождает полученную блокировку. Если объект блокировки действителен, то вызов этого метода освобождает блокировку и делает объект недействительным. Если этот объект блокировки недействителен, то вызов этого метода не имеет никакого эффекта.

• close () — этот метод вызывает метод release (). Он был добавлен в класс, чтобы его можно было использовать вместе с блочной конструкцией автоматического управления ресурсами.

acquBy () — этот метод возвращает канал, для которого была получена блокировка файла.

position () — этот метод возвращает позицию в файле первого байта заблокированной области. Блокированная область не должна содержаться внутри или даже перекрывать фактический базовый файл, поэтому значение, возвращаемое этим методом, может превышать текущий размер.

size () — этот метод возвращает размер заблокированной области в байтах. Блокированная область не должна содержаться внутри или даже перекрывать фактический базовый файл, поэтому значение, возвращаемое этим методом, может превышать текущий размер файла.

isShared () — Этот метод используется для определения того, является ли блокировка общей или нет.

overlaps (длинная позиция, длинный размер) — этот метод сообщает, перекрывает ли эта блокировка заданный диапазон блокировки.

isValid () — этот метод сообщает, действительна ли полученная блокировка. Объект блокировки остается действительным до тех пор, пока он не будет освобожден или соответствующий канал файла не будет закрыт, в зависимости от того, что произойдет раньше.

release () — Освобождает полученную блокировку. Если объект блокировки действителен, то вызов этого метода освобождает блокировку и делает объект недействительным. Если этот объект блокировки недействителен, то вызов этого метода не имеет никакого эффекта.

close () — этот метод вызывает метод release (). Он был добавлен в класс, чтобы его можно было использовать вместе с блочной конструкцией автоматического управления ресурсами.

Пример

В следующем примере показано, как использовать объект Future и выполнять асинхронные задачи.

package com.java.nio;import java.io.BufferedReader;import java.io.FileReader;import java.io.IOException;import java.nio.ByteBuffer;import java.nio.channels.AsynchronousFileChannel;import java.nio.file.Path;import java.nio.file.Paths;import java.nio.file.StandardOpenOption;import java.util.concurrent.ExecutionException;import java.util.concurrent.Future;publicclassFutureObject{publicstaticvoid main(String[] args)throwsException{ readFile();}privatestaticvoid readFile()throwsIOException,InterruptedException,ExecutionException{String filePath ="D:fileCopy.txt"; printFileContents(filePath);Path path =Paths.get(filePath);AsynchronousFileChannel channel =AsynchronousFileChannel.open(path,StandardOpenOption.READ);ByteBuffer buffer =ByteBuffer.allocate(400);Future<Integer> result = channel.read(buffer,0);// position = 0while(! result.isDone()){System.out.println("Task of reading file is in progress asynchronously.");}System.out.println("Reading done: "  result.isDone());System.out.println("Bytes read from file: "  result.get()); buffer.flip();System.out.print("Buffer contents: ");while(buffer.hasRemaining()){System.out.print((char) buffer.get());}System.out.println(" "); buffer.clear(); channel.close();}privatestaticvoid printFileContents(String path)throwsIOException{FileReader fr =newFileReader(path);BufferedReader br =newBufferedReader(fr);String textRead = br.readLine();System.out.println("File contents: ");while(textRead !=null){System.out.println(" "  textRead); textRead = br.readLine();} fr.close(); br.close();}}

Пример для демонстрации блокировки файла.

В следующем примере создайте блокировку для файла и запишите в него содержимое

package com.java.nio;import java.io.IOException;import java.nio.ByteBuffer;import java.nio.channels.FileChannel;import java.nio.channels.FileLock;import java.nio.file.Path;import java.nio.file.Paths;import java.nio.file.StandardOpenOption;publicclassFileLockExample{publicstaticvoid main(String[] args)throwsIOException{String input ="Demo text to be written in locked mode.";System.out.println("Input string to the test file is: "  input);ByteBuffer buf =ByteBuffer.wrap(input.getBytes());String fp ="D:file.txt";Path pt =Paths.get(fp);FileChannel channel =FileChannel.open(pt,StandardOpenOption.WRITE,StandardOpenOption.APPEND); channel.position(channel.size()-1);// position of a cursor at the end of file FileLocklock= channel.lock();System.out.println("The Lock is shared: " lock.isShared()); channel.write(buf); channel.close();// Releases the Lock System.out.println("Content Writing is complete. Therefore close the channel and release the lock.");PrintFileCreated.print(fp);}}

Сервер: datagramchannelserver.java

import java.io.IOException;import java.net.InetSocketAddress;import java.net.SocketAddress;import java.nio.ByteBuffer;import java.nio.channels.DatagramChannel;publicclassDatagramChannelServer{publicstaticvoid main(String[] args)throwsIOException{DatagramChannel server =DatagramChannel.open();InetSocketAddress iAdd =newInetSocketAddress("localhost",8989); server.bind(iAdd);System.out.println("Server Started: "  iAdd);ByteBuffer buffer =ByteBuffer.allocate(1024);//receive buffer from client.SocketAddress remoteAdd = server.receive(buffer);//change mode of buffer buffer.flip();int limits = buffer.limit();byte bytes[]=newbyte[limits]; buffer.get(bytes,0, limits);String msg =newString(bytes);System.out.println("Client at "  remoteAdd  " sent: "  msg); server.send(buffer,remoteAdd); server.close();}}

Сервер: socketchannelserver.java

import java.io.IOException;import java.net.InetSocketAddress;import java.net.SocketAddress;import java.nio.ByteBuffer;import java.nio.channels.FileChannel;import java.nio.channels.SocketChannel;import java.nio.file.Path;import java.nio.file.Paths;publicclassSocketChannelServer{publicstaticvoid main(String[] args)throwsIOException{SocketChannel server =SocketChannel.open();SocketAddress socketAddr =newInetSocketAddress("localhost",9000); server.connect(socketAddr);Path path =Paths.get("C:/Test/temp.txt");FileChannel fileChannel =FileChannel.open(path);ByteBuffer buffer =ByteBuffer.allocate(1024);while(fileChannel.read(buffer)>0){ buffer.flip(); server.write(buffer); buffer.clear();} fileChannel.close();System.out.println("File Sent"); server.close();}}