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

Java 网络编程中的多线程通信允许多个客户端或服务器同时连接到同一个应用程序，提高效率和响应请求。实现多线程通信需要使用 ServerSocket 和 Socket 类，通过创建 ServerSocket 对象监听传入连接，并为每个连接创建单独的线程来处理数据，如接收和发送响应。如实战案例中回声服务器，它会将收到的消息原样返回给客户端，展示了多线程通信在网络编程中的应用。

Java 网络编程中的多线程通信

在 Java 网络编程中，多线程通信允许多个客户端或服务器同时连接到同一应用程序，从而提高效率并响应更多请求。

实现多线程通信

要实现多线程通信，可以使用 ServerSocket 和 Socket 类：

1. 创建一个 ServerSocket 对象以监听传入的连接：

   ServerSocket serverSocket = new ServerSocket(port);

2. 创建一个单独的线程来处理每个传入的连接：

   while (true) {
     Socket socket = serverSocket.accept();
     Runnable task = new ClientHandler(socket);  // ClientHandler 为处理连接的自定义类
     new Thread(task).start();
   }

3. 在 ClientHandler 类中，处理从套接字接收的数据并发送响应：

   class ClientHandler implements Runnable {
   
     private Socket socket;
   
     public ClientHandler(Socket socket) {
    this.socket = socket;
     }
   
     @Override
     public void run() {
    // 从套接字接收数据
    BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String request = in.readLine();
   
    // 准备并发送响应
    String response = "HTTP/1.1 200 OK\n";
    socket.getOutputStream().write(response.getBytes());
   
    // 关闭套接字
    socket.close();
     }
   }

实战案例：回声服务器

这是一个回声服务器的简单示例，它会将它收到的任何消息原样返回给客户端：

服务器端

import java.net.ServerSocket;
import java.net.Socket;

public class EchoServer {

  public static void main(String[] args) throws Exception {
    // 监听端口 8080 的传入连接
    ServerSocket serverSocket = new ServerSocket(8080);

    while (true) {
      // 接受传入的连接
      Socket socket = serverSocket.accept();

      // 处理连接的线程
      Runnable task = new ClientHandler(socket);
      new Thread(task).start();
    }
  }

  private static class ClientHandler implements Runnable {

    private Socket socket;

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

    @Override
    public void run() {
      try {
        // 从客户端接收消息
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        String message = in.readLine();

        // 将消息原样返回给客户端
        socket.getOutputStream().write((message + "\n").getBytes());

        // 关闭连接
        socket.close();
      } catch (Exception e) {
        e.printStackTrace();
      }
    }
  }
}

客户端

import java.net.Socket;

public class EchoClient {

  public static void main(String[] args) throws Exception {
    // 连接到回声服务器的 8080 端口
    Socket socket = new Socket("localhost", 8080);

    // 向服务器发送消息
    socket.getOutputStream().write("Hello world!\n".getBytes());

    // 从服务器接收响应
    BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String response = in.readLine();

    // 打印服务器的响应
    System.out.println("Server response: " + response);

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