Java 網路編程中的多線程通訊允許多個客戶端或伺服器同時連接到同一個應用程序，提高效率和回應請求。實現多執行緒通訊需要使用 ServerSocket 和 Socket 類，透過建立 ServerSocket 物件監聽傳入連接，並為每個連接建立單獨的執行緒來處理數據，如接收和發送回應。如實戰案例中迴聲伺服器，它會將收到的訊息原樣傳回給客戶端，展示了多執行緒通訊在網路程式設計中的應用。
Java 網路程式設計中的多執行緒通訊
在Java 網路程式設計中，多執行緒通訊允許多個用戶端或伺服器同時連接到同一應用程序，從而提高效率並回應更多請求。
實作多執行緒通訊
要實作多執行緒通信，可以使用ServerSocket和Socket類別：
建立一個ServerSocket物件以監聽傳入的連接：
ServerSocket serverSocket = new ServerSocket(port);
建立一個單獨的執行緒來處理每個傳入的連接：
while (true) { Socket socket = serverSocket.accept(); Runnable task = new ClientHandler(socket); // ClientHandler 为处理连接的自定义类 new Thread(task).start(); }
在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(); } }
以上是Java網路程式設計如何進行多執行緒通訊？的詳細內容。更多資訊請關注PHP中文網其他相關文章！
