Java 開発: 非同期 IO を使用して大量の同時リクエストを処理する方法

Selector selector = Selector.open(); ServerSocketChannel serverSocketChannel = ServerSocketChannel.open(); serverSocketChannel.configureBlocking(false); // 设置为非阻塞模式 serverSocketChannel.bind(new InetSocketAddress("localhost", 8080)); // 绑定地址和端口 serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT); // 注册接收事件

while (true) { selector.select(); // 阻塞等待事件发生 Set selectionKeys = selector.selectedKeys(); Iterator iterator = selectionKeys.iterator(); while (iterator.hasNext()) { SelectionKey selectionKey = iterator.next(); iterator.remove(); if (selectionKey.isAcceptable()) { SocketChannel socketChannel = serverSocketChannel.accept(); socketChannel.configureBlocking(false); socketChannel.register(selector, SelectionKey.OP_READ); // 注册读事件 } else if (selectionKey.isReadable()) { SocketChannel socketChannel = (SocketChannel) selectionKey.channel(); ByteBuffer buffer = ByteBuffer.allocate(1024); int bytesRead = socketChannel.read(buffer); if (bytesRead > 0) { buffer.flip(); // 处理请求数据 String request = new String(buffer.array(), 0, bytesRead); // 处理请求，并返回响应数据 String response = processRequest(request); // 写入响应数据 ByteBuffer writeBuffer = ByteBuffer.wrap(response.getBytes()); socketChannel.write(writeBuffer); } else if (bytesRead == -1) { // 连接已关闭 socketChannel.close(); } } } }