Как да регистрирам канал с селектор в Java Nio?

Ей там! Като доставчик на NIO доста се занимавах с Java Nio и знам колко объркващо може да бъде да разбера как да регистрирате канал с селектор. И така, реших, че ще споделя моите знания и опит, за да направя този процес малко по -ясен за вас.

Първо, нека бързо да поговорим за това какво е Java Nio. Java Nio (нов вход/изход) е висока производителност, не -блокиращ I/O API, въведен в Java 1.4. Той предлага различен начин за работа с I/O операции в сравнение с традиционния Java I/O. Един от ключовите компоненти на Java Nio е селекторът. Селекторът е обект, който може да провери множество SelectAbleChannels за I/O събитие, като канал е готов за четене или писане. По този начин можете да управлявате няколко канала, като използвате една нишка, която е супер ефективна.

Сега по основната тема: Регистриране на канал с селектор. Процесът включва няколко стъпки и ще ги разбия за вас.

Стъпка 1: Създайте селектор

Първото нещо, което трябва да направите, е да създадете обект за селектор. Това е доста просто. Просто се обаждате наOpen ()метод наСелекторклас. Ето кода:

import java.nio.channels.selector; импортиране java.io.ioexception; Public Class ChannelRegistrationExample {public static void main (string [] args) {опитайте {selector selector = selector.open (); System.out.println ("Създаден селектор:" + селектор); } улов (ioexception e) {e.printstacktrace (); }}}

В този код ние просто създаваме новСелекторекземпляр. Ако има проблем по време на създаването, като система за системно ниво,Ioexceptionще бъде хванат и отпечатан.

Стъпка 2: Създайте SelectAbleChannel

След това трябва да създадете aSelectablechannel. Има различни видовеSelectablechannelв Java nio, катоSocketchannel,ServersocketchannelиDatagramChannel. В името на този пример, нека създадем aSocketchannel.

import java.nio.channels.socketchannel; импортиране java.io.ioexception; Public Class ChannelRegistrationExample {public static void main (string [] args) {опитайте {selector selector = selector.open (); Socketchannel Socketchannel = Socketchannel.open (); socketchannel.configureblocking (false); System.out.println ("Socketchannel създаден:" + Socketchannel); } улов (ioexception e) {e.printstacktrace (); }}}

В този актуализиран код създаваме aSocketchannelи го настроите на не -блокиращ режим. Това е от решаващо значение, тъй като само блокиращите канали могат да бъдат регистрирани с aСелектор.

Стъпка 3: Регистрирайте канала със селектора

Сега идва основната част. Вие регистриратеSelectablechannelсСелекторИзползване наРегистрация ()метод. Този метод взема два параметъра: TheСелекторинабор от лихвикоето показва видовете I/O операции, от които се интересувате.

Интересният набор е малко - маска и можете да използвате константи катоSelectionKey.op_read,SelectionKey.op_write,SelectionKey.op_connectиSelectionKey.op_accept.

import java.nio.channels.socketchannel; import java.nio.channels.selector; import java.nio.channels.selectionKey; импортиране java.io.ioexception; Public Class ChannelRegistrationExample {public static void main (string [] args) {опитайте {selector selector = selector.open (); Socketchannel Socketchannel = Socketchannel.open (); socketchannel.configureblocking (false); SelectionKey key = socketchannel.register (selector, selectionKey.op_connect); System.out.println ("Канал, регистриран с Selector. SelectionKey:" + ключ); } улов (ioexception e) {e.printstacktrace (); }}}

В този код регистрирамеSocketchannelсСелектори изразяваме интереса си къмAt_connectработа. TheРегистрация ()Метод връща aSelectionKeyкоето представлява регистрацията на канала с селектора. Можете да използвате товаSelectionKeyПо -късно да проверите състоянието на канала и да извършите други операции.

Работа с регистрираните канали

След като регистрирате канала, можете да използватеСелекторЗа да проверите дали някой от регистрираните канали е готов за операциите, от които се интересувате. Правите това, като се обадите наSelect ()метод наСелектор.

import java.nio.channels.socketchannel; import java.nio.channels.selector; import java.nio.channels.selectionKey; импортиране java.io.ioexception; импортиране java.util.iterator; импортиране java.util.set; Public Class ChannelRegistrationExample {public static void main (string [] args) {опитайте {selector selector = selector.open (); Socketchannel Socketchannel = Socketchannel.open (); socketchannel.configureblocking (false); SelectionKey key = socketchannel.register (selector, selectionKey.op_connect); System.out.println ("Канал, регистриран с Selector. SelectionKey:" + ключ); докато (true) {int readyChannels = selector.select (); ако (readyChannels == 0) продължете; Set <selectionKey> selectedKeys = selector.selectedkeys (); Итератор <selectionKey> keyiterator = selectedKeys.iterator (); докато (keyiterator.hasnext ()) {selectionKey selectionKey = keyiterator.next (); if (selectionKey.Isconnectable ()) {// Handle Connect Event Socketchannel Channel = (Socketchannel) selectionKey.Channel (); if (channe.isconnectionPending ()) {Channel.finishConnect (); }} keyiterator.remove (); }}} улов (ioexception e) {e.printstacktrace (); }}}

В този код използваме aдокатоцикъл, за да проверите непрекъснато дали някой канали са готови. Когато каналът е готов, ние повтаряме презSelectedKeysнастройте и се справят с подходящото събитие. В този случай ние се справяме сAt_connectсъбитие.

Защо това е важно за нашия бизнес, свързан с NIO

В нашия бизнес като доставчик на NIO ефективното управление на I/O е от решаващо значение. Java nio с не -блокирането на I/O иСелекторМеханизмът ни позволява да управляваме множество връзки и I/O операции с по -малко нишки. Това не само намалява потреблението на ресурси, но също така подобрява цялостната ефективност на нашите приложения.

Например, ако разработваме сървър, който комуникира с множество клиенти, като в случая на нашияNew Nio ES6,2025 NIO EC7, или2025 Nine ES7Свързани услуги, Java Nio може да ни помогне да се справим с голям брой едновременни връзки, без да претоварваме системата.

Заключение и призив за действие

Надявам се тази публикация в блога да ви даде добро разбиране как да регистрирате канал с селектор в Java Nio. В началото може да изглежда малко сложно, но след като го закачите, това е мощен инструмент във вашия арсенал за програмиране.

Ако сте на пазара за продукти или услуги, свързани с NIO и искате да се възползвате от ефективното управление на I/O като този, който обсъдихме тук, ще се радваме да си поговорим с вас. Независимо дали изграждате ново приложение или търсите да оптимизирате съществуващ, нашият екип от експерти може да ви предостави най -добрите решения. Обърнете се към нас, за да започнем дискусия за обществени поръчки и да видите как можем да работим заедно, за да отговорим на вашите нужди.

ЛИТЕРАТУРА

• "Java nio" от Рон Хитсс
• Документация на Oracle Java за NIO и селекционери