java 网络编程中的并发连接处理方法有两种：线程池：创建一个预先创建和管理的线程池，当客户端连接时从线程池获取线程处理连接。nio selector：在一个线程中处理多个连接，当客户端连接或有数据可读时触发事件，再进行处理。
Java 网络编程中的并发连接处理
在 Java 网络编程中，处理并发连接至关重要。并发连接是指一个应用程序同时处理多个同时访问它的客户端。
线程池
立即学习“Java免费学习笔记（深入）”；
一种常用的并发处理方法是使用线程池。线程池是一个预先创建和管理的一组线程。当一个客户端连接时，可以从线程池中获取一个线程来处理该连接。这可以防止为每个连接创建新线程，从而节省资源。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
class ThreadPoolServer {
public static void main(String[] args) {
// 创建一个线程池，指定线程数
ExecutorService threadPool = Executors.newFixedThreadPool(10);
// 创建ServerSocket监听端口
ServerSocket serverSocket = new ServerSocket(8080);
while (true) {
// 等待客户端连接
Socket clientSocket = serverSocket.accept();
// 从线程池中获取一个线程处理客户端连接
threadPool.execute(new ClientHandler(clientSocket));
}
}
private static class ClientHandler implements Runnable {
private Socket clientSocket;
public ClientHandler(Socket clientSocket) {
this.clientSocket = clientSocket;
}
@Override
public void run() {
// 处理客户端连接
try {
// 获取客户端输入
BufferedReader reader = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
String line = reader.readLine();
// 向客户端发送响应
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(clientSocket.getOutputStream()));
writer.write("HTTP/1.1 200 OK\n");
writer.flush();
// 关闭连接
clientSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}NioSelector
另一个处理并发连接的选项是使用 NIO Selector。NIO Selector 允许在一个线程中处理多个连接。当客户端连接或有数据可读时，Selector 会触发事件。
import java.io.IOException;
import java.net.InetSocketAddress;
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;
class NioServer {
public static void main(String[] args) throws IOException {
// 创建ServerSocketChannel监听端口
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.bind(new InetSocketAddress(8080));
// 设置ServerSocketChannel为非阻塞模式
serverSocketChannel.configureBlocking(false);
// 创建Selector
Selector selector = Selector.open();
// 将ServerSocketChannel注册到Selector的ACCEPT事件
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
while (true) {
// 阻塞等待事件发生
selector.select();
// 获取发生的事件
Set<SelectionKey> keys = selector.selectedKeys();
Iterator<SelectionKey> iterator = keys.iterator();
while (iterator.hasNext()) {
SelectionKey key = iterator.next();
iterator.remove();
// 处理ACCEPT事件
if (key.isAcceptable()) {
SocketChannel socketChannel = serverSocketChannel.accept();
// 设置SocketChannel为非阻塞模式
socketChannel.configureBlocking(false);
// 将SocketChannel注册到Selector的READ事件
socketChannel.register(selector, SelectionKey.OP_READ);
}
// 处理READ事件
else if (key.isReadable()) {
// 处理客户端连接
handleClientConnection(key);
}
}
}
}
private static void handleClientConnection(SelectionKey key) throws IOException {
SocketChannel socketChannel = (SocketChannel) key.channel();
// 获取客户端输入
BufferedReader reader = new BufferedReader(new InputStreamReader(socketChannel.socket().getInputStream()));
String line = reader.readLine();
// 向客户端发送响应
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socketChannel.socket().getOutputStream()));
writer.write("HTTP/1.1 200 OK\n");
writer.flush();
// 取消注册Selector的事件
key.cancel();
// 关闭连接
socketChannel.close();
}
} 
