.jpg)
在Java中實(shí)現(xiàn)客戶端和服務(wù)器通信的關(guān)鍵在于使用java.net包中的serversocket和socket類。1. 服務(wù)器端通過(guò)serversocket監(jiān)聽端口，調(diào)用accept()接收客戶端連接，并通過(guò)socket進(jìn)行數(shù)據(jù)讀寫；2. 客戶端使用socket連接服務(wù)器，通過(guò)輸入輸出流發(fā)送和接收數(shù)據(jù)；3. 為支持多個(gè)客戶端，服務(wù)器可為每個(gè)連接開啟新線程處理，或使用線程池管理資源；4. 可選地，定義應(yīng)用層協(xié)議如消息結(jié)束符或結(jié)構(gòu)化格式以提升數(shù)據(jù)處理能力。整個(gè)過(guò)程中需注意資源釋放、異常處理及多線程同步問(wèn)題。
在Java中實(shí)現(xiàn)客戶端和服務(wù)器之間的簡(jiǎn)單通信，主要依靠的是java.net包中的類。核心思路是：服務(wù)器監(jiān)聽某個(gè)端口，等待客戶端連接；客戶端主動(dòng)發(fā)起連接，發(fā)送或接收數(shù)據(jù)。下面分幾個(gè)關(guān)鍵步驟來(lái)說(shuō)明如何操作。
1. 創(chuàng)建服務(wù)器端（Server）
要?jiǎng)?chuàng)建一個(gè)簡(jiǎn)單的服務(wù)器，通常使用ServerSocket類來(lái)監(jiān)聽端口，當(dāng)有客戶端連接時(shí)，通過(guò)accept()方法獲取一個(gè)Socket對(duì)象，然后就可以通過(guò)這個(gè)對(duì)象進(jìn)行數(shù)據(jù)的讀寫。
示例代碼結(jié)構(gòu)如下：
立即學(xué)習(xí)“Java免費(fèi)學(xué)習(xí)筆記（深入）”；
ServerSocket serverSocket = new ServerSocket(8888); // 監(jiān)聽8888端口 Socket socket = serverSocket.accept(); // 等待客戶端連接 // 獲取輸入流，讀取客戶端發(fā)來(lái)的消息 BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); String msg = in.readLine(); System.out.println("收到：" + msg); // 關(guān)閉資源 in.close(); socket.close(); serverSocket.close();
注意點(diǎn)：accept()會(huì)阻塞線程直到有客戶端連接上來(lái)每個(gè)連接建議單獨(dú)開線程處理，否則只能處理一次連接不要忘記關(guān)閉資源，尤其是流和Socket
2. 編寫客戶端（Client）
客戶端使用Socket類來(lái)連接服務(wù)器，并通過(guò)輸入輸出流與服務(wù)器通信。比如可以使用PrintWriter發(fā)送消息，用BufferedReader接收響應(yīng)。
基本寫法：
Socket socket = new Socket("127.0.0.1", 8888); // 連接本地服務(wù)器的8888端口 // 發(fā)送消息 PrintWriter out = new PrintWriter(socket.getOutputStream(), true); out.println("Hello Server!"); // 接收回應(yīng) BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); String response = in.readLine(); System.out.println("服務(wù)器回應(yīng)：" + response); // 關(guān)閉資源 out.close(); in.close(); socket.close();
常見問(wèn)題：
- 如果服務(wù)器沒啟動(dòng)，客戶端連接會(huì)拋出異常
- 客戶端發(fā)送完消息后如果沒有讀取回應(yīng)就直接關(guān)閉，可能收不到回復(fù)
- 建議先運(yùn)行服務(wù)器再運(yùn)行客戶端
3. 使用多線程支持多個(gè)客戶端
上面的例子只能處理一個(gè)客戶端連接。如果想讓服務(wù)器能同時(shí)處理多個(gè)請(qǐng)求，就需要為每個(gè)連接開啟一個(gè)線程。
實(shí)現(xiàn)方式：
- 服務(wù)器主循環(huán)持續(xù)調(diào)用accept()
- 每次得到新的Socket后，新建一個(gè)線程處理該連接
- 在線程內(nèi)部完成讀寫操作
while (true) { Socket socket = serverSocket.accept(); new Thread(() -> { try { BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream())); String msg = in.readLine(); System.out.println("收到：" + msg); socket.close(); } catch (IOException e) { e.printStackTrace(); } }).start(); }
小技巧：
- 可以給線程起個(gè)名字方便調(diào)試
- 多線程環(huán)境下注意共享資源同步問(wèn)題
- 也可以使用線程池管理線程資源，避免頻繁創(chuàng)建銷毀
4. 選擇合適的協(xié)議格式（可選）
雖然TCP已經(jīng)保證了數(shù)據(jù)傳輸?shù)目煽啃裕氵€需要自己定義“應(yīng)用層協(xié)議”，比如：
這一步不是必須的，但在實(shí)際項(xiàng)目中非常有用，尤其當(dāng)你需要處理復(fù)雜數(shù)據(jù)時(shí)。
基本上就這些。Java網(wǎng)絡(luò)編程入門不難，但要穩(wěn)定可靠地用好，細(xì)節(jié)還是挺多的。
.png)
