Java Nioのセレクターにチャネルを登録する方法は？

ちょっと、そこ！ NIOのサプライヤーとして、私はJava Nioをかなり扱ってきましたが、セレクターにチャネルを登録する方法を把握することがどれほど混乱するかを知っています。だから、私はこのプロセスをあなたにとって少し明確にするために自分の知識と経験を共有すると思いました。

まず、Java Nioが何であるかについてすぐに話しましょう。 Java NIO（新しい入出力）は、Java 1.4で導入された、高いパフォーマンス、非ブロックI/O APIです。従来のJava I/Oと比較して、I/O操作の処理方法を提供します。 Java Nioの重要なコンポーネントの1つはセレクターです。セレクターは、読み取りや執筆の準備ができているチャネルなど、I/Oイベントの複数のSefferAbleChannelsをチェックできるオブジェクトです。これにより、単一のスレッドを使用して複数のチャネルを管理できます。これは非常に効率的です。

次に、メイントピックに：セレクターでチャネルを登録します。このプロセスにはいくつかのステップが含まれ、私はあなたのためにそれらを分解します。

ステップ1：セレクターを作成します

最初に行う必要があるのは、セレクターオブジェクトを作成することです。これは非常に簡単です。あなたはただ電話します開ける（）のメソッドセレクタクラス。これがコードです：

java.nio.channels.selectorをインポートします。 java.io.ioexceptionをインポートします。 Public Class ChannelRegistrationExample {public static void main（string [] args）{try {selector selector = selector.open（）; system.out.println（ "selector created：" + selector）; } catch（ioexception e）{e.printstacktrace（）; }}}

このコードでは、単に新しいものを作成していますセレクタ実例。作成中にシステムのように問題がある場合 - レベルエラー、ioException捕まって印刷されます。

ステップ2：selectablechannelを作成します

次に、aを作成する必要がありますseferablechannel。さまざまな種類がありますseferablechannelJava nioなどSocketchannel、Serversocketchannel、 そしてDatagramChannel。この例のために、aを作成しましょうSocketchannel。

java.nio.channels.socketchannelをインポートします。 java.io.ioexceptionをインポートします。 Public Class ChannelRegistrationExample {public static void main（string [] args）{try {selector selector = selector.open（）; socketchannel socketchannel = socketchannel.open（）; socketchannel.configureblocking（false）; System.out.println（ "Socketchannel created：" + socketchannel）; } catch（ioexception e）{e.printstacktrace（）; }}}

この更新されたコードでは、aを作成しますSocketchannel非ブロッキングモードに設定します。これは、非ブロッキングチャネルのみがで登録できるため、重要ですセレクタ。

ステップ3：セレクターにチャネルを登録します

今、主要な部分が登場します。登録しますseferablechannelでセレクタを使用して登録する（）方法。この方法では、次の2つのパラメーターが必要ですセレクタと利息セットこれは、興味のあるI/O操作の種類を示しています。

関心セットは少しです - マスク、そしてあなたは次のような定数を使用できますselectionkey.op_read、selectionkey.op_write、selectionkey.op_connect、 そしてselectionkey.op_accept。

java.nio.channels.socketchannelをインポートします。 java.nio.channels.selectorをインポートします。 java.nio.channels.selectionKeyをインポートします。 java.io.ioexceptionをインポートします。 Public Class ChannelRegistrationExample {public static void main（string [] args）{try {selector selector = selector.open（）; socketchannel socketchannel = socketchannel.open（）; socketchannel.configureblocking（false）; selectionkey key = socketchannel.register（selector、selectionkey.op_connect）; system.out.println（ "selector。selectionkey：" + key）に登録されたチャネル} catch（ioexception e）{e.printstacktrace（）; }}}

このコードでは、登録していますSocketchannelでセレクタそして、私たちの関心を表明しますat_connect手術。登録する（）メソッドはaを返しますSelectionKeyこれは、セレクターとのチャネルの登録を表します。これを使用できますSelectionKey後でチャネルのステータスを確認し、他の操作を実行します。

登録されたチャネルを操作します

チャネルを登録したら、を使用できますセレクタ登録されたチャネルのいずれかが興味のある操作の準備ができているかどうかを確認するには。select（）のメソッドセレクタ。

java.nio.channels.socketchannelをインポートします。 java.nio.channels.selectorをインポートします。 java.nio.channels.selectionKeyをインポートします。 java.io.ioexceptionをインポートします。 java.util.iteratorをインポートします。 java.util.setをインポートします。 Public Class ChannelRegistrationExample {public static void main（string [] args）{try {selector selector = selector.open（）; socketchannel socketchannel = socketchannel.open（）; socketchannel.configureblocking（false）; selectionkey key = socketchannel.register（selector、selectionkey.op_connect）; system.out.println（ "selector。selectionkey：" + key）に登録されたチャネルwhile（true）{int readychannels = selector.select（）; if（readychannels == 0）継続; set <selectionKey> selectedKeys = selector.selectedKeys（）; iterator <selectionKey> keyiterator = selectedKeys.iterator（）; while（keyiterator.hasnext（））{selectionkey selectionkey = keyiterator.next（）; if（selectionkey.isconnectable（））{//ハンドルコネクトイベントSocketchannel Channel =（Socketchannel）SelectionKey.Channel（）; if（Channel.isconnectionPending（））{channel.finishconnect（）; }} keyiterator.remove（）; }}} catch（ioexception e）{e.printstacktrace（）; }}}

このコードでは、aを使用していますその間ループが継続的にチャネルの準備ができているかどうかを継続的に確認します。チャネルの準備ができたら、繰り返しますSelectedKeys適切なイベントを設定して処理します。この場合、私たちは処理していますat_connectイベント。

これが私たちのNIOに関連するビジネスにとって重要な理由

NIOサプライヤーとしての私たちのビジネスでは、効率的なI/O処理が重要です。 I/OをブロックしていないJava nioセレクタメカニズムにより、スレッドが少ない複数の接続とI/O操作を管理できます。これにより、リソースの消費が削減されるだけでなく、アプリケーションの全体的なパフォーマンスも向上します。

たとえば、私たちの場合のように、複数のクライアントと通信するサーバーを開発している場合新しいnio es6、2025 NIO EC7、 または2025ナインES7関連サービス、Java Nioは、システムを過負荷せずに多数の同時接続を処理するのに役立ちます。

結論と行動への呼びかけ

このブログ投稿が、Java Nioのセレクターにチャネルを登録する方法をよく理解してくれることを願っています。最初は少し複雑に思えるかもしれませんが、一度それを手に入れると、それはあなたのプログラミングアーセナルの強力なツールです。

NIOに関連する製品またはサービスの市場にいて、ここで説明したような効率的なI/Oハンドリングを利用したい場合は、おしゃべりしたいと思います。新しいアプリケーションを構築する場合でも、既存のアプリケーションを最適化しようとしている場合でも、当社の専門家チームは最良のソリューションを提供できます。調達の議論を開始するために私たちに連絡し、あなたのニーズを満たすために私たちがどのように協力できるかを見てください。

参照

• Ron Hitchensによる「Java nio」
• NIOおよびセレクターに関するOracle Javaドキュメント