Java网络编程中如何处理并发连接？

java 网络编程中的并发连接处理方法有两种：线程池：创建一个预先创建和管理的线程池，当客户端连接时从线程池获取线程处理连接。nio selector：在一个线程中处理多个连接，当客户端连接或有数据可读时触发事件，再进行处理。

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 OKn");
                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 OKn");
        writer.flush();

        // 取消注册Selector的事件
        key.cancel();

        // 关闭连接
        socketChannel.close();
    }
}

登录后复制

以上就是Java网络编程中如何处理并发连接？的详细内容，更多请关注叮当号网其它相关文章！