Jak zaimplementować nieblokujące wejścia/wyjścia przy użyciu Java NIO?

Jako dostawca specjalizujący się w rozwiązaniach NIO (nieblokujących wejść/wyjść) na własne oczy widziałem transformacyjną moc Java NIO w tworzeniu nowoczesnego oprogramowania. W tym poście na blogu podzielę się spostrzeżeniami na temat implementacji nieblokujących wejść/wyjść przy użyciu Java NIO, czerpiąc z moich doświadczeń w tej dziedzinie.

Zrozumienie podstaw Java NIO

Java NIO, wprowadzony w Javie 1.4, oferuje nowy sposób wykonywania operacji we/wy w porównaniu z tradycyjnym Java I/O. Podstawowe komponenty Java NIO obejmują kanały, bufory i selektory. Kanały są podobne do strumieni w tradycyjnych wejściach/wyjściach, ale są dwukierunkowe i mogą wykonywać operacje nieblokujące. Bufory służą do przechowywania danych podczas operacji we/wy, pełniąc rolę kontenera do przesyłania danych pomiędzy kanałami a aplikacją. Selektory umożliwiają pojedynczemu wątkowi zarządzanie wieloma kanałami, umożliwiając wydajne, nieblokujące wejścia/wyjścia.

Bufory w Javie NIO

Bufory są sercem Java NIO. Zasadniczo są to kontenery na dane o stałej pojemności. Dostępne są różne typy buforów, takie jak ByteBuffer, CharBuffer, IntBuffer itp., w zależności od typu danych, które mogą przechowywać.

Weźmy prosty przykład użycia ByteBuffer:

importuj java.nio.ByteBuffer; public class BufferExample { public static void main(String[] args) { Buffer ByteBuffer = ByteBuffer.allocate(1024); bufor.put("Witam, Java NIO!".getBytes()); bufor.flip(); while (buffer.hasRemaining()) { System.out.print((char) bufor.get()); } } }

W tym przykładzie najpierw przydzielamy ByteBuffer o pojemności 1024 bajtów. Następnie umieszczamy pewne dane w buforze i wywołujemy funkcjętrzepnięcie()metoda przygotowania bufora do odczytu. Na koniec czytamy dane z bufora, aż nie będzie już więcej danych.

Kanały w Javie NIO

Kanały służą do odczytywania i zapisywania danych w źródle lub miejscu docelowym. W Java NIO istnieje kilka typów kanałów, w tym FileChannel, SocketChannel, ServerSocketChannel i DatagramChannel.

Kanał pliku

FileChannel służy do operacji we/wy na plikach. Oto przykład odczytu danych z pliku za pomocą FileChannel:

importuj java.io.FileInputStream; importuj wyjątek java.io.IO; importuj java.nio.ByteBuffer; importuj java.nio.channels.FileChannel; klasa publiczna FileChannelExample { public static void main(String[] args) { try (FileInputStream fis = new FileInputStream("example.txt"); FileChannel kanał = fis.getChannel()) { ByteBuffer bufor = ByteBuffer.allocate(1024); int bytesRead = kanał.odczyt(bufor); while (bytesRead != -1) { bufor.flip(); while (buffer.hasRemaining()) { System.out.print((char) bufor.get()); } bufor.clear(); bytesRead = kanał.odczyt(bufor); } } catch (IOException e) { e.printStackTrace(); } } }

W tym przykładzie tworzymy FileInputStream i uzyskujemy jego FileChannel. Następnie przydzielamy ByteBuffer i wczytujemy dane z kanału do bufora. Odwracamy bufor, aby przygotować się do odczytu i wydrukować dane. Po odczycie czyścimy bufor i kontynuujemy czytanie do momentu wyczerpania się danych.

SocketChannel i ServerSocketChannel

SocketChannel i ServerSocketChannel są używane do wejścia/wyjścia sieci. Oto prosty przykład nieblokującego serwera korzystającego z ServerSocketChannel i SocketChannel:

