超详细JavaNIO选择器教程，轻松掌握高性能网络编程！

1、选择器的概念和使用场景

Java NIO中的选择器（Selector），是一个可以同时处理多个通道的I/O多路复用机制。在传统的I/O模型中，每个连接都需要独立的线程去处理，当连接数量增多时，线程数量也会随之增加，这会导致系统资源的消耗和线程切换的开销，从而影响系统的性能和可伸缩性。而使用选择器，可以将多个通道注册到同一个选择器中，这样就可以用一个线程来处理多个通道的I/O事件，从而大大减少线程数量，提高系统的并发处理能力。

创新互联建站专业成都网站设计、成都做网站，集网站策划、网站设计、网站制作于一体，网站seo、网站优化、网站营销、软文营销等专业人才根据搜索规律编程设计，让网站在运行后，在搜索中有好的表现，专业设计制作为您带来效益的网站！让网站建设为您创造效益。

选择器通常用于实现高并发的网络应用，例如服务器端的网络编程、聊天室、游戏服务器等场景，也可以用于实现文件I/O等操作。

2、选择器的工作原理

选择器的工作原理可以简单描述为以下几个步骤：

  • 创建一个选择器（Selector）对象。
  • 将一个或多个通道（SelectableChannel）注册到选择器中，指定需要监听的事件类型（SelectionKey.OP_READ、SelectionKey.OP_WRITE等）。
  • 不断轮询选择器，检查是否有通道的事件已经就绪（ready）。
  • 如果有通道的事件已经就绪，就处理这些事件，例如读取数据、写入数据等。
  • 重复以上步骤，直到不需要再处理事件。

选择器的轮询操作通常是阻塞的，直到至少有一个通道的事件已经就绪。这种阻塞模式可以通过设置选择器的超时时间来避免，或者使用非阻塞式的轮询操作。

3、选择器的API

Java NIO中与选择器相关的API主要包括以下几个类：

  • Selector：选择器类，用于管理通道的注册、轮询等操作。
  • SelectionKey：选择键类，表示一个通道注册到一个选择器中的关系，包含通道、选择器、事件类型等信息。
  • SelectableChannel：可选择通道类，表示一个可以注册到选择器中的通道，包括SocketChannel、ServerSocketChannel、DatagramChannel等。

在使用选择器时，需要先创建一个Selector对象，然后将需要监听的通道（SelectableChannel）注册到选择器中，通过返回的SelectionKey对象可以获取通道、选择器、事件类型等信息，从而进行相应的读写操作。

4、选择器的注册操作

选择器的注册操作是将一个通道注册到一个选择器中，以便选择器能够监听该通道的I/O事件。注册操作通常使用SelectableChannel类的register()方法实现，例如：

SelectableChannel channel = ... // 创建并打开一个通道
Selector selector = Selector.open(); // 创建一个选择器
channel.configureBlocking(false); // 设置通道为非阻塞模式
SelectionKey key = channel.register(selector, SelectionKey.OP_READ); // 将通道注册到选择器中，监听读事件

在注册操作中，需要指定监听的事件类型，例如SelectionKey.OP_READ表示监听读事件，SelectionKey.OP_WRITE表示监听写事件等。注册操作也可以取消，使用SelectionKey类的cancel()方法实现，例如：

key.cancel(); // 取消注册操作

5、选择器的轮询操作

选择器的轮询操作是选择器的核心操作，它通过不断地轮询已注册的通道，检查是否有I/O事件已经就绪，从而进行相应的读写操作。轮询操作通常使用Selector类的select()方法实现，例如：

while (true) {
    int readyChannels = selector.select(); // 阻塞等待通道就绪，返回就绪通道数
    if (readyChannels == 0) {
        continue;
    }
    Set selectedKeys = selector.selectedKeys(); // 获取已就绪的SelectionKey集合
    Iterator keyIterator = selectedKeys.iterator();
    while (keyIterator.hasNext()) {
        SelectionKey key = keyIterator.next();
        if (key.isReadable()) { // 通道可读事件就绪
            // 处理读数据操作
        }
        if (key.isWritable()) { // 通道可写事件就绪
            // 处理写数据操作
        }
        keyIterator.remove(); // 移除已处理的SelectionKey
    }
}

在轮询操作中，需要首先调用select()方法阻塞等待通道就绪，该方法会返回已就绪的通道数，如果返回值为0，表示没有通道就绪，需要继续轮询。然后通过selectedKeys()方法获取已就绪的SelectionKey集合，遍历集合，根据事件类型进行相应的读写操作，并将已处理的SelectionKey从集合中移除。

6、选择器的非阻塞式读写

选择器可以实现非阻塞式的I/O操作，即在读写操作时不会阻塞线程，可以继续处理其他通道的事件。非阻塞式读写通常使用SelectableChannel类的configureBlocking(false)方法实现，例如：

SelectableChannel channel = ... // 创建并打开一个通道
channel.configureBlocking(false); // 设置通道为非阻塞模式

在非阻塞式读写中，读写方法通常返回0或者-1，表示没有数据可读，或者通道已经关闭等情况。需要根据返回值进行相应的处理，例如：

