Java多线程如何进行网络通信

在Java中，使用多线程进行网络通信通常涉及到以下几个步骤：

1. 创建一个ServerSocket对象，监听指定的端口。这个对象会阻塞当前线程，直到有客户端连接进来。

ServerSocket serverSocket = new ServerSocket(port);

2. 使用serverSocket.accept()方法接受客户端连接。这个方法会返回一个新的Socket对象，用于与客户端进行通信。这个操作是阻塞的，所以通常会在一个单独的线程中执行。

Socket clientSocket = serverSocket.accept();

3. 为每个客户端连接创建一个新的线程，用于处理与该客户端的通信。在这个线程中，可以使用clientSocket.getInputStream()和clientSocket.getOutputStream()方法获取输入流和输出流，从而实现数据的发送和接收。

Thread clientThread = new Thread(() -> {
    try {
        InputStream inputStream = clientSocket.getInputStream();
        OutputStream outputStream = clientSocket.getOutputStream();

        // 读取客户端发送的数据
        byte[] buffer = new byte[1024];
        int bytesRead;
        while ((bytesRead = inputStream.read(buffer)) != -1) {
            String message = new String(buffer, 0, bytesRead);
            System.out.println("Received message from client: " + message);
        }

        // 向客户端发送数据
        String response = "Hello, client!";
        outputStream.write(response.getBytes());

        // 关闭资源
        inputStream.close();
        outputStream.close();
        clientSocket.close();
    } catch (IOException e) {
        e.printStackTrace();
    }
});

4. 启动线程，开始处理客户端连接。

clientThread.start();

5. 重复步骤2-4，直到所有客户端连接都被处理完毕。

下面是一个简单的Java多线程服务器示例：

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

public class MultiThreadedServer {
    public static void main(String[] args) throws IOException {
        int port = 8888;
        ServerSocket serverSocket = new ServerSocket(port);
        System.out.println("Server started on port " + port);

        while (true) {
            Socket clientSocket = serverSocket.accept();
            System.out.println("Client connected: " + clientSocket.getInetAddress());

            Thread clientThread = new Thread(() -> {
                try {
                    InputStream inputStream = clientSocket.getInputStream();
                    OutputStream outputStream = clientSocket.getOutputStream();

                    // 读取客户端发送的数据
                    byte[] buffer = new byte[1024];
                    int bytesRead;
                    while ((bytesRead = inputStream.read(buffer)) != -1) {
                        String message = new String(buffer, 0, bytesRead);
                        System.out.println("Received message from client: " + message);
                    }

                    // 向客户端发送数据
                    String response = "Hello, client!";
                    outputStream.write(response.getBytes());

                    // 关闭资源
                    inputStream.close();
                    outputStream.close();
                    clientSocket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            });

            clientThread.start();
        }
    }
}

这个示例中，服务器会监听8888端口，每当有新的客户端连接时，都会创建一个新的线程来处理与该客户端的通信。