Java Socket 編程核心技術：從 URLConnection 到原生 Socket 實戰

前言：Java 網絡編程三大核心類

java.net 包提供了網絡編程基礎支撐，核心三大類分工明確：

• URLConnection：高層抽象，面向 Web 資源訪問，屏蔽底層 Socket 細節
• Socket：客戶端雙向通信端點，支撐 TCP 連接
• ServerSocket：服務端監聽端點，接受客戶端連接請求

本文從高層 URLConnection 切入，逐步深入核心機制。

一、URLConnection：零感知使用 Socket

1.1 四步訪問流程

1. 創建 URLConnection 實例
2. 配置請求參數（各類 setter 方法）
3. 建立連接 connect()
4. 交互響應數據（各類 getter 方法）

1.2 實戰：構建通用 HTTP 客戶端

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

public class URLClient {
    protected URLConnection connection;

    public static void main(String[] args) {
        URLClient client = new URLClient();
        String yahoo = client.getDocumentAt("https://www.yahoo.com");
        System.out.println(yahoo);
    }

    public String getDocumentAt(String urlString) {
        StringBuilder document = new StringBuilder();
        try {
            URL url = new URL(urlString);
            URLConnection conn = url.openConnection();
            
            // 流包裝鏈：InputStream → InputStreamReader → BufferedReader
            BufferedReader reader = new BufferedReader(
                new InputStreamReader(conn.getInputStream())
            );
            
            String line;
            while ((line = reader.readLine()) != null) {
                document.append(line).append("\n"); // 保留原始換行格式
            }
            reader.close();
        } catch (MalformedURLException e) {
            System.err.println("無效 URL: " + urlString);
        } catch (IOException e) {
            System.err.println("連接異常: " + urlString);
        }
        return document.toString();
    }
}

1.3 關鍵技術點解析

• 流包裝模式：BufferedReader(new InputStreamReader(conn.getInputStream())) 是 Java IO 處理網絡流的標準套路，必須熟練掌握
• readLine() 阻塞特性：遇到行終止符（\n/\r\n）返回，連接關閉返回 null，無數據時持續阻塞
• 異常處理：MalformedURLException（URL 格式錯誤）、IOException（網絡/IO 錯誤）需分別捕獲

二、Socket 客戶端：TCP 雙向通信實戰

2.1 核心步驟

1. 創建 Socket(host, port) 建立連接
2. 獲取輸出流發送數據，輸入流接收響應
3. 業務邏輯處理
4. 關閉流與 Socket

2.2 代碼範例：簡易 Echo 客戶端

public class SocketClient {
    public static void main(String[] args) throws IOException {
        String host = "localhost";
        int port = 8888;
        
        try (Socket socket = new Socket(host, port);
             PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
             BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
             BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in))) {
            
            String userInput;
            while ((userInput = stdIn.readLine()) != null) {
                out.println(userInput);        // 發送
                System.out.println("Server: " + in.readLine()); // 接收回顯
            }
        }
    }
}

三、ServerSocket 服務端：併發處理架構

3.1 基礎監聽循環

public class SocketServer {
    public static void main(String[] args) throws IOException {
        int port = 8888;
        try (ServerSocket serverSocket = new ServerSocket(port)) {
            System.out.println("Server started on port " + port);
            while (true) {
                Socket clientSocket = serverSocket.accept(); // 阻塞等待連接
                // 單線程處理（生產環境需改為線程池）
                new Thread(new ClientHandler(clientSocket)).start();
            }
        }
    }
}

class ClientHandler implements Runnable {
    private final Socket socket;
    ClientHandler(Socket socket) { this.socket = socket; }
    
    @Override
    public void run() {
        try (BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
             PrintWriter out = new PrintWriter(socket.getOutputStream(), true)) {
            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                out.println("Echo: " + inputLine);
            }
        } catch (IOException e) {
            System.err.println("Client handling error: " + e.getMessage());
        }
    }
}

3.2 生產級優化要點

• 線程池：使用 ExecutorService 替代 new Thread()，控制併發數
• NIO/Netty：高併發場景建議遷移至非阻塞 I/O 模型
• 協議設計：定義明確的應用層協議（長度前綴、分隔符、序列化格式）
• 優雅關閉：實現 shutdown hook，處理在飛請求

四、進階主題：URLConnection vs Socket 選型指南

五、常見坑與最佳實踐

• 流關閉順序：先關閉外層包裝流，底層流會自動關閉；try-with-resources 自動管理
• 編碼一致性：客戶端/服務端雙方指定相同 Charset（推薦 UTF-8）
• 超時設置：socket.setSoTimeout(ms) 防止讀取無限阻塞；connection.setConnectTimeout()
• 緩衝區大小：大數據傳輸調整 socket.setSendBufferSize()/setReceiveBufferSize()
• 半包/粘包：TCP 流無邊界，應用層必須實現消息幀解析（長度頭、特殊分隔符）

六、總結

Java 網絡編程從 URLConnection 的高層便利到 Socket/ServerSocket 的底層掌控，層層遞進。掌握流包裝模式、阻塞特性、併發處理模型與協議設計，是構建穩健網絡應用的基石。現代高併發場景建議直接採用 Netty 等成熟 NIO 框架，但理解原生 Socket 機制仍是排查疑難雜症、優化性能的前提。