Java如何实现多线程网络服务

在Java中，可以使用java.net包中的类和接口来实现多线程网络服务。以下是一个简单的示例，展示了如何使用多线程来处理客户端连接。

1. 首先，创建一个实现Runnable接口的类，该类将处理客户端连接：

import java.io.*;
import java.net.*;

public class ClientHandler implements Runnable {
    private Socket clientSocket;

    public ClientHandler(Socket socket) {
        this.clientSocket = socket;
    }

    @Override
    public void run() {
        try (
            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
            PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)
        ) {
            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                System.out.println("Received from client: " + inputLine);
                out.println("Server response: " + inputLine);
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                clientSocket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

2. 创建一个服务器类，该类将监听客户端连接并创建新的线程来处理它们：

import java.io.*;
import java.net.*;

public class MultiThreadedServer {
    private int port;

    public MultiThreadedServer(int port) {
        this.port = port;
    }

    public void start() {
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("Server started on port " + port);

            while (true) {
                Socket clientSocket = serverSocket.accept();
                System.out.println("New client connected");

                ClientHandler clientHandler = new ClientHandler(clientSocket);
                Thread thread = new Thread(clientHandler);
                thread.start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        int port = 12345;
        MultiThreadedServer server = new MultiThreadedServer(port);
        server.start();
    }
}

在这个示例中，MultiThreadedServer类创建了一个ServerSocket，监听指定的端口。当客户端连接时，serverSocket.accept()将返回一个新的Socket对象，用于与客户端通信。然后，我们创建一个新的ClientHandler实例，并为其分配一个新的线程。ClientHandler类的run()方法将处理客户端请求，直到客户端断开连接。

要运行此示例，请将代码保存到两个文件中（ClientHandler.java和MultiThreadedServer.java），然后编译并运行MultiThreadedServer类。服务器将在端口12345上启动，并为每个连接的客户端创建一个新的线程。