Java 多執行緒伺服器程式設計實戰：基於 ServerSocket 與執行緒池的高併發架構

前言：Java 網路編程的天然優勢

Java 誕生於網路時代，java.net 套件提供了跨平台、高層抽象的網路 API。多執行緒伺服器 是 Java 網路編程的經典模式：主執行緒監聽連接 (ServerSocket.accept())，每新連接派生一個工作執行緒處理業務邏輯，實現併發服務。本文從 ServerSocket 核心 API、單執行緒/多執行緒架構對比、執行緒池優化、NIO.2 非阻塞演進、生產級最佳實踐五個維度，系統構建 Java 多執行緒伺服器開發知識體系。

一、ServerSocket 核心 API 深度解析

public class ServerSocket {
    // 建構子：綁定埠口，backlog 指定作業系統待連接佇列長度
    public ServerSocket(int port) throws IOException
    public ServerSocket(int port, int backlog) throws IOException
    public ServerSocket(int port, int backlog, InetAddress bindAddr) throws IOException

    // 核心：阻塞等待客戶端連接，返回雙向通訊 Socket
    public Socket accept() throws IOException

    // 配置與查詢
    public void setSoTimeout(int timeout) // accept 超時，拋 SocketTimeoutException
    public InetAddress getInetAddress()   // 綁定的本地 IP
    public int getLocalPort()             // 綁定的本地埠
    public void close() throws IOException // 關閉監聽
}

關鍵參數選擇

• 埠口：避開 0-1023 (系統保留)，建議 8000-65535，生產環境配置檔外部化。
• backlog：TCP 三次握手完成但未被 accept() 取走的連接佇列長度。Linux 預設 /proc/sys/net/core/somaxconn (通常 128/4096)。高併發建議 1024+。
• bindAddr：多網卡指定綁定 IP (如 127.0.0.1 僅本機、0.0.0.0 全介面)。

二、架構演進：從單執行緒到執行緒池

2.1 單執行緒阻塞模型 (教學用)

while (true) {
    Socket client = serverSocket.accept(); // 阻塞
    handleRequest(client); // 串行處理，前一個未完成後續等待
}

缺陷：無併發能力，長請求阻塞所有後續連接。

2.2 每請求一執行緒

while (true) {
    Socket client = serverSocket.accept();
    new Thread(() -> handleRequest(client)).start(); // 或 Thread.start()
}

缺陷：執行緒創建/銷毀開銷大，無限制創建導致 OOM、CPU 抖動、GC 風暴。

2.3 執行緒池模式 (生產標準)

// 固定大小池，有界佇列，拒絕策略
ExecutorService pool = new ThreadPoolExecutor(
    corePoolSize, maximumPoolSize, keepAliveTime, TimeUnit.SECONDS,
    new LinkedBlockingQueue<>(queueCapacity),
    new ThreadFactoryBuilder().setNameFormat("worker-%d").build(),
    new ThreadPoolExecutor.AbortPolicy() // 或 CallerRunsPolicy
);

// 主迴圈
while (!shutdown) {
    try {
        Socket client = serverSocket.accept();
        pool.execute(() -> {
            try { handleRequest(client); } 
            catch (Exception e) { log.error("處理請求異常", e); }
            finally { try { client.close(); } catch (IOException ignored) {} }
        });
    } catch (SocketTimeoutException e) { /* 定期檢查 shutdown 標誌 */ }
    catch (IOException e) { if (!shutdown) log.error("Accept 失敗", e); }
}

// 關閉流程
pool.shutdown(); // 拒絕新任務，處理完佇列
pool.awaitTermination(60, TimeUnit.SECONDS); // 等待執行中任務完成

2.4 執行緒池關鍵配置建議

三、請求處理模板：資源安全與協定解析

void handleRequest(Socket client) {
    // 設定讀寫超時，防止惡意/殭屍連接佔用資源
    try {
        client.setSoTimeout(30000); // 30 秒無資料傳輸則超時
    } catch (SocketException e) { log.warn("設定超時失敗", e); }

    try (InputStream in = client.getInputStream();
         OutputStream out = client.getOutputStream()) {

        // 1. 讀取請求 (協定解析：HTTP、自定義二進制、文本行...)
        Request req = parseRequest(in);
        
        // 2. 業務邏輯處理
        Response resp = processBusiness(req);
        
        // 3. 寫入回應
        writeResponse(out, resp);
        out.flush();

    } catch (SocketTimeoutException e) {
        log.warn("客戶端 {} 讀寫超時", client.getRemoteSocketAddress());
    } catch (IOException e) {
        log.error("IO 異常", e);
    } catch (Exception e) {
        log.error("業務處理異常", e);
        // 可選：寫入錯誤回應
    } finally {
        // try-with-resources 自動關閉 in/out，Socket 需顯式關閉
        try { client.close(); } catch (IOException ignored) {}
    }
}