int bytesRead = channel.read(buffer); // 读取数据到缓冲区
if (bytesRead == -1) { // 通道已经关闭
    channel.close();
} else if (bytesRead == 0) { // 没有数据可读
    // 继续处理其他通道的事件
} else { // 读取到数据
    // 处理读取到的数据
}

7、选择器的注意事项

使用选择器需要注意以下几点：

  • 注册操作和取消注册操作需要正确处理，避免重复注册或取消注册操作，否则会导致程序异常。
  • 轮询操作中需要及时移除已处理的SelectionKey，否则会导致重复处理已就绪的事件。
  • 轮询操作中需要注意超时时间的设置，避免长时间阻塞。
  • 非阻塞式读写中需要根据返回值进行相应的处理，避免陷入无限循环或者读写错误。

完整代码

以下是完整可运行的Java NIO选择器（Selector）示例代码，包括选择器的创建、通道的注册、轮询操作、非阻塞式读写等：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectableChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.Set;

public class NioSelectorDemo {

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

        // 创建选择器
        Selector selector = Selector.open();

        // 创建服务器通道
        ServerSocketChannel serverChannel = ServerSocketChannel.open();
        InetSocketAddress address = new InetSocketAddress("localhost", 8080);

        // 绑定服务器地址
        serverChannel.bind(address);

        // 设置通道为非阻塞模式
        serverChannel.configureBlocking(false);

        // 注册通道到选择器上，并指定监听事件类型为接收连接事件
        SelectionKey key = serverChannel.register(selector, SelectionKey.OP_ACCEPT);

        System.out.println("服务器启动，监听地址：" + address);

        while (true) {
            // 阻塞等待通道就绪
            int readyChannels = selector.select();
            if (readyChannels == 0) {
                continue;
            }

            // 获取已就绪的通道集合
            Set selectedKeys = selector.selectedKeys();
            Iterator keyIterator = selectedKeys.iterator();

            while (keyIterator.hasNext()) {
                SelectionKey selectionKey = keyIterator.next();

                if (selectionKey.isAcceptable()) { // 接收连接事件就绪
                    // 获取服务器通道
                    ServerSocketChannel server = (ServerSocketChannel) selectionKey.channel();

                    // 接收客户端连接，并注册到选择器上
                    SocketChannel client = server.accept();
                    client.configureBlocking(false);
                    client.register(selector, SelectionKey.OP_READ);

                    System.out.println("客户端连接： " + client.getRemoteAddress());

                } else if (selectionKey.isReadable()) { // 通道可读事件就绪
                    // 获取通道
                    SocketChannel client = (SocketChannel) selectionKey.channel();

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

                    if (bytesRead == -1) { // 通道已经关闭
                        client.close();
                    } else if (bytesRead == 0) { // 没有数据可读
                        continue;
                    } else { // 读取到数据
                        buffer.flip();
                        byte[] bytes = new byte[buffer.remaining()];
                        buffer.get(bytes);
                        String message = new String(bytes).trim();
                        System.out.println("收到消息：" + message);
                    }
                }

                // 移除已处理的通道
                keyIterator.remove();
            }
        }
    }
}

在以上代码中，我们创建了一个服务器通道ServerSocketChannel，将其绑定到地址localhost:8080上，并将其注册到选择器Selector中，指定监听事件类型为接收连接事件（SelectionKey.OP_ACCEPT）。在轮询操作中，我们使用SelectionKey的isAcceptable()和isReadable()方法判断通道是否已经就绪，然后进行相应的读写操作。

可以使用telnet或nc（Netcat）等工具进行测试。以telnet为例，可以按照以下步骤进行测试：

  • 打开终端或命令行窗口。
  • 输入telnet localhost 8080命令，连接到服务器。
  • 输入任意内容，发送给服务器。
  • 在服务器控制台中，可以看到收到了客户端发送的消息。

如果没有安装telnet或nc等工具，也可以使用其他网络调试工具，例如Postman、curl等，通过HTTP协议进行测试。

在测试时，需要注意防火墙等网络配置，确保客户端能够连接到服务器。

总结

选择器（Selector）是Java NIO中的一个重要组件，可以实现高效的I/O多路复用机制，提高系统的并发处理能力。在使用选择器时，需要了解选择器的概念、工作原理、API、注册操作、轮询操作、非阻塞式读写、注意事项等方面的知识，从而编写出高效、稳定的网络应用程序。

当前名称：超详细JavaNIO选择器教程，轻松掌握高性能网络编程！
网址分享：http://www.36103.cn/qtweb/news23/14423.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

移动网站建设知识

各行业网站

成都网站建设　　 　三台网站建设　　 　宜宾做网站　　 　四川服务器托管　　 　成都未宇聚　　 　什邡做网站　　 　南充电信机房托管　　 　成都定制网站建设　　 　营销型网站建设　　 　支点广告　　 　西云机房　　 　雅安电信机房　　 　成都光华电信机房　　 　成都小程序开发　　 　成都铁科精智测控　　 　服务器租用　　 　成都酒店服定制　　 　西云服务器托管　　 　成都木托盘　　 　成都网站推广