ホームページ Java &#&チュートリアル Java I/O ストリームの NIO API はどのように機能しますか?

Java I/O ストリームの NIO API はどのように機能しますか?

Apr 13, 2024 pm 09:36 PM
java nio

Java NIO API は、I/O 操作を処理するための高度な API であり、従来のブロッキング I/O よりも優れたパフォーマンスとスケーラビリティを提供します。 バッファ: アプリケーションとオペレーティング システムの間でデータを転送するためのメモリ領域。チャネル: アプリケーションと I/O デバイス間の接続を表す抽象的な概念。セレクター: 複数のチャネルをポーリングして、どのチャネルが読み取りおよび書き込みの準備ができているかを判断するために使用されます。

Java I/O流中的NIO API是如何工作的?

#Java I/O ストリームの NIO API: 徹底した分析

はじめに

NIO (ノンブロッキング I/O) API は、I/O 操作を処理するための Java の高レベル API です。特に大量の接続やデータを処理する場合に、従来のブロッキング I/O よりも優れたパフォーマンスとスケーラビリティを提供します。

NIO API のコンポーネント

NIO API は次の主要コンポーネントで構成されます:

  • バッファ:A メモリアプリケーションと基盤となるオペレーティング システムの間でデータを転送するために使用される領域。
  • チャネル: アプリケーションと I/O デバイス間の接続を表す抽象的な概念。
  • セレクター: 複数のチャネルをポーリングして、どのチャネルが読み取りおよび書き込みの準備ができているかを判断するために使用されます。

NIO の仕組み

NIO の操作はイベント ループに基づいています:

    バッファとチャネルの作成、初期化選択デバイス。
  1. 関心のあるイベントをセレクターに登録します (読み取り可能または書き込み可能など)。
  2. セレクターは登録されたチャンネルをポーリングして、どのチャンネルがデータを処理する準備ができているかを判断します。
  3. セレクターは、1 つ以上のチャネルの準備ができたときにアプリケーション スレッドを起動します。
  4. アプリケーションはデータの読み取りまたは書き込みを行った後、セレクター上のチャネルの登録を解除します。

実際的なケース

NIO API を使用して単純なサーバーを作成する例を次に示します。

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.ArrayList;
import java.util.List;

public class NIOServer {

    private static final int PORT = 8080;
    private static List<SocketChannel> connectedSockets = new ArrayList<>();

    public static void main(String[] args) throws IOException {

        // 创建服务器套接字通道
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();

        // 将服务器通道绑定到端口
        serverSocketChannel.bind(new InetSocketAddress(PORT));

        // 设置非阻塞模式
        serverSocketChannel.configureBlocking(false);

        // 获取选择器
        Selector selector = Selector.open();

        // 将服务器通道注册到选择器,感兴趣的可接受事件
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

        // 事件循环
        while (true) {

            // 阻塞,直到至少有一个通道准备好
            int readyChannels = selector.select();

            // 如果没有准备好的通道,则继续
            if (readyChannels == 0) {
                continue;
            }

            // 处理准备好的通道
            for (SelectionKey key : selector.selectedKeys()) {

                // 可接受事件
                if (key.isAcceptable()) {

                    // 接受传入的连接
                    SocketChannel socketChannel = serverSocketChannel.accept();

                    // 设置非阻塞模式
                    socketChannel.configureBlocking(false);

                    // 将套接字通道注册到选择器,感兴趣的可读事件
                    socketChannel.register(selector, SelectionKey.OP_READ);

                    // 添加到已连接套接字列表
                    connectedSockets.add(socketChannel);
                }

                // 可读事件
                else if (key.isReadable()) {

                    SocketChannel socketChannel = (SocketChannel) key.channel();

                    // 读取数据
                    ByteBuffer buffer = ByteBuffer.allocate(1024);
                    int bytesRead = socketChannel.read(buffer);

                    // 如果读取到EOF,则关闭套接字
                    if (bytesRead == -1) {
                        socketChannel.close();
                        connectedSockets.remove(socketChannel);
                    }

                    // 处理读取到的数据
                    // ...

                }
            }

            // 清除已处理的键
            selector.selectedKeys().clear();
        }
    }
}
ログイン後にコピー

この例では、サーバーは 8080 ポートでリッスンし、クライアント接続を受け入れます。クライアントが接続すると、接続されたソケットのリストに追加されます。サーバーはセレクターを使用して接続されたソケットをポーリングし、どのソケットがデータの読み取りと書き込みの準備ができているかを判断します。

以上がJava I/O ストリームの NIO API はどのように機能しますか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

AI Hentai Generator

AI Hentai Generator

AIヘンタイを無料で生成します。

ホットツール

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

SublimeText3 中国語版

SublimeText3 中国語版

中国語版、とても使いやすい

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

ドリームウィーバー CS6

ドリームウィーバー CS6

ビジュアル Web 開発ツール

SublimeText3 Mac版

SublimeText3 Mac版

神レベルのコード編集ソフト(SublimeText3)

Javaの平方根 Javaの平方根 Aug 30, 2024 pm 04:26 PM

Java の平方根のガイド。ここでは、Java で平方根がどのように機能するかを、例とそのコード実装をそれぞれ示して説明します。

Javaの完全数 Javaの完全数 Aug 30, 2024 pm 04:28 PM

Java における完全数のガイド。ここでは、定義、Java で完全数を確認する方法、コード実装の例について説明します。

Java の乱数ジェネレーター Java の乱数ジェネレーター Aug 30, 2024 pm 04:27 PM

Java の乱数ジェネレーターのガイド。ここでは、Java の関数について例を挙げて説明し、2 つの異なるジェネレーターについて例を挙げて説明します。

ジャワのウェカ ジャワのウェカ Aug 30, 2024 pm 04:28 PM

Java の Weka へのガイド。ここでは、weka java の概要、使い方、プラットフォームの種類、利点について例を交えて説明します。

Javaのアームストロング数 Javaのアームストロング数 Aug 30, 2024 pm 04:26 PM

Java のアームストロング番号に関するガイド。ここでは、Java でのアームストロング数の概要とコードの一部について説明します。

Javaのスミス番号 Javaのスミス番号 Aug 30, 2024 pm 04:28 PM

Java のスミス番号のガイド。ここでは定義、Java でスミス番号を確認する方法について説明します。コード実装の例。

Java Springのインタビューの質問 Java Springのインタビューの質問 Aug 30, 2024 pm 04:29 PM

この記事では、Java Spring の面接で最もよく聞かれる質問とその詳細な回答をまとめました。面接を突破できるように。

Java 8 Stream Foreachから休憩または戻ってきますか? Java 8 Stream Foreachから休憩または戻ってきますか? Feb 07, 2025 pm 12:09 PM

Java 8は、Stream APIを導入し、データ収集を処理する強力で表現力のある方法を提供します。ただし、ストリームを使用する際の一般的な質問は次のとおりです。 従来のループにより、早期の中断やリターンが可能になりますが、StreamのForeachメソッドはこの方法を直接サポートしていません。この記事では、理由を説明し、ストリーム処理システムに早期終了を実装するための代替方法を調査します。 さらに読み取り:JavaストリームAPIの改善 ストリームを理解してください Foreachメソッドは、ストリーム内の各要素で1つの操作を実行する端末操作です。その設計意図はです

See all articles