四、優雅關閉：訊號處理與資源釋放

volatile boolean shutdown = false;

// 註冊關閉鉤子 (SIGTERM, SIGINT, System.exit)
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
    shutdown = true;
    try { serverSocket.close(); } catch (IOException ignored) {} // 喚醒 accept()
    pool.shutdown();
    try { 
        if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
            pool.shutdownNow(); // 強制中斷執行中任務
        }
    } catch (InterruptedException e) { pool.shutdownNow(); }
}));

五、現代演進：NIO 非阻塞與 Netty

傳統 BIO (Blocking I/O) 一連接一執行緒，C10K 問題 (萬級連接) 下執行緒開銷成為瓶頸。

5.1 Java NIO (New I/O / Non-blocking I/O)

• ServerSocketChannel + Selector：單執行緒多路複用，事件驅動。
• 適用於長連接、高併發、低業務邏輯複雜度場景 (如閒聊伺服器、代理)。
• 編程模型複雜 (半包/粘包、狀態機、ByteBuffer 管理)。

5.2 Netty: 企業級 NIO 框架

// Netty 4.x 簡易 Echo Server
EventLoopGroup boss = new NioEventLoopGroup(1);
EventLoopGroup worker = new NioEventLoopGroup();
try {
    ServerBootstrap b = new ServerBootstrap();
    b.group(boss, worker)
     .channel(NioServerSocketChannel.class)
     .childHandler(new ChannelInitializer() {
         protected void initChannel(SocketChannel ch) {
             ch.pipeline().addLast(new EchoServerHandler());
         }
     });
    ChannelFuture f = b.bind(8080).sync();
    f.channel().closeFuture().sync();
} finally {
    boss.shutdownGracefully();
    worker.shutdownGracefully();
}

Netty 優勢：零拷貝、記憶體池、編解碼器管線、SSL/TLS、HTTP/2、WebSocket、優雅關閉、流量整形、完善的檢測工具。

六、生產級檢查清單

1. ✅ 埠口、執行緒池參數**外部化配置** (YAML/Properties/Config Center)。
2. ✅ **監控指標**：活躍連接數、執行緒池佇列長度、拒絕任務數、平均處理延遲、錯誤率 (Prometheus + Grafana)。
3. ✅ **日誌追蹤**：請求 ID 鏈路追蹤 (MDC)、結構化日誌 (JSON)、錯誤堆疊完整保留。
4. ✅ **安全防護**：連接頻率限制 (Token Bucket)、IP 黑白名單、TLS 加密、輸入驗證防注入。
5. ✅ **優雅降級**：熔斷器、限流器、超時控制、快取旁路。
6. ✅ **壓力測試**：預上線必跑 JMeter/wrk/locust，驗證目標 QPS、P99 延遲、錯誤率、資源使用率。

結語

Java 多執行緒伺服器從 ServerSocket + Thread 起步，經歷 ExecutorService 執行緒池優化，邁向 NIO 非阻塞與 Netty 等高性能框架。**核心思想始終不變：主執行緒專職 Accept，工作執行緒/EventLoop 專職處理，資源池化控制併發度，超時與優雅關閉保障穩定性**。根據業務場景 (短連接高併發 vs 長連接低頻、CPU 密集 vs IO 密集、團隊技術棧) 選擇合適架構，並在可觀測性、安全性、運維友好度上持續投入，才是構建企業級高可用網路服務的正道。

1. 上一篇文章： Java 並發編程核心組件自製：信號量與管道流深度實現
2. 下一篇文章： Java Swing 多執行緒實現等待提示對話框：避免 UI 凍結的最佳實踐

Java 程式設計入門

Servlet 與 JSP 開發原則：分離表現與邏輯

Servlet/JSP 是 Java 伺服器端開發核心技術。

Java 資料庫事務處理實戰：JDBC 本地事務與 JTA 分散式事務對比

事務基礎回顧：ACID 原則 原子性：事務內所有操作要么全

深入淺出Java代理設計模式：原理、分類與實戰

引言：生活中的代理模式 逛電腦市場升級硬體時，資深DIY玩家

JDK 動態代理機制全流程圖解：從 InvocationHandler 到 $Proxy0 誕生

動態代理三大核心組件 目標對象：實現業務邏輯的真實類 (U