importuj wyjątek java.io.IO; importuj adres java.net.InetSocket; importuj java.nio.ByteBuffer; importuj java.nio.channels.SelectionKey; importuj java.nio.channels.Selector; importuj java.nio.channels.ServerSocketChannel; importuj java.nio.channels.SocketChannel; importuj java.util.Iterator; importuj java.util.Set; klasa publiczna NonBlockingServer { public static void main(String[] args) { try (ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); Selektor selektora = Selector.open()) { serverSocketChannel.socket().bind(new InetSocketAddress(8080)); serwerSocketChannel.configureBlocking(false); serverSocketChannel.register(selektor, SelectionKey.OP_ACCEPT); while (true) { int gotoweKanały = selektor.select(); if (readyChannels == 0) kontynuuj; Set<SelectionKey> wybraneKeys = selektor.selectedKeys(); Iterator<SelectionKey> keyIterator = wybraneKeys.iterator(); while (keyIterator.hasNext()) { Klucz wyboru = keyIterator.next(); if (key.isAcceptable()) { ServerSocketChannel serwerChannel = (ServerSocketChannel) key.channel(); SocketChannel SocketChannel = serwerKanał.accept(); gniazdoChannel.configureBlocking(false); gniazdoChannel.register(selektor, SelectionKey.OP_READ); } else if (key.isReadable()) { SocketChannel SocketChannel = (SocketChannel) key.channel(); Bufor ByteBuffer = ByteBuffer.allocate(1024); int bytesRead = SocketChannel.read(bufor); if (bytesRead > 0) { bufor.flip(); while (buffer.hasRemaining()) { System.out.print((char) bufor.get()); } } } keyIterator.remove(); } } } catch (IOException e) { e.printStackTrace(); } } }

W tym przykładzie tworzymy ServerSocketChannel i konfigurujemy go tak, aby nie blokował. Rejestrujemy kanał w Selektorze dlaOP_AKCEPTUJĘdziałanie. W pętli głównej za pomocą Selektora czekamy na gotowe kanały. Gdy kanał jest gotowy, sprawdzamy rodzaj operacji (akceptacja lub odczyt) i wykonujemy odpowiednią akcję.

Selektory w Javie NIO

Selektory są kluczem do osiągnięcia nieblokujących wejść/wyjść w Java NIO. Selektor umożliwia pojedynczemu wątkowi zarządzanie wieloma kanałami. Monitoruje kanały pod kątem różnych zdarzeń, takich jak odczyt, zapis, połączenie i akceptacja.

W poprzednim przykładzie serwera nieblokującego użyliśmy selektora do zarządzania wieloma kanałami SocketChannel. Thewybierać()metodę bloków Selektora, dopóki przynajmniej jeden kanał nie będzie gotowy do operacji. Gdy kanał jest już gotowy, możemy uzyskać odpowiedni SelectionKey i wykonać odpowiednią operację.

Zastosowania w świecie rzeczywistym Java NIO

Java NIO jest szeroko stosowana w różnych rzeczywistych aplikacjach, szczególnie w wysokowydajnych serwerach sieciowych i aplikacjach wymagających wydajnych operacji we/wy. Na przykład przy opracowywaniu nowych pojazdów napędzanych energią, takich jak2025 NIO ES8,2025 NIO ES7, INowy NIO ET7, Java NIO może być używany do przesyłania danych pomiędzy różnymi komponentami pojazdu, takimi jak system zarządzania akumulatorem, system sterowania silnikiem i pokładowy system informacyjno-rozrywkowy.

Wniosek

Wdrożenie nieblokujących wejść/wyjść przy użyciu Java NIO może znacznie poprawić wydajność i skalowalność aplikacji. Rozumiejąc podstawowe komponenty Java NIO, takie jak bufory, kanały i selektory, można tworzyć wydajne i wydajne aplikacje we/wy.

Jeśli jesteś zainteresowany wdrożeniem Java NIO w swoich projektach lub potrzebujesz więcej informacji na temat naszych rozwiązań NIO, skontaktuj się z nami w celu zamówienia i dalszych dyskusji.

Referencje

• „Java NIO” Rona Hitchensa
• Dokumentacja Java dla pakietu NIO