Java多線程的 TCP 網絡程序

發布時間：

2022-05-18 16:39

信息來源：

網絡推薦

瀏覽次數：

863

在例 13-10 和例 13-11 中分則實我了服務器端程序和客戶端程序，當一個客戶端程序請
求服務器端時，服務器端就會結束阻塞狀態，完成程序的運行。實際上，很多服務器端程序
都是允許收多個應用程序訪問的。例如門戶網站可以被多個用戶同時訪問，因此服務器都是
多線程的，下面就通過一個圖例來表示多個用戶訪同一個服務器。如圖 13-19 所示。
圖 13-19 代表的是多個客戶端訪問同一個服務器端，服務器端為每個客戶端創建一個對
應的 Socket,并且開啟一個新的線程使兩個 Socket 建立專線進行通信，接下來根據圖 13-19
所示的通信方式對例 13-11 的服務端程序進行改進，如例 13-12 所示。
例 13-12 Example06.java
import java.io.*;
import java.net.*;
public class Example06 {
public static void main(String[] args) throws Exception {
new TCPServer().listen(); // 創建 TCPServer 對象，并調用 listen()方
法
}
}
// TCP 服務端
class TCPServer {
private static final int PORT = 7788; // 定義一個靜態常量作為端口號
public void listen() throws Exception {
// 創建 ServerSocket 對象，監聽指定的端口
ServerSocket serverSocket = new ServerSocket(PORT);
// 使用 while 循環不停的接收客戶端發送的請求
while (true) {
// 調用 ServerSocket 的 accept()方法與客戶端建立連接
final Socket client = serverSocket.accept();
// 下面的代碼用來開啟一個新的線程
new Thread() {
public void run() {
OutputStream os; // 定義一個輸出流對象
try {
os = client.getOutputStream(); // 獲取客戶端的輸出
流
System.out.println("開始與客戶端交互數據");
os.write(("傳智播客歡迎你！").getBytes());
Thread.sleep(5000); // 使線程休眠
5000 毫秒
System.out.println("結束與客戶端交互數據");
os.close(); // 關閉輸出流
client.close(); // 關閉 Socket 對
象
} catch (Exception e) {
e.printStackTrace();
}
};
}.start();
}
}
}
例 13-12 中，使用多線程的方式創建了一個服務器端程序。通過在 whlie 循環中調用
accept()方法，不停地接收客戶端發送的請求，當與客戶端建立連接后，就會開啟一個新的
線程,該線程會去處理客戶端發送的數據，而主線程仍處于繼續等待狀態。
為了驗證服務器端程序是否實現了多線程，首先運行服務器端程序(例 13-12)，之后運行
三個客戶端程序<例 13-11)，當運行第一個客戶端程序時，服務器端馬上就進行數據處理，
打印出"開始與客戶端交互數據"，再運行第二個和第三個客戶端程序，會發現服務器端也
立刻做出回應.兩個客戶端會話結束后分別打印各自結束信息，如圖 13-20 所示。這說明通

過多線程的方式，可以實現多個用戶對同一個服務器端程序的訪問。

上一篇：

Java簡單的 TCP 網絡程序

下一篇：

Java TCP 案例-文件上傳