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 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 {
        // 创建ServerSocketchaner
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress(8080));

        // ServerSocketchanel设置为非阻塞模式
        serverSocketChannel.configureBlocking(false);

        // 创建Selectortor
        Selector selector = Selector.open();

        // 在SelectorACCEPT事件中注册ServerSocketchanel
        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();

                    // 将Socketchanel设置为非阻塞模式
                    socketChannel.configureBlocking(false);

                    // 在SelectorREAD事件中注册Socketchanel
                    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();
    }
}

登录后复制

以上是Java网络编程中如何处理并发连接？详情请关注图灵教育其他相关文章！