核心内容摘要
OpenMMLab实战指南：从环境搭建到首个检测模型运行
视频看了几百小时还迷糊关注我几分钟让你秒懂
前言为什么我们要聊 I/O 多路复用在开发高并发网络服务比如聊天服务器、实时推送系统、游戏后端等时我们经常会遇到一个核心问题如何高效地同时处理成千上万个客户端连接传统的“一个连接开一个线程”的方式在连接数暴增时会迅速耗尽系统资源内存、线程上下文切换开销等导致服务崩溃或响应极慢。
这时候I/O 多路复用I/O Multiplexing就派上用场了。
本文将用通俗易懂的方式结合Java Spring Boot的实战代码带你彻底搞懂 I/O 多路复用并告诉你什么时候该用、什么时候不该用。
什么是 I/O 多路复用
简单比喻想象你在一家餐厅当服务员传统阻塞 I/O你为每个客人单独服务点完菜才去下一个。
如果客人思考很久你就干站着等——效率极低。
多线程模型你请很多服务员每人负责一个客人。
人多了餐厅挤爆管理混乱。
I/O 多路复用你一个人站在门口手里拿着所有客人的菜单编号。
只要哪个客人喊“好了”你就立刻过去处理——一个线程监听多个连接谁就绪就处理谁。
这就是 I/O 多路复用的核心思想用一个线程监控多个 I/O 通道当任意一个通道就绪可读/可写时立即处理它。
技术本质操作系统提供如select、poll、epollLinux、kqueuemacOS等系统调用允许程序同时监听多个文件描述符如 socket的状态变化。
在 Java 中我们通过NIONon-blocking I/O和Selector来实现这一机制。
需求场景什么情况下需要 I/O 多路复用✅适用场景高并发长连接服务如 WebSocket 聊天室实时消息推送系统游戏服务器大量玩家在线自定义协议的 TCP 服务网关❌不适用场景普通 Web 接口REST API请求短、无状态 → 用 Tomcat 线程池即可计算密集型任务I/O 多路复用解决的是 I/O 瓶颈不是 CPU 瓶颈
Java 实现用 NIO Selector 手写一个简易多路复用服务器注意Spring Boot 默认使用 Tomcat基于线程池不直接暴露 NIO 编程。
但我们可以在 Spring Boot 中嵌入自定义 NIO 服务。
项目结构src/ └── main/ └── java/ └── com.example.iomultiplexing/ ├── IoMultiplexingServer.java ← 核心多路复用逻辑 └── Application.java ← Spring Boot 启动类
核心代码IoMultiplexingServer.javapackage com.example.iomultiplexing; import org.springframework.stereotype.Component; import javax.annotation.PostConstruct; import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.*; import java.util.Iterator; import java.util.Set; Component public class IoMultiplexingServer { private static final int PORT 8081; private Selector selector; PostConstruct public void start() throws IOException { //
创建 ServerSocketChannel非阻塞 ServerSocketChannel serverChannel ServerSocketChannel.open(); serverChannel.configureBlocking(false); serverChannel.bind(new InetSocketAddress(PORT)); //
创建 Selector多路复用器 selector Selector.open(); //
将 serverChannel 注册到 selector监听 ACCEPT 事件 serverChannel.register(selector, SelectionKey.OP_ACCEPT); System.out.println(I/O 多路复用服务器启动监听端口: PORT); //
事件循环 while (true) { // 阻塞等待直到有 channel 就绪最多阻塞 1 秒 int readyChannels selector.select(
; if (readyChannels
continue; // 获取所有就绪的事件 SetSelectionKey selectedKeys selector.selectedKeys(); IteratorSelectionKey keyIterator selectedKeys.iterator(); while (keyIterator.hasNext()) { SelectionKey key keyIterator.next(); keyIterator.remove(); // 必须移除否则会重复处理 if (!key.isValid()) continue; try { if (key.isAcceptable()) { handleAccept(key); } else if (key.isReadable()) { handleRead(key); } } catch (IOException e) { System.err.println(处理连接出错: e.getMessage()); key.cancel(); try { key.channel().close(); } catch (IOException ignored) {} } } } } private void handleAccept(SelectionKey key) throws IOException { ServerSocketChannel server (ServerSocketChannel) key.channel(); SocketChannel client server.accept(); if (client ! null) { client.configureBlocking(false); // 注册 READ 事件后续可读时触发 client.register(selector, SelectionKey.OP_READ); System.out.println(新客户端连接: client.getRemoteAddress()); } } private void handleRead(SelectionKey key) throws IOException { SocketChannel client (SocketChannel) key.channel(); ByteBuffer buffer ByteBuffer.allocate(
; int bytesRead client.read(buffer); if (bytesRead
{ buffer.flip(); byte[] data new byte[buffer.remaining()]; buffer.get(data); String msg new String(data).trim(); System.out.println(收到消息: msg); // 回显 String response Echo: msg; client.write(ByteBuffer.wrap(response.getBytes())); } else if (bytesRead
{ // 客户端断开 System.out.println(客户端断开连接); key.cancel(); client.close(); } } }
启动类Application.javapackage com.example.iomultiplexing; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; SpringBootApplication public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
测试方式启动 Spring Boot 应用后用telnet或nc测试# 终端1 telnet localhost 8081 # 输入 hello → 会收到 Echo: hello # 终端2同时连接 telnet localhost 8081 # 输入 world → 也会收到 Echo: world✅关键点整个服务器只用一个线程却能同时处理多个客户端
反例错误的用法小白常踩的坑❌ 反例1在 Web 接口中强行用 NIO// 错误示范 RestController public class BadController { GetMapping(/test) public String test() { // 这里试图用 Selector 处理 HTTP 请求大错特错 // Spring MVC 已经由 Tomcat 处理了 I/O你再套一层 NIO 是画蛇添足 return 别这么干; } }后果代码复杂度飙升性能反而下降且破坏 Spring Boot 的编程模型。
❌ 反例2忘记keyIterator.remove()while (keyIterator.hasNext()) { SelectionKey key keyIterator.next(); // 忘记 remove() → 下次循环还会处理同一个 key handleRead(key); }后果无限循环处理同一个事件CPU 100%服务卡死
六、
注意事项 最佳实践事项说明不要滥用普通 Web 服务用 Spring Web Tomcat 足够无需手写 NIO异常处理必须捕获IOException并关闭 channel否则连接泄漏缓冲区复用生产环境应使用ThreadLocal或对象池复用ByteBuffer避免频繁分配内存粘包/拆包TCP 是流协议需自行处理消息边界如加长度头平台差异epollLinux性能远优于selectJava NIO 在 Linux 上自动使用 epoll
七、