网络 I/O:单 Selector 多线程(单线程模型)

简介: 网络 I/O:单 Selector 多线程(单线程模型)

网络编程中,I/O模型的选择对于程序的性能和可扩展性至关重要。单 Selector 多线程(单线程模型)是一种常见的网络 I/O 模型,它利用单个 Selector 对象来监听多个 Socket 连接,并通过多线程来处理这些连接的读写操作。这种模型在处理大量并发连接时具有较好的性能表现,尤其适用于高并发、低延迟的网络应用。

单 Selector 多线程模型的核心是 Selector 对象,它能够监视多个 Socket 对象的状态变化,包括连接、数据到达等事件。通过在 Selector 上注册感兴趣的事件和对应的 Socket,程序可以在一个单独的线程中轮询 Selector,检查哪些事件已经发生并执行相应的操作。

下面是一个使用 Java 的 NIO(Non-blocking I/O)实现单 Selector 多线程模型的示例代码:

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.*;
public class SingleSelectorExample {
    private static final int PORT = 8080;
    private static final int THREAD_COUNT = 10;
    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);
        for (int i = 0; i < THREAD_COUNT; i++) {
            new WorkerThread(selector).start();
        }
        while (true) {
            try {
                int readyChannels = selector.select();
                if (readyChannels == 0) continue;
                Set<SelectionKey> selectedKeys = selector.selectedKeys();
                Iterator<SelectionKey> keyIterator = selectedKeys.iterator();
                while (keyIterator.hasNext()) {
                    SelectionKey key = keyIterator.next();
                    if (key.isAcceptable()) {
                        ServerSocketChannel server = (ServerSocketChannel) key.channel();
                        SocketChannel client = server.accept();
                        client.configureBlocking(false);
                        client.register(selector, SelectionKey.OP_READ);
                    } else if (key.isReadable()) {
                        SocketChannel client = (SocketChannel) key.channel();
                        ByteBuffer buffer = ByteBuffer.allocate(1024);
                        int bytesRead = client.read(buffer);
                        if (bytesRead > 0) {
                            // 处理接收到的数据...
                        } else if (bytesRead < 0) {
                            client.close();
                        } else {
                            // 数据读取完毕,重置 buffer 或进行其他处理...
                        }
                    } else if (key.isWritable()) {
                        // 处理可写状态...
                    }
                    keyIterator.remove();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

上述代码中,我们创建了一个 ServerSocketChannel 用于监听客户端的连接请求。通过将 ServerSocketChannel 的配置设置为非阻塞模式,我们可以在同一个线程中处理其他 I/O 事件。然后,我们打开一个 Selector 对象,并在其上注册了 ServerSocketChannel,监听 OP_ACCEPT 事件(新的连接请求)。

接下来,我们创建了多个 WorkerThread 线程,每个线程都会轮询 Selector。在主线程中,我们进入一个无限循环,轮询 Selector 并处理已就绪的通道。当有新的连接请求到来时,我们接受连接并将新 SocketChannel 注册到 Selector 上,监听 OP_READ 事件(数据可读)。

对于已注册的 SocketChannel,我们还需要处理 OP_READ 事件。当数据可读时,我们从 SocketChannel 读取数据到 ByteBuffer 中。如果读取到的字节数大于 0,说明有数据可读,我们可以处理这些数据。如果读取到的字节数为 0,表示对端已经关闭连接。如果读取过程中发生 IOException,我们关闭 SocketChannel。

此外,如果某个通道的 SelectionKey 还处于可写状态(OP_WRITE),我们也可以处理相应的写操作。

通过这种方式,单 Selector 多线程模型可以在一个单独的线程中高效地处理多个 Socket 连接的 I/O 事件。这种模型适用于高并发、低延迟的网络应用,能够充分利用多核处理器的性能,并且避免了多线程编程的复杂性。

需要注意的是,在实际应用中,可能还需要考虑其他问题,如连接的管理、线程池的配置、资源的释放等。此外,不同的编程语言和框架提供了不同的 I/O 模型和工具,选择适合自己应用场景的模型和工具也是非常重要的。

相关文章
|
12月前
|
JSON 监控 网络协议
干货分享“对接的 API 总是不稳定,网络分层模型” 看电商 API 故障的本质
本文从 OSI 七层网络模型出发,深入剖析电商 API 不稳定的根本原因,涵盖物理层到应用层的典型故障与解决方案,结合阿里、京东等大厂架构,详解如何构建高稳定性的电商 API 通信体系。
|
9月前
|
设计模式 缓存 安全
【JUC】(6)带你了解共享模型之 享元和不可变 模型并初步带你了解并发工具 线程池Pool,文章内还有饥饿问题、设计模式之工作线程的解决于实现
JUC专栏第六篇,本文带你了解两个共享模型:享元和不可变 模型,并初步带你了解并发工具 线程池Pool,文章中还有解决饥饿问题、设计模式之工作线程的实现
598 2
|
9月前
|
JSON 网络协议 安全
【Java】(10)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
429 1
|
9月前
|
JSON 网络协议 安全
【Java基础】(1)进程与线程的关系、Tread类;讲解基本线程安全、网络编程内容;JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念,进程是处于运行过程中的程序,并且具有一定的独立功能,进程是系统进行资源分配和调度的一个独立单位一般而言,进程包含如下三个特征。独立性动态性并发性。
396 1
|
9月前
|
机器学习/深度学习 数据采集 人工智能
深度学习实战指南:从神经网络基础到模型优化的完整攻略
🌟 蒋星熠Jaxonic,AI探索者。深耕深度学习,从神经网络到Transformer,用代码践行智能革命。分享实战经验,助你构建CV、NLP模型,共赴二进制星辰大海。
|
10月前
|
机器学习/深度学习 传感器 算法
【无人车路径跟踪】基于神经网络的数据驱动迭代学习控制(ILC)算法,用于具有未知模型和重复任务的非线性单输入单输出(SISO)离散时间系统的无人车的路径跟踪(Matlab代码实现)
【无人车路径跟踪】基于神经网络的数据驱动迭代学习控制(ILC)算法,用于具有未知模型和重复任务的非线性单输入单输出(SISO)离散时间系统的无人车的路径跟踪(Matlab代码实现)
628 2
|
10月前
|
机器学习/深度学习 并行计算 算法
【CPOBP-NSWOA】基于豪冠猪优化BP神经网络模型的多目标鲸鱼寻优算法研究(Matlab代码实现)
【CPOBP-NSWOA】基于豪冠猪优化BP神经网络模型的多目标鲸鱼寻优算法研究(Matlab代码实现)
253 8
|
11月前
|
算法 安全 网络安全
【多智能体系统】遭受DoS攻击的网络物理多智能体系统的弹性模型预测控制MPC研究(Simulink仿真实现)
【多智能体系统】遭受DoS攻击的网络物理多智能体系统的弹性模型预测控制MPC研究(Simulink仿真实现)
385 0
|
12月前
|
数据采集 监控 调度
干货分享“用 多线程 爬取数据”:单线程 + 协程的效率反超 3 倍,这才是 Python 异步的正确打开方式
在 Python 爬虫中,多线程因 GIL 和切换开销效率低下,而协程通过用户态调度实现高并发,大幅提升爬取效率。本文详解协程原理、实战对比多线程性能,并提供最佳实践,助你掌握异步爬虫核心技术。
|
SQL 安全 网络安全
网络安全与信息安全:知识分享####
【10月更文挑战第21天】 随着数字化时代的快速发展,网络安全和信息安全已成为个人和企业不可忽视的关键问题。本文将探讨网络安全漏洞、加密技术以及安全意识的重要性,并提供一些实用的建议,帮助读者提高自身的网络安全防护能力。 ####
521 17