【大厂面试题】说下 IO 多路复用?

举报
激流丶 发表于 2023/07/04 12:19:24 2023/07/04
【摘要】 IO多路复用(Input/Output Multiplexing)是一种在单个线程中管理多个输入/输出通道的技术。它允许一个线程同时监听多个输入流(例如网络套接字、文件描述符等),并在有数据可读或可写时进行相应的处理,而不需要为每个通道创建一个独立的线程。

博主介绍: ✌博主从事应用安全和大数据领域,有8年研发经验,5年面试官经验,Java技术专家,WEB架构师,阿里云专家博主,华为云云享专家✌

Java知识图谱点击链接:体系化学习Java(Java面试专题)

💕💕 感兴趣的同学可以收藏关注下不然下次找不到哟💕💕

image.png

1、什么是 IO 多路复用

IO多路复用(Input/Output Multiplexing)是一种在单个线程中管理多个输入/输出通道的技术。它允许一个线程同时监听多个输入流(例如网络套接字、文件描述符等),并在有数据可读或可写时进行相应的处理,而不需要为每个通道创建一个独立的线程。

常见的IO多路复用机制包括select、poll和epoll。这些机制通过将多个IO通道注册到一个事件管理器中,然后通过阻塞方式等待事件的发生。一旦有事件发生(如有数据可读或可写),线程就会被唤醒,然后可以针对具体的事件进行处理。

IO多路复用的优点是可以有效地管理大量的IO通道,减少线程的创建和销毁开销,提高系统的并发性能。它在网络编程中特别有用,可以用于实现高性能的服务器和客户端应用程序。

2、IO 多路复用的优缺点

IO多路复用的优点包括:

  1. 高效性:通过单个线程同时管理多个IO通道,减少了线程的创建和销毁开销,提高了系统的并发性能。
  2. 资源节约:相比每个通道创建一个独立的线程,IO多路复用可以使用更少的线程来处理大量的IO通道,节约了系统资源。
  3. 简化编程模型:使用IO多路复用可以将异步IO操作转换为同步的事件驱动模型,简化了编程逻辑和代码复杂度。
  4. 可扩展性:由于使用了事件驱动模型,IO多路复用可以轻松地扩展到更多的IO通道,而不需要修改大量的代码。

然而,IO多路复用也有一些缺点:

  1. 学习曲线较陡:相比于传统的多线程或多进程模型,IO多路复用的概念和使用方式可能需要一些学习和理解。
  2. 对编程模型的要求较高:使用IO多路复用需要合理地设计和处理事件驱动的逻辑,否则可能会导致代码复杂、难以维护。
  3. 不适用于CPU密集型任务:IO多路复用适用于IO密集型任务,而对于CPU密集型任务,使用多线程或多进程模型可能更为合适。

3、IO 多路复用的应用场景

IO多路复用在以下几个应用场景中非常常见和有用:

  1. 网络编程:在网络编程中,服务器通常需要同时处理多个客户端的连接请求和数据传输。使用IO多路复用可以轻松管理多个网络套接字,监听并处理可读或可写的事件。这种方式可以实现高并发的服务器,提高系统的性能和扩展性。

  2. 高性能服务器:对于需要处理大量并发连接的服务器,如聊天服务器、实时通信服务器、游戏服务器等,使用IO多路复用可以有效地管理和处理多个客户端连接,提高服务器的吞吐量和响应速度。

  3. 文件操作:在文件操作中,当需要同时读取或写入多个文件时,可以使用IO多路复用来监听文件描述符的可读或可写事件,从而避免使用多线程或多进程的方式,提高文件操作的效率。

  4. 定时器和事件调度:IO多路复用可以用于实现定时器和事件调度功能。通过将定时器和事件的触发时间注册到IO多路复用机制中,可以在特定的时间点触发相应的事件,执行相应的操作。

总的来说,IO多路复用适用于需要同时管理和处理多个IO通道的场景,特别是在需要高并发处理的网络编程和服务器应用中非常常见。它可以提高系统的性能和资源利用率,简化编程模型,并且具有良好的可扩展性。

4、IO 多路复用的原理

IO多路复用是一种高效的IO处理机制,其原理如下:

  1. 多路复用:多路复用是指通过一个线程同时监听多个IO事件的就绪状态。在传统的阻塞IO模型中,每个IO操作都需要一个独立的线程来处理,当有大量的IO操作时,会导致线程数量的增加,从而带来线程切换和上下文切换的开销。而多路复用通过使用一个线程来监听多个IO事件,避免了线程数量的增加,减少了线程切换和上下文切换的开销。

  2. IO事件就绪通知:多路复用机制通过操作系统提供的系统调用(如select、poll、epoll等)来监听多个IO事件的就绪状态。当有任何一个IO事件就绪时,操作系统会通知应用程序,告知哪些IO事件已经准备好可以进行读取或写入操作。

  3. 非阻塞IO:多路复用机制通常与非阻塞IO配合使用。在非阻塞IO模型中,当一个IO操作无法立即完成时,不会阻塞线程,而是立即返回一个错误码或特定的状态,应用程序可以继续处理其他IO操作或其他任务,提高了系统的并发性能。

  4. 事件循环:多路复用机制通过事件循环来处理就绪的IO事件。事件循环会不断地监听IO事件的就绪状态,当有IO事件就绪时,会调用相应的回调函数来处理该事件。通过事件循环的方式,可以高效地处理多个IO操作。

5、IO 多路复用的实现

IO多路复用的实现可以通过操作系统提供的不同系统调用来实现,其中最常用的有select、poll和epoll。

  1. select
    select是最古老的IO多路复用机制,它使用一个文件描述符集合来监听多个IO事件的就绪状态。应用程序需要将需要监听的文件描述符添加到集合中,然后调用select函数进行监听。当有文件描述符就绪时,select函数会返回,并告知哪些文件描述符已经准备好进行读取或写入操作。然后应用程序可以通过遍历文件描述符集合来处理就绪的IO事件。

  2. poll
    poll是select的改进版本,它也使用一个文件描述符集合来监听多个IO事件的就绪状态。与select不同的是,poll不需要每次调用都将文件描述符集合传递给内核,而是使用一个pollfd结构体数组来传递。应用程序需要将需要监听的文件描述符和事件类型添加到pollfd数组中,然后调用poll函数进行监听。当有文件描述符就绪时,poll函数会返回,并告知哪些文件描述符已经准备好进行读取或写入操作。然后应用程序可以通过遍历pollfd数组来处理就绪的IO事件。

  3. epoll
    epoll是Linux特有的IO多路复用机制,它使用一个内核事件表来管理和监听多个IO事件的就绪状态。应用程序需要将需要监听的文件描述符添加到内核事件表中,然后调用epoll_wait函数进行监听。当有文件描述符就绪时,epoll_wait函数会返回,并告知哪些文件描述符已经准备好进行读取或写入操作。与select和poll不同的是,epoll使用回调函数来处理就绪的IO事件,而不需要应用程序遍历事件列表。

6、用 Java 写一段 IO 多路复用的代码

package com.pany.camp.io;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.channels.*;
import java.util.Iterator;
import java.util.Set;

/**
 *
 * @description:  IO多路复用
 * @copyright: @Copyright (c) 2022 
 * @company: Aiocloud
 * @author: pany
 * @version: 1.0.0 
 * @createTime: 2023-07-04 12:09
 */
public class IOMultiplexingExample {

    public static void main(String[] args) throws IOException {
        // 创建一个Selector
        Selector selector = Selector.open();

        // 创建需要监听的Channel
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress("localhost", 8080));
        serverSocketChannel.configureBlocking(false);

        // 将Channel注册到Selector,并指定监听事件为接收连接
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

        while (true) {
            // 阻塞等待就绪的事件
            selector.select();

            // 获取就绪的事件集合
            Set<SelectionKey> selectedKeys = selector.selectedKeys();
            Iterator<SelectionKey> keyIterator = selectedKeys.iterator();

            // 处理就绪的事件
            while (keyIterator.hasNext()) {
                SelectionKey key = keyIterator.next();

                if (key.isAcceptable()) {
                    // 接收连接事件
                    ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel();
                    SocketChannel clientChannel = serverChannel.accept();
                    clientChannel.configureBlocking(false);
                    clientChannel.register(selector, SelectionKey.OP_READ);
                } else if (key.isReadable()) {
                    // 可读事件
                    SocketChannel clientChannel = (SocketChannel) key.channel();
                    // 读取数据
                    // ...
                }

                // 处理完事件后,需要从集合中移除该事件
                keyIterator.remove();
            }
        }
    }
}

将ServerSocketChannel注册到Selector上,监听接收连接事件。然后通过循环调用 selector.select() 来阻塞等待就绪的事件。一旦有事件就绪,就会进入事件处理的循环,根据事件类型进行相应的处理。处理完事件后,需要从集合中移除该事件。

需要注意的是,IO多路复用适用于非阻塞IO,因此需要将Channel设置为非阻塞模式。在实际应用中,可能还需要处理写入事件、连接事件等其他类型的事件。

image.png

💕💕 本文由激流原创,原创不易,感谢支持
💕💕喜欢的话记得点赞收藏啊
image.png

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。